Не могли бы вы предоставить мне пример кода в узле js, который выполняет запросы KSQL на Kafka?...

Я использую исходный JDBC-разъем Kafka для извлечения событий БД, и я запускаю kafka connect в...

Я пытаюсь запустить kafka из ambari UI. песочница hdp. это не начинается. я проверил журнал,...

Я создаю собственный SinkConnector с использованием Kafka Connect (2.3.0), который необходимо...

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

Я работал над Dash и kafka вместе. Я могу напечатать значения, полученные от потребителя Kafka, в...

Я настроил сотрудников Kafka connect для работы в кластере и получения данных БД. Также я сохранил...

TL; DR: у меня много потребителей, работающих над темой Кафки. Через некоторое время большинство из...

В настоящее время я хочу, чтобы мои клиенты Kafka были написаны на .Net. Хотя Java / Scala, как...

Я использую AWS MSK и хочу включить ACL, но не могу создать тему, когда ACL включены. Я использую...

Мы обновили наш кластер Kafka (обновление до 2.3) несколько дней назад, и мы замечаем огромное...

У меня есть требование, где мне нужно прочитать тему Кафки в pyspark и постоянно сравнивать...

Попытка понять (новичок в kafka), как работает цикл событий опроса в kafka. Вариант использования:...

У меня вопрос, у меня есть небольшие данные CSV, которые я могу запустить на лету с помощью kafka....

Я использую эту библиотеку node-rdkafka для реализации узла kafka с потребительской паузой и...

Мое приложение создано с помощью SpringBoot и находится в кластере (два разных istance openshit) У...

Я пытаюсь подключиться к реестру схемы Hortonworks из пользовательского десериализатора для темы...

Firest Я опрашиваю данные с kafka и мне нужно читать записи с помощью асинхронных методов, я...

Я пытался по существу использовать Apache-Kafka для связи между производителем Arch и потребителем...

Развертываем капсулы kafka и zookeeper в кластере kubernetes.Эти два связаны друг с другом...

Мы используем Kafka Exporter для мониторинга нашего кластера с участием до 10 брокеров в некоторых...

Мы пытаемся настроить потребительские метрики kafka в Datadog. Немного подробностей: Наш брокер...

Я запускаю mirrormaker в контейнере docker, когда я запускаю mirror maker, я получаю ошибку ниже....

Я проводил стресс-тестирование на Кафке.Я использовал тестовый фреймворк trogdor для создания...

У меня есть тема kafka, которая имеет 4 раздела, и я хотел бы увеличить до 8 разделов. Я хочу знать...