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

Я планирую использовать Kafka hdfs connect для перемещения сообщений из Kafka в hdfs.Глядя на это,...

В соответствии с решением, упомянутым здесь...

Я хочу запустить kafka connect в распределенном режиме в моей настройке с 3 узлами.Но...

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

Я создал одну тему кафки с одним разделом. kafka-topics --create --topic files.write...

Я установил confluent платформу на машине Ubuntu 16.04, и первоначально я настроил zookeeper, Kafka...

Я скачал kafka и пытаюсь выполнить стартовый скрипт, используя .\bin\kafka-server-start.sh

kafka-connect: kafka-connect-cassandra-1.2.1-2.1.0-all.jar Мои данные внутри Кассандры помечены...

Я не могу найти способ в kafka-acls.sh использовать префикс для названия темы и литерала или '*'...

В отношении этого примера пример с debezium У меня есть несколько тем с разными первичными ключами...

Как мне получить все детали сервера kafka, такие как имена тем kafka, разделы, группы и т. Д. До...

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

Я хочу включить аутентификацию SASL только для клиента с брокером связи, а не для Брокер с брокером...

Оптимизация кода У меня есть приложение flink, которое считывает данные с URL / порта, выполняет их...

как запустить ksql в среде Windows? мы установили слитную кафку в формате zip.мы не нашли файл...

У меня установлено два брокера Kafka 2.1.0 на одном хосте Windows.Коэффициент репликации по...

Я пытаюсь отправить сообщения из темы кафки (данные в формате avro) в таблицу Postgres.У меня есть...

Я использую это примеры дебезия Я добавил "themes.regex": "CID1122. (. *)" в моем jdbc-sink.json...

Когда я использую библиотеку python-kafka (1.4.4) для получения сообщения (Kafka version 1.1.0,...

У меня есть таблица с именем SUBSCRIPTIONS со следующими столбцами: KEY varchar, APPLICATION_ID...

Мне нужен мой файл conf logstash для отправки сообщения в тему kafka, чтобы указать, что...

Мне нужна встроенная кафка для юнит-тестирования (UT). Я пытаюсь заставить github

Я использую Kafka и включил kerberos (SASL_PLAINTEXT используя GSSAPI) для аутентификации kerberos

У меня есть потоковое приложение на основе Flink, которое использует источники и приемники apache...