Я разрабатываю Spring Boot + Apache Kafka + Apache Zookeeper пример.Я установил / setup Apache...

Я проверил документацию по librdkafka и там указано, что set_log_cb может использоваться для...

Я получаю ошибку ниже при запуске Kafka-Server на windows машине.Я скачал Scala 2.11 - kafka_2.11-2

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

моя проблема в том, что я установил 2 брокера kafka и 2 узла zookeeper на разных контейнерах...

Я получаю это Исключение Kafka Storage: остановка из-за неисправимой ошибки ввода-вывода при...

Я пытаюсь подключиться к нескольким брокерам Kafka с помощью Spring Cloud Stream. Во время...

Kafka Quickstart Использование Kafka v2.1.0 на RHEL v6.9 Потребитель не может получить данные,...

Я использую изображение док-станции Landoop Kafka.Я использую его пользовательский интерфейс для...

Я читаю документацию Кафки и пытаюсь понять, как она работает.Это касается потребителей.Вкратце,...

Цель: прочитать все сообщения из темы, а затем прекратить процесс. Я могу непрерывно читать...

Я пытаюсь сохранить метки времени Unix в наносекундах в поле типа Date базы данных Mongodb. Метки...

Я записываю файл в тему kafka через kafka -roduction cli, используя эту команду...

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

Я знаю, что возможно получить последнее смещение kafka, но возможно ли получить метку времени...

Я следовал документации Apache для установки ssl, но столкнулся со следующими ошибками. Причина:...

Я новичок в Kafka, и у меня есть потребитель Kafka, реализованный с использованием библиотеки Java...

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

у нас есть тема Kafka, которая cleanup.policy в настоящее время delete .Сообщения, созданные по...

Я создал тему вручную test с помощью этой команды: bin/kafka-topics.sh --create --zookeeper...

Хотелось бы знать, можем ли мы предоставить некоторые API REST от Kafka, которые можно использовать...

Я настраиваю потребителя kafka следующим образом: private Consumer<String, HistoryEvent>...

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

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

Когда я запускаю эту команду, я получаю 2 темы.Я знаю, что создал тестовую тему, но вижу...