apache-kafka

1зной

1ответ

Как запросить Spark StreamingContext с искровым sql в zeppelin?

Я пытаюсь использовать искру sql для запроса данных, поступающих из kafka, используя zeppelin для анализа тенденции в реальном времени, но без успеха. здесь простые фрагменты кода, что я бегу в дирижа

1зной

1ответ

Кафка MetricsReporter при поддержке Спринг загрузки привод

я решил вернуться к своей идее интеграции Кафки Метрики с весной загрузки приводом, который я уже упоминал здесь: https://github.com/spring-projects/spring-boot/issues/6227 В настоящее время у меня ес

0зной

1ответ

Обрабатывается только первое сообщение в потоке Кафки

В Spark я создаю поток из Kafka с периодическим временем 5 секунд. За это время может появиться много сообщений, и я хочу обрабатывать каждый из них по отдельности, но кажется, что с моей текущей логи

4зной

2ответ

Apache Kafka создать тему из кода

Как известно, создание в Kafka должно выполняться в части инициализации сервера. Там мы используем сценарий по умолчанию ./kafka-topics --zookeeper ..., но что, если нам нужно динамически создавать те

2зной

1ответ

Как очистить тему узла сообщения?

Часто при разработке с MessageHub я обнаружил, что хочу очистить свои данные разработки от темы. Как я могу очистить тему MessageHub? Этот вопрос похож на Purge Kafka Queue, но отличается тем, что это