Результаты поиска по запросу "apache-kafka"
использование протокола mqtt с kafka в качестве посредника сообщений
Как мы можем использовать протокол mqtt с kafka в качестве посредника сообщений?Клиенты (java-приложения android / ios / desktop и т. Д.) Будут создавать и п...
Ошибка Кафки в операциях ввода-вывода java.io.EOFException: null
Я использую Kafka 0.8.2.0 (Scala 2.10). В моих файлах журнала я периодически вижу следующее сообщение. Это похоже на проблему с подключением, но я работаю на...
Как удалить тему в apache kafka [дубликаты]
На этот вопрос уже есть ответ здесь:Удалить тему в Кафке 0.8.1.1 13 ответовМне нужно удалить тему в kafka-0.8.2.2.3. Я использовал следующую команду для удал...
Kafka 0.8.2.2 - Невозможно публиковать сообщения
Мы написали Java-клиент для публикации сообщения для Кафки. Код, как показано ниже
Как я могу использовать Kafka для сохранения журналов в logstash в течение более длительного периода?
В настоящее время я использую redis -> s3 - >astic search -> kibana stack для передачи и визуализации моих логов. Но из-за большого объема данных в ...
Кафка-потребитель 0.9 обратно совместим?
Будет ли новый клиент 0.9.x для kafka совместимым с брокером 0.8?Другими словами - можно только перейти на новую потребительскую реализацию, не затрагивая ни...
Не удалось найти лидеров для Set ([TOPICNNAME, 0])), когда мы работаем в Apache Saprk
Мы используем Apache Spark 1.5.1 и kafka_2.10-0.8.2.1 и Kafka DirectStream API для извлечения данных из Kafka с использованием Spark.Мы создали темы в Кафке ...
Кафка как читать из темы __consumer_offsets
Я пытаюсь выяснить, с какими смещениями работают мои нынешние потребители высокого уровня. Я использую Кафку 0.8.2.1, снет «offset.storage» установлен в serv...
Кафка тема больше не существует после перезагрузки
Я создал тему в своем локальном кластере kafka с 3-мя серверами / брокерами, выполнив следующую команду из моего каталога установки kafka