Я использую Flink's FlinkKafkaConsumer010 и Kafka версии 1.1. Я хочу получить информацию о смещении...

Я строю планировщик корпоративных событий на основе потоков Kafka.Запланированные события...

У меня есть простая таблица базы данных в MySQL, которая имеет (id varchar(255), val varchar(255),

Попытка понять API производителя Java. Что означает завершение? Помоги мне понять за то же самое....

Запуск kafka connect в нашем docker-swarm со следующим файлом compose: cp-kafka-connect-node:...

Иногда (кажется очень случайным) Кафка отправляет старые сообщения.Я хочу только самые последние...

I am reading a "ABC" topic which have 5 partitions но на самом деле, когда я создал группу...

Для миграции кластеров Kafka с AWS на AZURE, проблема заключается в том, что мы используем наше...

Я пытался развернуть Kafka с реестром схемы локально, используя Kubernetes. Тем не менее, журналы...

Возможно ли генерировать случайные данные Avro по указанной схеме с использованием библиотеки org

Мне нужно автоматизировать повторный запуск кластера кафки (3 брокера кафки). Я могу легко сделать...

У меня вопрос о том, как мы можем интегрировать производителя kafka с интерфейсным веб-приложением....

Я использую диаграммы Кафки Хелма от здесь . Я пробовал Горизонтальный Pod Autoscaler для того же....

Вот как инициализируется мой потребитель: const client = new kafka.Client(config.ZK_HOST) const...

Я хочу получить статистику из темы Кафки: всего написано сообщений всего письменных сообщений за...

Я часто делаю что-то похожее на приведенное ниже, что позволяет мне загружать умеренное количество...

Я новичок в Apache Flink, поэтому сейчас пытаюсь провести несколько экспериментов. Я читаю тему из...

В настоящее время я сталкиваюсь с модулем kafka kubernetes в CrashLoopBackOff kafka-prod-4 1/2...

Я использую Kafka и Springboot в своем проекте, теперь у меня есть внешний кластер Kafka и проект...

У меня есть приложение для потокового воспроизведения, которое отвечает за объединение данных JSON...

Я работаю над решением, в котором у клиента уже есть iBM MQ, поэтому мне нужно интегрировать в него...

У меня есть сервер Kafka, работающий в ACL.Я могу добавить пользователя: Боб к теме теста...

У меня есть три разных узла, на каждом из которых есть докер с Ubuntu. Я хочу сделать кластер Kafka...

Я пытаюсь использовать Apache Kafka в сценарии с 24 узлами, где соединение между узлами...

мы планируем установить и запустить JDBC-разъем Confluent в операционной системе Windows (без...