Я использую Avro для создания класса.Вот мой код в продюсере выглядит так: TweetInfo tweetInfo =...

У меня есть тема кафки, в которой есть сообщения без авро-схемы.Недавно мы хотим отправить...

Я вижу следующую ошибку exception Unsupported Avro type. Supported types are null, Boolean, Integer...

Я пытаюсь настроить проект с облаком Springboot Stream с Kafka.Мне удалось создать простой пример,...

У меня работает Zookeeper на порту 2181 (по умолчанию) и сервер Kafka, прослушивающий порт 9090 на...

Как я могу установить для свойства spring-boot: spring.kafka.producer.retries значение Integer

Я пытаюсь получить какие-то метрики (клиентское отставание, ...) от Кафки, чтобы предоставить его...

Я пытаюсь сделать маленький PoC с Кафкой.Однако при создании потребителя в Java этот потребитель не...

Я настроил Kafka Cluster с 3 брокерами, используя 3 Zookeepers вместе с каждым брокером.На рисунке...

Для связи с Кафкой из приложения Dockerized Spring-Boot, единственная возможность, которую я смог...

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

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

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

Я пытаюсь разработать / отладить приложение Spring KAfka.Я использую KafkaTemplate для сериализации...

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

Я использую Kafka 2.1 в режиме SASL_PLAINTEXT и для управления ACL по темам, которые мне нужны для...

У меня есть создание приемника kafka connect, который конвертирует данные в другое хранилище;Я хочу...

В Apache Kafka относительно первого изображения ниже, если каждый раздел содержал одно и то же...

Пока потребительское приложение Kafka запущено и работает, мы можем использовать...

Я скачал файл kafka_2.11-2.1.0 с веб-сайта Kafka, распаковал его и в соответствии с инструкциями...

Я делаю PoC, используя dotnet и ksql.https://github.com/pablocastilla/kafkiano/ Общая идея состоит...

Я новичок в kubernetes, я пытаюсь интегрировать kafka с debezium и mysql.я успешно развернул kafka...

Я сейчас работаю над модулем Kafka, где я использую spring-kafka абстракцию связи Kafka.Я могу...

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

Я пытаюсь выполнить некоторые тесты для Kafka с использованием Kstreams и KTable. Kafka KTables -...