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

Когда мы инициализируем EmbeddedKafkaBroker с: EmbeddedKafkaBroker embeddedKafkaBroker = new...

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

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

У меня есть тема с 10 разделами, и я генерирую события с A,B,C,D,E,F,G,H,I 9 различными ключами. Я...

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

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

У меня просто небольшая проблема с размером файла, отправляемого flume на kafka. Я не знаю, где...

Я использую следующую команду для запуска службы Kafka. Когда я нажимаю Enter, создается новая...

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

У меня есть приложение с блоками кода Spring-Kafka и Native Kafka. краткая логика: My Spring Kafka...

Где бы вы предпочли публиковать события, содержащие только измененные данные (т.е. 2 атрибута), а...

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

мы создали сеть фабрики гиперледеров с kafka as (OSN) с использованием docker swarm, однако мы не...

Я хочу использовать схемы apache avro для сериализации и десериализации данных. Я хочу использовать...

Когда я выкидываю сообщения Kafka в Windows cmd с помощью следующей команды: kafka-console-consumer...

Я должен установить IP-адрес zookeeper в ConsumerGroup вместо IP-адреса Kafka-Host. Потому что я...

Я пытаюсь сравнить Spark и Kafka с Flink.Когда я запускаю тестовый код локально, все работает...

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

Я пытаюсь перейти с прослушивателя SSL Kafka на прослушиватель SASL_SSL Kafka, не нарушая текущий...

Мы используем темы кафки классическим способом. Много раз мы сталкивались с необходимостью обновить...

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

Я пытаюсь использовать Кафку: import java.util.Properties; import org.apache.kafka.clients.producer

Итак, я защитил кластер kafka с помощью механизма безопасности ниже server.properties и добавил...

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