kafka-consumer-api

0зной

1ответ

Как написать пробный носик kafka с помощью нового API-интерфейса Kafka?

Нравится шторм-кафка-клиент, меня использовал штормовой кафка-клиент, но он не может хорошо работать, а новый носик тоже не работает. Кто может помочь мне написать пробный кафка.

0зной

1ответ

сообщения, опубликованные всем потребителям с той же группой потребителей в проекте spring-data-stream

У меня есть мой зооператор и 3-х кафковый брокер, работающий локально. Я запустил одного производителя и одного потребителя. Я вижу, что потребитель потребляет сообщение. Затем я запустил трех потреби

0зной

1ответ

Найти последнее сохраненное поручены смещение в низком уровне потребителя

Привет Ниже приведен код для моего потребителя, $conf->set('group.id','commonqueue2'); $conf->set('offset.store.method', 'broker'); $rk = new \RdKafka\Consumer($conf); $rk->addBrokers(

2зной

1ответ

kafka new api 0.10 не предоставляет список потоков и потребительских объектов по одной теме

Раньше я использовал 0.8 API. Когда вы передаете ему список тем, он возвращает карту потоков (по одной записи для каждой темы). Это позволяет мне создавать отдельный поток и назначать поток каждой тем

0зной

1ответ

Где определить количество потребителей для конкретной группы потребителей?

Я работаю над Spark Streaming, чтобы потреблять данные от Kafka. Если у меня есть DirectStream, у меня нет опций для определения consumer group и number of consumers. Например: val messages = KafkaUti

0зной

1ответ

Получение NoSuchMethodError в Kafka Consumer v0.10.0.1

Я пытаюсь перейти на KafkaClient 0.10.0.1 из 0.9.0.0. Код работает отлично в производстве с 0.9.0.0. Теперь тот же код в платформе разработки бросает исключение, когда пользователь запускается со след