Я использую кластер Kafka с 3 узлами (3-Kafka, 3-Zookeeper - все на разных узлах в одной VLAN).Все...

Я использую kafka: kafka_2.12-2.1.0, подпружиненный kafka на стороне клиента и застрял с проблемой....

Сценарий: у вас есть Kafka-Cluster в разных DC, но они настроены как один кластер.Так что нет...

Как настроить потребителя так, чтобы он опрашивал 50 записей одновременно в одном опросе.Я создал...

org.springframework.beans.factory.annotation.AnnotatedBeanDefinition.setRole (I) V это происходило...

Когда я описываю одну из моих тем, я получаю этот статус: ➜ local-kafka_2.12-2.0.0...

У меня есть производитель, который выдает несколько сообщений (например, 10).Есть n разделов и...

Я хотел бы изменить путь к файлу log4j.properties для zookeeper, потому что я тоже хочу прочитать...

Я пытаюсь использовать SpoolDirCsvSourceConnector из https://github

Когда у нас есть несколько читателей, читающих тему из одного раздела. Есть ли вероятность, что все...

Рассмотрим следующую настройку prop.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG,...

У меня есть производитель сообщений на моем локальном компьютере и брокер на удаленном хосте (aws)....

Я пытаюсь создать соединитель Kafka-connect для передачи из темы AVRO в файл. И затем восстановите...

События на стороне команды обрабатываются, но запрос (проектор) не вызывается.Использование...

Если два процесса, использующие одну и ту же группу потребителей (group.id), подпишутся на один и...

В настоящее время я изучаю систему схем Avro и, насколько я понимаю, поток обновления схемы...

Я новичок в Java, и мне нужно выполнить фрагмент кода, связанный с Kafka, который приведен ниже:...

Каков наилучший формат сообщения для использования с apachhe kafka, чтобы производители и...

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

Мы рассматриваем возможность использования kafka в качестве решения для обмена сообщениями с малой...

У меня есть следующий кластер Kafka: 1 zk и 2 брокера, 1zk + 1 брокер на одной машине и 2 брокера...

у нас есть кластер HDP - 2.6.4 с версией ambari 2.6.1 у нас есть 3 брокера kafka с версией 10.1 и 3...

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

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

Позвольте мне объяснить мою проблему на примере: Существует микро-сервис под названием «служба...