Что происходит, когда несколько экземпляров одного приложения с одинаковым идентификатором группы...
При самом первом потреблении мой потребитель потребляет одно и то же сообщение дважды, это...
Я хочу создать отдельную очередь для каждой темы в Кафке.Это возможно или возможно?
Я не могу понять из документации, какое свойство теперь заменяет consumer.timeout.ms = -1 (по...
Если все мои сообщения kafka содержат уникальный ключ, каким будет самый быстрый способ запросить...
хочу подключить внешнюю тему кафки, предоставленную вендором;поскольку мы уже разработали сервис...
Я разрабатываю потребительский API kafka, который использует мои сообщения из темы.Когда он...
Когда я пытаюсь соединить сливной кластер Kafka с простым потребительским кодом, используя Scala....
В настоящее время я ищу решения для неожиданного поведения при работе с конкретными сценариями...
Я сталкиваюсь с org.apache.kafka.common.errors.InvalidGroupIdException: Чтобы использовать API...
Мне нужны предложения альтернатив Spring-Kafka. Я использовал Kafka, интегрированный в Spring, в...
Итак, я получил несколько досадных компромиссов с моими потребителями кафки.Я использую...
У меня фиксированное количество разделов темы. Производители производят данные с разной скоростью в...
Я использую Кафку уже несколько месяцев, и я понял, что некоторые из основных понятий мне пока не...
Смещение сбрасывается, когда одна тема используется двумя разными группами потребителей. Я...
Вот мой потребительский конфиг.Я использую SSL для аутентификации. consumer =...
Я работаю с Paf над POC и изучаю уникальные функции, используя транзакционный API, и все еще...
Там есть файл журнала, который доставляет сообщение из FluentD в Kafka (FluentD -> Kafka)....
У меня есть вариант использования, когда потребитель должен использовать минимум n записей, чтобы...
У меня есть одно приложение Kafka Streams (V 2.1.1), которое создает записи и помещает их в тему...
Я хочу знать отставание потребителей для группы потребителей, использующих Java. Я пытался...
Проходя по этому сайту, я создал Kafka Producer и Kafka Consumer https://www.tutorialkart
Я пытаюсь интегрировать MongoDB и Storm-Kafka, Kafka Producer производит данные из MongoDB, но не...
Допустим, у нас есть одна тема "topic-1" в kafka с разделом 5. Потребительская группа A с 5...
Мой кластер построил 3 узла. Я создал тему с именем test Тема: тест PartitionCount: 3...