Я только что заметил, что когда я создаю одно сообщение в раздел, мой потребитель не получает его....

Версии: "org.apache.storm" % "storm-kafka-client" % "1.2.1" "org

У меня есть тема Kafka Avro, созданная с помощью KafkaAvroSerializer. Мои автономные свойства, как...

Я пытаюсь запустить Kafka в режиме кластера, используя два экземпляра реестра схемы, но я не совсем...

На веб-сайте конфигурации докера конфлуента , касающемся идентификатора open-source / enterprise,...

У меня есть этот код, который загружается, когда запускается мой узел, я просто изменил этот код с...

Мы настроили экземпляр kafka и включили шифрование. При попытке подключиться к брокеру Kafka с...

Я использую кластер Kafka на 3 экземплярах EC2. Каждый экземпляр запускает kafka (0.11.0.1) и...

Я работаю над небольшим проектом, использующим SpringBoot для извлечения данных из Kafka и передачи...

Я сейчас нахожусь в проекте, где используются JPA и Kafka. Я пытаюсь найти набор хорошей практики...

Было сказано, что потребители могут читать только всю тему. Не повезло в оценке брокеров для...

Я пытаюсь протестировать приложение Spring Cloud Streams и Kafka Streams, используя предоставленный...

Я много читал о трех упомянутых системах. Но я все еще не уверен, что использовать. Кажется, все...

Я пытаюсь запустить kafka connect в распределенном режиме для чтения из темы и записи в HDFS....

Я включил аутентификацию Kerberos на Kafka 1.0. Когда я пытаюсь выполнить kafka-run-class.sh kafka

Я использую фреймворк spring-kafka для реализации слушателя kafka. В настоящее время я читаю из...

Я бы хотел направить сообщение на основе значения поля. Я использую соединитель JDBC для извлечения...

Я хочу получить метку времени запуска окна (здесь это 1530008520000) из команды...

У меня есть пользовательский потребитель Kafka, в котором я использую для отправки некоторых...

Я знаю, что могу очистить тему Kafka в брокере, либо удалив журналы в / data / kafka-logs / topic /...

Что происходит с сообщениями, которые успешно записываются в раздел лидера на Kafka Broker 1, и...

Я хочу ограничить скорость при извлечении данных из кафки.Мой код выглядит так: df = spark.read

Моя тема кафки состоит в передаче данных в этом формате (начиная с collectd ):...

Я управляю супервизором.Перечитайте и перезапустите успешно.Тем не менее, когда я запускаю команду:...

Я пробую Кафку с Postgres Sink, используя JDBC-коннектор приемника. Исключение: INFO Unable to...