Я пытаюсь использовать Apache Flink 1.6.0 для чтения некоторых сообщений из темы кафки,...
Я пытаюсь прочитать данные из DB2, используя Kafka, а затем записать их в HDFS.Я использую...
Возможно ли в KSQL вывести старые и новые значения из таблицы?Мы хотели бы использовать таблицу в...
Я пытаюсь подключиться к серверу kafka через модуль весенней интеграции с конфигурацией SASL и...
Я хочу отправить логин брокеру Kafka, используя log4j.Тем не менее, общие сообщения хорошо...
Я использую кластер Apache Flink 1.6.0.Мы используем FlinkKafkaConsumer011 в работе.Контрольная...
У меня проблема с использованием KafkaEmbedded от https://mvnrepository.com/artifact/org
"Я добавил kafka appender в log4j2.xml в приложении Mule ESB, в журнале появляется сообщение об...
Использование KSQL-CLI с темой kafka, сообщения которой являются объектами JSON.Я хочу извлечь поля...
У меня проблема в том, что многие мои клиенты Kafka из одной группы потребителей не завершили...
Я изо всех сил пытался заставить это работать, но в конечном счете заставил скрипт выполнить...
Kafka уже предоставила другой механизм аутентификации SASL, такой как GSSAPI (Kerberos), PLAIN,...
Должен ли идемпотентный производитель быть транзакционным, чтобы обеспечить идемпотентность при...
у нас есть кластер Kafka (как сторонний хостинг), для которого включен SSL.Сейчас мы пытаемся...
Я пытаюсь установить Zookeeper и Kafka для базового теста. Необходимо изменить порт клиента в...
Мое требование - подключить базу данных oracle как источник с помощью kafka connect, я ищу...
Я запускаю работника в распределенном режиме и использую REST API для запуска ОДНОГО соединителя. У...
У меня следующая проблема: мне нужно отправить следы Зипкину через Кафку с помощью Sleuth.Исходя из...
Я хочу создать KafkaConsumer с Kafka 2.0.0, который будет использовать все доступные сообщения один...
Я настроил кластер брокеров Kafka и кластер экземпляров Zk, используя архив распространения kafka_2
Я работаю над потоковой передачей данных из postgreSQL в HDFS.У меня была настроенная среда на...
У меня есть тема Кафки и две группы потребителей, каждая из которых использует эту тему. Одна...
Файлы загружаются через клиент в папку на сервере.он непрерывно загружает файлы с другого клиента с...
В кластере PoC cloudera, поставляемом с kafka (1 брокер), я пытаюсь отправлять сообщения в кластер...
Я слежу за показателями JM X, доступными на веб-сайте Apache для Kafka.Один из показателей указан...