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

Я написал этого производителя Kafka и прочитал файл с рабочего стола, а затем выдвинул данные в...

Как я понимаю, один из брокеров выбран в качестве координатора группы, который занимается...

Я выполняю следующее задание с Confluent JDBC-Source-коннектором : { "name":...

У меня есть 9 брокеров, 5 узлов Zookeeper Kafka. Чтобы сократить время сообщения о сбоях, мы...

Для мониторинга матрицы Кафки я создал инструмент мониторинга, который загружает значения в API...

У меня проблемы с привлечением к работе самого простого потребителя кафки.Я использую...

Что это за классы?Я читаю об этом весь день и не могу понять из этого.Как именно он подключается к...

Я читаю большой файл, используя Java readStream.И я хочу передать это к теме Кафки.В настоящее...

KafkaConsumer поддерживает как список тем, так и шаблон при подписке. Можем ли мы сделать то же...

У меня есть тема Кафки, в которой есть несколько групп потребителей.Мне нужно, чтобы сообщения по...

У меня проблема с Apache kafka У меня есть 4 кластера, в которые я хочу установить экземпляры kafka

Когда я запускаю потребителя с одним экземпляром, он отображается в группе потребителей, но не...

Я пытаюсь развернуть автономное задание подключения для потоковой передачи с сервера mssql, однако...

Я пытаюсь использовать тему кафки в python и обслуживать через http с помощью клиента prometheus,...

Я пытаюсь создать элементы, используя FlinkKafkaProducer010, однако, когда я открываю окно консоли...

Я работаю в Docker для Windows, и вот мои настройки NiFi: Подробная информация о процессоре...

У меня есть огромная масса записей данных для Kafka, использующих пакетную обработку и сжатие. Я...

Я пытаюсь создать простого производителя Kafka на основе confluent_kafka .Мой код следующий: #

Я получаю ошибку ниже при попытке передать слова в Kafka-потребителе, команды с i введены...

Кто-то знает, как создать темы с несколькими подписками в Apache Kafka с помощью Sarama У меня...

Я пытаюсь опубликовать ответ в теме кафки.Этот ответ получен из mongodb. from kafka import...

Я пытаюсь развернуть топологию шторма / потока на удаленном сервере.Топология успешно развернута,...

У меня есть настройка кластера, которой управляет Ambari, однако я хотел бы добавить докер...

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