Я хочу создать простое приложение, основанное на данных датчика, с Apache Kafka. Мой вопрос очень...

Как создать новый Kafka Producer из существующего Consumer с Java?

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

Если я сам использую свою тему и управляю смещением, некоторые обрабатываемые мной записи успешны,...

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

мы настроили кластер Kafka с одним узлом и запустили приложение потребителей на другом сервере...

У меня есть тема customer-avro в кластере kafka со списком брокеров kafka1.com:9092,kafka2.com:9092...

Я читаю Кафка, полное руководство , и в главе «Потребители» есть реклама «Повторные попытки...

У нас есть реализация Kafka около 40 тем, и каждая тема имеет 40 разделов и 3 репликации. У нас...

У меня есть приложение "потреблять-преобразовывать-производить" с единовременной скемантикой в...

Я просто отчаянно ищу пример кода для адаптера Esper CEP Kafka. Я уже установил Kafka и записал...

У меня есть одна тема Кафки и четыре группы потребителей. В каждой группе может быть разное...

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

Я учу кафку с простым потребителем. Я настроил неправильный URL сервера. При использовании метода...

Я нашел свойство auto.offset.reset = самое раннее или auto.offset.reset = самое последнее. Теперь...

У меня есть потребитель, который опрашивает несколько тем. Для этого вопроса я ограничил один...

Если потребители Kafka принимают сообщения в режиме синхронизации, но их зависимый нисходящий...

Кафка - нескольким потребителям из одной группы назначен один и тот же раздел Я только начал...

У меня есть требование переигрывать старые смещения Кафки в случае любой проблемы. Есть ли весной...

Я создал кафку с 3 брокерами с 3 коэффициентами репликации. Я пытался работать с kafka, постоянно...

Flink позволяет читать из темы Кафки, это узкое место в производительности, делающее Flink...

Недавно у меня возникли некоторые проблемы при использовании пользовательских AIP-файлов kafka, и...

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

Я пытаюсь реализовать базовый сценарий, перечитать тему с начала (хотя бы 1 сообщение), и я...

Я настроил kafka-connect-spooldir для использования файлов, содержащих объекты JSON, в соответствии...