Я хотел понять порядок, которым Кафка следует внутри, чтобы помещать сообщения в раздел, который он...
Я хочу удалить тему кафки программно и много изо всех сил, чтобы она заработала. Использую ниже...
Kafka JDBC Sink Connector дает исключение пустого указателя для сообщения со схемой, имеющей...
Я бы хотел использовать события из темы кафки после времени их прибытия. Время, в которое я хочу,...
Мы новички в Кафке, поэтому я ищу руководство высокого уровня. У нас есть данные для одной сущности...
У меня есть потребитель Kafka, который подписывается на следующие темы MY_TOPIC,...
У меня есть простой KTABLE в KSQL, который называется DIMAGE Когда я запускаю следующий код {...
Я хотел бы просмотреть все темы, запущенные на сервере, из моих локальных скриптов kafka. Я могу...
Я пытаюсь запустить микросервис как приложение с весенней загрузкой, которое зависит от RocksDB. В...
Я хочу использовать кафку из приложения .net. Я создал производителя и потребителя, используя .net....
У меня настроена сеть роя при попытке запустить Kafka MirrorMake из службы внутри стека докеров, я...
У меня есть кластер Kafka, в котором для log.dir задан смонтированный путь NFS, указывающий на...
Я хочу получить список идентификаторов брокера в кластере с помощью команды kubectl exec. Я могу...
У меня есть вопрос о том, как смещения темы работают в Kafka, хранятся ли они в виде структуры...
Каждую тему я создаю в Кафке и удаляю ее. .\bin\windows\kafka-topics.bat --zookeeper localhost:2181...
Я скачал файлы плагинов с https://www.confluent.io/connector/kafka-connect-cdc-microsoft-sql/, Он...
Мы постоянно обсуждаем правильное (или предполагаемое) использование Кафки для событий. Спорным...
была одна статья Мартина Клеппмана (в блоге Confluent) о том, что в одну и ту же тему кафки можно...
Я знаю, чтобы написать потребителя Kafka и вставить / обновить каждую запись в базе данных Oracle,...
Один из наших брокеров Kafka имел очень высокую среднюю нагрузку (в среднем около 8) на 8-ядерном...
Я пытаюсь записать данные по теме кафки, но застрял с некоторыми ошибками. Ниже приведены сведения...
Мое требование - сбросить смещение темы kafka, когда приложению не удалось обработать сообщение,...
Я довольно новичок в Kafka, и у меня есть вопрос, касающийся отношений / сопоставления между...
Я создавал пример Kafka Producer, используя Java. я был отправив обычные данные, которые просто...
У меня есть Kafka Topic (1.0.0) с одним разделом. Потребитель упакован в EAR, и при развертывании в...