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

Я пытаюсь обновить наш KafkaBroker с 0.10.2 до 1.1.3 , включая формат журнала сообщений. В...

Я пытаюсь разработать Kafka Consumer в Spring Boot.Я могу настроить Kafka Cluster в Kafka Tool и...

У меня есть 2 отдельных док-контейнера.Один (openjdk:alpine) работает под управлением Apache Kafka

У меня есть производитель producer, который хочет отправить some_persistent_message на dbConsumer и...

При использовании java API Kafka 1.0.0 jar-файлы представляют собой kafka_2.11-1.0.0-cp1.jar,...

Mine - это приложение Springboot. В моем коде упругого поиска есть kafka-потребители.Итак, при...

Мне известно, что максимальное количество активных потребителей в группе потребителей - это...

В развертывании Kafka пользовательская логика разделителя тем используется для маршрутизации всех...

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

Рассмотрим этого потребителя Kafka, который получает данные из темы, буферизует их в...

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

В настоящее время я работаю над приложением, которое частично использует Apache Kafka (версия 2.2

В Kafka v 1.x.x и более поздних версиях. Можно ли получить метку времени сообщения, если у меня...

Я пытаюсь запустить kafka-console-consume.sh для темы XXX sh kafka-console-consumer.sh...

Мне нужно использовать конкретное смещение для конкретного конечного смещения!consumer.seek ()...

Я использую ReplyingKafkaTemplate в моем контроллере Rest для возврата синхронного ответа.Я также...

У меня есть SchemaRegistry и KafkaBroker, из которого я беру данные с Avro v1.8.1. Для...

Я пишу в тему вывода, используя KStream.to ("outputtopic"); В документах apache упоминалось, что он...

Согласно моему текущему пониманию Кафки, данные хранятся, и каждое «местоположение магазина»...

Я ищу способы парковки сообщений в хранилище данных после нескольких повторных попыток и...

Клиенты KAFKA (производитель и потребитель) обнаруживают топологию, подключаясь к одному из...

Я пытаюсь описать группу потребителей kafka с помощью приведенной ниже команды в терминале:

У меня есть этот фрагмент кода, который потребляет сообщения от производителя: public class...

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