Я работаю над развертыванием Kafka / Zookeeper в Kubernetes, используя MINIKUBE.ниже приведен мой...

Я хочу получить данные из базы данных SQL Server, которая содержит данные, близкие к 5 ТБ.Я буду...

Я пытаюсь понять Avro Serialization на Confluent Kafka вместе с использованием реестра Schema.До...

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

Я использую конвейер данных, так что я читаю данные из sql db в тему kafka через jdbc connect. Я...

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

Установив KAFKA и просмотрев эти сообщения: Кафка теряет все темы при перезагрузке Тема Кафки...

Ниже приведена трассировка стека: Ошибка обработки запроса;Вложенное исключение: org.apache.kafka

У нас есть 1 тема с 3 разделами с одним потребителем.Мы используем данные в виде пакетов (25),...

Когда хост-брокер отключается / перезапускается, клиент kafka продолжает отправлять новые запросы...

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

Я работаю над Spring Java micro-services, используя Apache Kafka для обмена сообщениями.Иногда я...

В настоящее время я профилировал приложение весенней загрузки для производителя kafka и обнаружил,...

Я использую Kafka Connect ConnectSealsearch Connector, который предоставляется Confluent для...

У меня есть кафка с диаграммой руля jmx.https://github.com/bitnami/charts/tree/master/bitnami/kafka...

Сбой команды mvn install, и я не могу собрать исходный код kafka-connect-jdbc.Я собираюсь изменить...

Я читал о безопасности kafka и, похоже, ACKL - это путь для установки безопасной kafka.Но мой...

Мой кластер Kafka имеет следующую конфигурацию. Кластер версий Kafka (v1.1.0) с 3 брокерами Одна...

У меня есть Kafka Topic только с одним разделом, и я не понимаю, что произойдет в следующих случаях

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

Задача состоит в том, чтобы создать производителя Kafka, который подключается к кластеру Kafka,...

Я рассчитывал какой-то транзакционный код, чтобы увидеть, где я больше всего терял.Время,...

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

Я пытаюсь создать веб-API в контейнере Docker, который будет отправлен в экземпляр OpenShift.В API...

Контекст: У нас есть требование, когда мне нужно захватить конкретную транзакцию с использованием...