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

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

У меня есть настройка kakfa на экземпляре ec2.Я назначил эластичный IP-адрес этому экземпляру.Я...

У меня есть кластер Apache Kafka с удалением политики хранения и периодом хранения 24 часа. Затем я...

Учитывая процесс потоковой передачи, при котором входящие данные обогащаются производителем, а...

Согласно книге Кафки Производитель публикует сообщения в теме. Эти сообщения будут написаны в...

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

Я работал с R, чтобы выполнить анализ данных для создания модели прогнозирования. Теперь мне нужно...

Я создал схему Avro для записей, которые мы публикуем в нашей теме Kafka.Наша фактическая схема...

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

У меня есть два класса для сериализации и десериализации в кафке.Сериализация работает нормально,...

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

Мне нужно разработать приложение для Android, которое отправляет и получает различные типы данных с...

Мой KafkaConsumer подписывается на шаблон тем. Однако при удалении некоторых устаревших тем он...

Моя цель - у меня есть приложение для загрузки весенних приложений kafka со свойством сериализации...

У меня установлен вручную Confluent Kafka Connect S3 с использованием автономного метода, а не с...

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

Я пытаюсь подтвердить, что конфиг Kafka Consumer работает правильно.Я устанавливаю некоторые...

Я пытаюсь установить kafka на Cloudera quickstart vm.Я сделал все шаги.Но я получаю следующую...

Я установил Apache Kafka на свой сервер Centos.Я просто пытаюсь написать сообщение в тему на другом...

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

Я пытаюсь аутентифицировать мой прокси-сервер Kafka с помощью SASL, но у меня возникают проблемы...

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

Это мой простой фрагмент кода, в котором я пытаюсь прочитать потребителя общей формы записи Avro:...

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