Начиная с Kafka 2.0 доступна опция иметь собственную реализацию для аутентификации, и я пытаюсь...

Я использую слияние для реализации ETL в реальном времени.Мой источник данных - oracle, в каждой...

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

В настоящее время мы работаем над настройкой кластера Kafka. Можете ли вы сообщить мне...

Мой Java KafkaProducer способен отправлять сообщения и получать асинхронный обратный вызов в обоих...

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

Если у меня есть одна тема, которая имеет 5 разделов, а затем у меня есть служба, потребляющая эти...

Я пытаюсь погрузить некоторые данные из темы Кафки в базу данных SQLite.Он проверяет таблицу и...

У меня есть приложение на Python, которое выполняет функцию на основе выражения cron.Функция должна...

У меня есть Кафка 0.10.0, которая, если я правильно понимаю, добавляет временные метки ко всем...

Описание проблемы: Наш потребитель Kafka (разработанный в Spring Boot 2.x) работает в течение...

У меня есть источник Akka Stream Kafka, который читает тему Kafka. У меня есть простая задача,...

Кафка 0.11.0.0 запущена в производство.Мы видим, что сжатие журнала в теме смещения потребителя не...

В книге под названием «Микросервисы Typescript» я нашел предложение, содержащее странно названный...

Я использую JDBC-коннектор для подключения к SAP и создания таблиц.Некоторые из них имеют @ в...

Я установил приемник Connector для Postgres к одному из узлов моего кластера Kakfka.Настройка...

Я запутался, в какой степени назначение разделов относится к клиентской части partition.assignment

Я получаю эту ошибку ниже: java.util.ConcurrentModificationException: KafkaConsumer is not safe for...

Я использую segmentio / kafka-go для подключения к Kafka. // to produce messages topic :=...

Я оцениваю платформу vert.x, чтобы увидеть, могу ли я уменьшить связь на основе Kafka между моими...

Я хочу перенести данные определенных условий из elasticsearch в kafka. Есть ли способ сделать это?

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

В настоящее время у моего потребителя kafka у меня отключена автоматическая фиксация , поэтому в...

Я пытаюсь использовать env var для настройки kafka на seedstack.Синтаксис работает с конфигурацией...

верблюд версия 2.15.1 Конечная точка определяется как (Ref: http://camel.apache.org/kafka.html)...