Я установил приемник Connector для Postgres к одному из узлов моего кластера Kakfka.Настройка...

Можно ли перейти к теме Kafka, когда только один из брокеров доступен от производителя, ни один из...

Я установил kafka_2.11-1.1.0 и установил для объявленного слушателя значение advertised

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

Я получаю это Исключение Kafka Storage: остановка из-за неисправимой ошибки ввода-вывода при...

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

Я читаю документацию Кафки и пытаюсь понять, как она работает.Это касается потребителей.Вкратце,...

Я записываю файл в тему kafka через kafka -roduction cli, используя эту команду...

Мне интересно, можно ли использовать Apache Kafka для отказоустойчивой среды с реляционными базами...

Допустим, у меня есть один брокер kafka, настроенный с одним разделом log.retention.bytes=80000 log

Я подготовил производителя кафки, который помещает Список в тему кафки.Отлично работает на 1...

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

Я использую scala, spark и Kafka.У меня есть 2 вопроса. 1.Как подтвердить, что тема существует в...

Как проверить, доступен ли сервер Kafka или нет. Я попробовал ниже scala code -Producer API. val...

Я получаю следующую ошибку в журналах при попытке опубликовать первое сообщение в новой теме....

I am sending `List<Object>` from Kafka Producer to a topic. A consumer which listens to the...

Я пытаюсь найти способ / помощника для преобразования .Net Class в Avro.Generic.GenericRecord.В...

Получение следующей ошибки (Kafka 2.1.0): 2018-12-03 21: 22: 37.873 ОШИБКА 37645 ---...

я пишу код jave для чтения данных json из локальной файловой системы и хочу отправить эти данные в...

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

Вот мой код и зависимость. Я пытаюсь писать сообщения в KAfka с помощью API производителя.И тема...

В настоящее время, когда я создаю продюсера для отправки моих записей и, например, по каким-то...

Я использую Kafka в своем Java-приложении. Когда я отправляю сообщение в Kafka для использования...

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

Я относительно новичок в hive / hadoop Я читал эти Обработчики хранилища Hive . Теперь я пытаюсь...