При использовании Kafka Connect Api для публикации коннекторов или проверки их статусов пароль...

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

Я могу создать KafkaConsumer через KafkaConsumer<String, String> consumer = new...

Я получил java.io.IOException: Too many open files во время работы экземпляра Kafka и использования...

Я использую шторм V1.2.1.После настройки в соответствии с официальной документацией я хочу получить...

Я тестирую модуль очень простого класса-обертки для KafkaProducer, метод отправки которого просто...

Я получаю сообщение об ошибке в confluent-5.0.0. ksql>CREATE TABLE order_per_hour AS SELECT...

Предположим, что у меня задание таймера выполняется бесконечно долго, которое перебирает все группы...

В моем проекте camus используется долгое время и никогда не обновляется.В проекте camus...

Я пытаюсь использовать ruby-kafka gem для отправки сообщений, но получаю сообщение об ошибке Could...

Теперь, когда идемпотентный производитель может предоставить ровно один раз гарантию для каждого...

У меня есть служба весенней загрузки, у которой есть потребитель kafka.Я использую spring-kafka для...

У меня есть тема кафки по имени page_views и поток по имени pageviews.Теперь я хочу рассчитать...

Я использую kafka-python для создания потребителя Kafka (подключенного к производителю Kafka,...

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

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

Используется репо: https://github.com/Yolean/kubernetes-kafka/ Итак, я пытаюсь запустить кластер...

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

Я читаю из темы Кафки и фиксирую смещения чтения. Могу ли я каким-то образом, используя тот же...

Я занимаюсь организацией, в которой работают разные устаревшие системы, работающие на IBM AIX.В...

У нас есть сообщения, которые являются зависимыми.скажем, у нас есть 4 сообщения M1, M2, M1_update1...

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

Я пытаюсь реализовать модель публикации-подписки с Kafka, где одна тема будет прочитана /...

Я работаю над confluent-4.1.1 с помощью ksql cli.Могу ли я создать поток для вложенного формата...

Не могу определить, что не так с моей конфигурацией слушателя kafka.Изначально у меня есть непустая...