apache-kafka

4зной

3ответ

Kafka bootstrap-servers vs zookeeper в kafka-console-consumer

Я пытаюсь протестировать один узел Kafka с 3 брокерами & zookeeper. Я хочу проверить с помощью консольных инструментов. Я бег производителя как таковые: kafka-console-producer --broker-list localhost:

0зной

1ответ

librdkafka C++ API custom logger funcrtion

Я использую API librdkafka C++, и я хотел бы изменить поведение по умолчанию для регистратора (по умолчанию - stderr). В документации по конфигурации указано, что я могу изменить функцию log_cb, но я

4зной

3ответ

Подсчет Количество сообщений, хранящихся в теме kafka

Я использую версию kafka 0.9.0.0, и я хочу подсчитать количество сообщений в теме kafka без использования сценария администратора kafka-console-consumer.sh. Я пробовал все команды в ответе Java, How t

3зной

1ответ

Интеграция Apache Kafka с tomcat и весной

Я новичок в kafka, я думаю об интеграции очереди сообщений kafka с входящим HTTP-запросом и потреблением в моем веб-приложении. здесь мой вопрос заключается в том, как захватить входящий запрос в tomc

8зной

1ответ

Динамическое подключение входного потока Kafka к нескольким выходным потокам

Есть ли встроенная функция в потоки Kafka, которая позволяет динамически подключать один входной поток к нескольким выходным потокам? KStream.branch позволяет разветвляться на основе истинных/ложных п