У меня есть один потребитель, которого я инициализирую списком брокеров (bootstrap.servers). В...

Мы запускаем kafka connect для получения авро-данных из раздела kafka и сохраняем его в формате...

Я пытался заставить работать основной поток kafka, и я создал продюсера и использовал producer

Использование документации слияния для kafka_cluster Я получил эту ошибку: Jul 03, 2018 4:20:41 PM...

У нас есть тема с сообщениями со скоростью 1msg в секунду с 3 разделами, и я использую разъем HDFS...

Я пробую потоковые журналы из log4j2 в топик Кафки. Мой сервер zookeeper & kafka работает. Я уже...

Я пытаюсь использовать класс ZKStringSerializer, который я получаю с import kafka.utils

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

я использую https://github.com/Yolean/kubernetes-kafka бегать кубернется на миникубе Я выставил...

Я читаю сообщения Кафки, используя простой потребитель Кафки. Сохранение вывода в HDFS и некоторая...

Запись в Kafka неблокирующая, но чтение из нее блокирует поток. Почему метод опроса Kafka не...

Я запускаю Apache Kafka в Windows. Когда я запускаю zookeeper и одного брокера, это нормально....

KafkaProducer javadoc говорит, что использование одного экземпляра даст более высокую...

Я провожу тестирование производительности для проверки того, насколько быстро производитель...

Я настроил кластер Kafka, кластер Storm и кластер Hadoop. все работает нормально, когда у них нет...

Какие шаги можно предпринять, чтобы уменьшить задержку в конвейере потоковой обработки, который...

Как получить текущее смещение, или смещение по разделам, или количество записей для данной темы?...

Я использую документацию confluent, но когда я добавляю разъем hdfs-sink, я получаю эту ошибку:...

Я новичок в Кафке. Я отправляю запрос на сервер REST и отправляю ответ на запрос на сервер kafka в...

Привет, я использую Spotify / Kafka и запускаю его с docker run —name ka -p 9092:9092 -p 2181:2181...

Пользовательский класс лицо class Person { private Integer id; private String name; //getters and...

Я тестирую async send () в моем производителе кафки. Кластер, к которому я хочу подключиться,...

У меня есть код приемника kafka connect, для которого ниже json передается как команда curl для...

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

Какое свойство я должен установить для автоматического удаления или автоматической очистки данных...