Я создал потребителя kafka в своем весеннем загрузочном приложении, которое слушает тему - my_topic...

У меня есть потребительское приложение kafka, которое читает данные IoT из темы kafka.Но все же я...

Команда debezium kafka connect: docker run -it --rm --name connect -p 8083:8083 -e GROUP_ID=1 -e...

Я немного запутался в связи между max.in.flight.requests.per.connection для Kafka Producers и...

Я пытаюсь настроить двух заказчиков Hyperledger Fabric (с одним и тем же блоком генеза). В блоке...

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

В настоящее время я работаю над приложением, которое частично использует Apache Kafka (версия 2.2

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

Я пишу соединитель Kafka, чтобы загрузить некоторые данные из нескольких источников на Github...

Я изменил диаграммы Burrow, доступные в https://github

В Kafka v 1.x.x и более поздних версиях. Можно ли получить метку времени сообщения, если у меня...

Я использую разъем Debezium Postgres.У меня есть две таблицы в Postgres, названные «публикации» и...

Когда объект установлен как «Case» вместо «Lead» по умолчанию в salesforce-example.properties,...

Управление схемами kafka с помощью avro дает нам гибкость для обратной совместимости, но как нам...

В настоящее время я работаю над проектом Kafka, и моя проблема в том, что я могу прочитать файл с...

Я работаю с Flutter и мне нужно записать данные в Kafka.Как я могу сделать это во флаттере / дартсе

Я пытаюсь запустить kafka-console-consume.sh для темы XXX sh kafka-console-consumer.sh...

Я новичок в InfluxDB, проблема заключается в том, что мне нужно вставить Python dicts в InfluxDB...

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

Я пытаюсь создать темы Kafka, используя Java. Но я получаю Exception in thread "main"...

Я могу заставить моего производителя Apache Kafka отправлять сообщения, когда он работает внутри...

Мы используем kafka как источник нашего конвейера.Я хочу перенести существующее состояние из...

У меня есть самозаверяющий сертификат (и закрытый ключ). Они используются для аутентификации Kafka...

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

Я использую apache camel kafka в качестве клиента для создания сообщения. Я наблюдал, как...