Я разрабатываю приложение на основе kafka, в котором слушатель kafka будет прослушивать запись; как...
В Кафке я могу разбить свою тему на множество разделов. У меня не может быть больше потребителей,...
Я настроил своего продюсера kafka заново, следуя инструкции, упомянутой здесь: https://www
У меня есть один экземпляр клиента kafka, который потребляет 200 разделов, теперь я хочу, чтобы он...
Я пытаюсь отладить проблему, для которой я пытаюсь доказать, что каждый отдельный ключ идет в 1...
Мы подписываемся на производителя кафки с нашим потребителем, и в нашей реализации мы застряли...
Я пытаюсь читать сообщения Кафки, используя потребителя Кафки в jmeter, используя сэмплер jsr223. я...
В случае интеграционного тестирования я отправляю запись в Kafka и хотел бы знать, когда она будет...
Я использую kafka-console-consumer для изучения темы кафки. Периодически я получаю это сообщение об...
Мне нужна помощь в создании тестового примера Junit для моего потребителя Java-кафки. Исходный код...
есть ли какой-либо клиент администратора Python kafka, который может создавать темы / удалять темы...
Мне трудно найти простые шаблоны для обработки исключений в теме кафки. Сценарий таков: у...
Я пытаюсь import KafkaConsumer from kafka. Там написано: нет модуля с именем kafka from kafka...
Я нашел это, где я сбросил свою LAG с помощью инструмента kafka-consumer-groups.sh Как изменить...
В нашей компании мы пытаемся настроить 3node Kafka кластер с SSL-шифрованием и аутентификацией SASL...
Получение ошибки ниже как потребитель к теме кафки. Издатель должен использовать сжатие gzip, а...