Я использую Ubuntu 18 и использую Java (intellij IDE) и пишу базовое приложение для kafka. Я...
Я пытаюсь построить конвейер kakfa, который будет считывать входные данные JSON в тему Kafka. Я...
Я хочу запустить исходный соединитель JDBC, используя Kafka Connect REST API.Хотя автономный режим...
У меня есть тема с 10 разделами в кластере Kafka 0.10.0.1. У меня есть приложение, которое...
Мы хотим проверить или проверить журналы в разделе /var/kafka/kafka-logs/, чтобы понять, какие...
Я хочу отправить данные из kafka (выполняя некоторую работу с mapreduce) в улей. Подходит ли для...
Существует требование, когда мы получаем поток данных из Kafka Stream, и наша цель - передать эти...
Существует ли какая-либо конфигурация для потребителя Kafka для чтения входящего сообщения ровно...
Какова роль контрольной точки эпохи лидера в сегменте журнала раздела Kafka?
Я работаю с Кафкой.и получить сообщение в описании.Я устанавливаю свойства для десериализатора в...
Я получаю следующую ошибку при попытке использовать строку в качестве ключа в теме kafka. 18/05/14...
У меня простое POC-приложение на основе Apache Camel , которое пытается извлечь сообщения из IBM MQ...
Я использую следующую раковину.Проблема в том, что он устанавливает имя индексаasticsearch так же,...
Добрый день, я пытаюсь отладить выполнение файла docker-compose, использующего пару разработанных...
Интересно, могу ли я получить некоторую помощь в понимании транзакций в Kafka и, в частности, как я...
Я скачал Kafka и запустил его на своей локальной Windows для тестирования / разработки. Он работал...
Я настроил kafka на отдельный узел (HDF ver 3.1.1, Kafka ver 1.0.0) Чтобы загрузить данные из kafka...
Кто-нибудь знает, как отлаживать кластер kakfa с помощью Eclipse?Я попытался добавить конфигурацию...
Приложение My Spring Boot содержит несколько @KafkaListener с , и каждый слушатель выполняет одни и...
Я только начал узнавать о Кафке и на высоком уровне, я не до конца понимаю разницу между...
Я создал тему, которая имеет много разделов. Используя производителя консоли, я хочу отправлять...
Я установил кластер Kafka с 3 узлами. kafka-console-producer.sh и kafka-console-consumer.sh...
Я создаю повторно созданный поток CREATE STREAM details_stream_rekeyed2 as \ select CONCAT(IdSeq...
Мне нужно позвонить потребителю Kafka в режиме публикации / подписки 1000 раз. Насколько я знаю,...
Представьте, что соединение с кластером Kafka закрыто (например, отключен кабель), и рано или...