Я пытаюсь получить «живой сюжет» с использованием кафки и боке, но сталкиваюсь со следующим...
Я читаю сообщения от Кафки в Flink Shell (Scala) следующим образом: scala> val stream = senv
Скажем, например, у меня есть этот POJO сотрудника: public class Employee { private int id; private...
Например, если у меня есть длительный процесс в одном из моих KafkaConsumer.(Допустим, для...
Я использую ниже Команды. Я запустил Zookeeper, используя это bin/zookeeper-server-start.sh...
Когда я запускаю локальный брокер kafka на моей машине со следующим конфигом...
У нас есть 3 узла развертывания Kafka кластера, в общей сложности 35 тем с 50 разделами в каждой.В...
Я создаю основной поток в SCDF (локальный сервер 1.7.3), в котором я настраиваю 2 потока.1. HTTP ->...
Я пытаюсь перенести данные кафки в HDFS.Я вижу данные темы kafka в окне kafka-consumer-console. Вот...
Я пытаюсь настроить связь SSL с межброкерскими и брокер-клиентскими коммуникациями в kafka,...
Существуют лучшие практики, которые рекомендуют запускать Mirror Maker на целевом кластере
Недавно мы использовали flink для использования тем kafka с шаблоном регулярных выражений....
Я запускаю Kafka и Zookeeper в Windows с помощью следующих команд: zookeeper-server-start.bat...
В микросервисной архитектуре у нас обычно есть два способа связи 2-х микросервисов.Допустим, службе...
Я ищу возможность повторной обработки незафиксированных сообщений после приостановки и...
У меня есть сценарий использования, в котором я хотел бы сопоставить поле ключа исходной таблицы с...
У меня есть приложение весенней загрузки, которое определяет: контроллер REST, который пишет в тему...
Мы определили базового подписчика, который пропускает пропущенные сообщения (т. Е. По некоторым...
Я использую Kafka 2, и по какой-то причине единственными процессорами NiFi, которые будут правильно...
Я пытаюсь настроить SSL-аутентификацию по всем направлениям с моей настройкой Kafka / Zookeeper. то...
Уважаемые, мне нужно добавить некоторые интеграционные тесты ко многим ресурсам в проекте, над...
Несколько серверов приложений подписываются на уведомление об истечении срока действия сообщения,...
Я новичок в ksql и уже давно пользуюсь mysql.Я хотел бы знать, есть ли в любом случае подзапросы в...
У меня есть инсталляция kafka в кластере kubernetes. У меня есть модуль, на котором запущено...
У меня есть микро-сервис, который отправляет объект json, а другой получает этот объект. Я настроил...