У меня 4 раздела и 4 потребителя (например, A, B, C, D).Как настроить, какой потребитель будет...

Я работаю с Kafka Consumer и подписываюсь только на одну тему.Я хочу вернуть только назначенные...

У меня есть приложение Java 8, работающее с Apache Kafka 2.11-0.10.1.0.Мне нужно использовать...

У нас есть Node, а приложения Java используют клиенты Kafka. В настоящее время требуется получить...

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

У меня установлено два брокера Kafka 2.1.0 на одном хосте Windows.Коэффициент репликации по...

Я использую клиентскую библиотеку .NET из Confluent. Мне нужно подключиться к теме и прочитать...

У нас были процессоры, которые передают смещение через производителя для достижения точной...

@Bean public ConsumerFactory<String,String> consumerFactory() { Map<String, Object>...

у нас есть один потребитель кафки, который постоянно опрашивает тему кафки и обрабатывает сообщения

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

Я супер новичок в Кафке, и я, честно говоря, понятия не имею об этом типе потребителя (насколько я...

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

могут ли два файла conf logstash, запущенные из одного и того же экземпляра, считываться из одной и...

Я использую spring-kafka 2.1.10. ВЫПУСК.У меня есть потребитель со следующими свойствами...

Если kafka enable.auto.commit=true, значит ли это, что каждые 5 секунд он будет запускать...

Я написал код приложения, в котором есть продюсер и потребительская часть одного и того же процесса

Я использую клиент kafka-node для публикации и подписки на kafka. Я хочу получить конкретное...

Я подписался на тему Кафки, как показано ниже. Мне нужно запустить некоторую логику только после...

Я нахожусь в процессе настройки мониторинга для потребителей и брокеров кафки. Мониторинг серверных...

Наша настройка kafka выглядит следующим образом: 30 разделов на тему 1 потребительский поток мы...

Я играю с Кафкой, пытаюсь справиться с этим.Одна из вещей, которую мы должны уметь делать - это...

У меня есть тема Кафки и один раздел. Когда я создаю потребителя, упускается упоминание группы .id....

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

Иногда (кажется очень случайным) Кафка отправляет старые сообщения.Я хочу только самые последние...