Как схемы из Confluent Schema-Registry распространяются Confluent-Replicator по назначению...

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

Я хочу создать несколько потребителей или группу потребителей для одной и той же темы.Поскольку мое...

Я пытаюсь следовать этим инструкциям для локального подключения к моей heroku kafka с помощью...

У меня есть кластер Kafka с 3 брокерами.Репликация настроена: offsets.topic.replication.factor = 3...

Я установил экземпляр heroku kafka, и я пытаюсь подключиться к нему с помощью приемника Python.У...

Почему Apache Kafka 2.12-1.1.0 не работает с JDK 10.0.1? ./bin/zookeeper-server-start.sh...

пытается соединить два Kstream, но я получаю сообщение об ошибке несоответствия типов, ниже...

В перераспределении разделов это все еще отображается в процессе. Ссылка используется gist...

Я использую Python-клиент (Confulent kafka) для потребления из kafka.Иногда потребитель...

Я использую OpaqueTridentKafkaSpout для приема сообщений от Kafka.Ниже приведен код.Я...

Я хочу отправить экземпляр класса брокеру kafka. A1 = Axestrack('1087999'...

Я использую spring-kafka 1.3.5, которая использует клиент 0.11.0.2.У меня есть 2 раздела.И мой max

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

После создания «тестовой» темы, kafka-topics --create --zookeeper localhost:2181...

Я пытаюсь загрузить данные в таблицы (таблицы) Postgres через соединитель Kafka Sink, но получаю...

Я получаю данные из MongoDB и помещаю их в Kafka.357 ответов в секунду - это скорость, с которой...

Я пытаюсь подключиться к разъему Flink kafka 0.11, но он продолжает выдавать мне эту ошибку при...

Я установил kafka в облачном сервере. Я хочу подключить сервер cloud-kafka из моей локальной...

Я пытаюсь использовать новую функцию (https://www.confluent

Я пытаюсь реализовать простое приложение потоковой обработки в Scala, но сталкиваюсь с проблемами...

Если моей системе необходимо захватить геолокацию нескольких транспортных средств и записать их в...

Я использую Hadoop из Docker Swarm с 1 наменодом и 3 датододами (на 3 физических машинах).Я также...

У меня периодически возникает проблема с Kafka: я делю сообщения по идентификатору клиента, и...

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