Я использую ReplyingKafkaTemplate.Класс DefaultKafkaConsumerFactory использует одного потребителя...

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

Я получаю исключение десериализации при использовании данных из темы Кафки.Я хочу установить...

Я хочу найти конкретные сообщения в теме kafka. Единственное решение, которое я нашел, это...

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

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

Я использую @KafkaListener для потребления из темы kafka, у меня есть логика приложения для...

Я использую kafka: kafka_2.12-2.1.0, подпружиненный kafka на стороне клиента и застрял с проблемой....

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

У меня есть производитель, который выдает несколько сообщений (например, 10).Есть n разделов и...

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

Если два процесса, использующие одну и ту же группу потребителей (group.id), подпишутся на один и...

Я пытаюсь отслеживать данные kafka с помощью yahoo kafka manager, и он работает нормально, без...

Используя Spring Boot, я пытаюсь настроить своих потребителей Kafka в режиме пакетного приема:...

У меня есть следующий кластер Kafka: 1 zk и 2 брокера, 1zk + 1 брокер на одной машине и 2 брокера...

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

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

Я использую Kafka Java API v2.1.Я хочу знать, какие исключения будут распространяться на код...

Я создал сервис SpringBoot, который использует SpringCloud @StreamListener для обработки сообщений...

Последняя версия kafka поддерживает семантику "точно один раз" (EoS).Чтобы поддержать это понятие,...

Я запускаю образ док-станции kafka.Я наблюдаю за отключениями потребителей по тому же конкретному...

Привет! Я создал поток со следующими значениями из темы: "id VARCHAR, src_ip VARCHAR, message...

Я использую Spring KafKa, и я устанавливаю ackMode в MANUAL_IMMEDIATE props

Как найти смещение сообщения в теме Кафки?Содержит ли смещение несколько сообщений или одно...

Приведенный ниже код работает и фиксирует смещение после обработки данных.Но проблема в том, что он...