Может ли кто-нибудь объяснить и направить мне ссылку или ресурс, чтобы прочитать о том, как...

У меня есть клиент Spring-Cloud-Streams, который читает тему Kakfa, состоящую из нескольких...

Я пытаюсь отправить данные файла csv через производителя kafka, а затем на стороне потребителя...

Я довольно новичок в Kafka и только начал работать с Python, так что извините за мои неправильные...

Я отправляю пустую матрицу от производителя kafka, и она отлично работает: async def...

Мы реализуем тему Kafka, которая представляет собой кластер из 3 машин. Мы собираемся выйти из...

работает сообщество Confluent Kafka 4.1.1. У меня есть ... мин. Синхронизированные реплики = 2 ....

У меня есть набор файлов в HDFS, эти файлы твиты. Мне нужно транслировать эти твиты через...

Что такое advertised.listeners .Как это поможет подключиться к брокеру Kafka, работающему на...

Я пытаюсь использовать исходный соединитель Kafka Connect JDBC со следующими свойствами в режиме...

У меня проблема с сериализацией Apache Kafka и Avro. В свойствах моего производителя я использую io

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

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

Согласно этому документу : key Optional Kafka event key. If configured, the event key must be...

У меня есть два контейнера в моих тестах с использованием @Testcontainers с Junit5, Kafka и...

Я хочу отслеживать здоровье брокера Kafka с помощью метрик Kafka Consumer JMX.Я использую...

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

Я начинаю с Kafka и довольно плохо знаком с Python. Я использую эту библиотеку с именем...

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

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

Если мы определим сервер Kafka как свойство в application.properties file like: spring.cloud.stream

Мне нужно применить транзакции в системе, которая состоит из следующих компонентов: Производитель...

Я создал потребитель kafka, используя 'kafka-node', для файла события consumer

Запись данных из файла Avro в разделы с помощью Confluent 5.1.0. когда я запускал потребительскую...

В настоящее время я использую SCS с SB2.0.Просто хотел бы узнать, что такое режим подтверждения по...