Я создал пример данных опроса конвейера из MySQL и записал их в HDFS (в том числе в таблицу кустов)

Справочная информация: Я установил число разделов по умолчанию = 1 и коэффициент репликации = 3 в...

Данные из исходной системы - abc@abc.com # kafka-avro-console-customer --bootstrap-server...

Я получаю исключение десериализации при использовании данных из темы Кафки.Я хочу установить...

Мы недавно внедрили kerberos в нашем кластере kafka. Клиенты должны использовать SASL_SSL для...

Я новичок в скале и моргании.Я использую следующий код, чтобы использовать сообщение json из потока...

Я хочу найти конкретные сообщения в теме kafka. Единственное решение, которое я нашел, это...

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

Когда StreamListener требуется много времени (дольше, чем max.poll.interval.ms) для обработки...

Как получить потоковую передачу данных из SAP HANA в Кафку в реальном времени?

Я сейчас играю с Spring Boot v2.Пока что мои настройки выглядят так: Весна -> Телеграф -> Кафка ->...

В моем приложении несколько предприятий.при каждом входе в систему предприятия выполняйте некоторые...

Я пытаюсь запустить Кафку с помощью докера. Я запустил службу kafka. docker-compose ps Name Command...

Я использую @KafkaListener для потребления из темы kafka, у меня есть логика приложения для...

Мы используем Kafka Connectors (JDBC и другие) и настраиваем их с помощью REST API (используя curl...

У меня есть список брокеров для моего кластера Kafka.Как я могу получить хост zookeeper, используя...

Я использую метод .poll в своем приложении, у меня много сообщений в моем лаге, но при вызове .poll...

Я работаю над микроуслугами с spring-Kafka-2.1.5 и spring-boot-2.0.5 Первый сервис выдаст некоторые...

У меня есть некоторые сомнения по поводу восстановления баланса.Прямо сейчас я вручную назначаю...

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

поиск подробностей при обновлении retention.ms и ниже - сценарий созданная тема t1 с retention.ms 6...

org.apache.kafka.common.KafkaExceptioption: Unexpected error from SyncGroup: The server experienced...

Kafka представила новый потребительский API-интерфейс высокого уровня, а старый SimpleConsumer...

Я не могу получить метрики JMX с помощью сценария bin / kafka-run-class.sh kafka.tools.JmxTool

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