У нас есть настройка BELK, при которой один Logstash в настоящее время извлекает журналы из «kafka»...

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

Я пытаюсь сделать это без использования Confluent Control Center, так как у меня нет лицензии. Я...

Мы используем kafka для нашей очереди сообщений. Наш бизнес требовал, чтобы временная метка...

Интересно, является ли источник для коммитирования только опросом новых записей, когда записи...

Я использую Apache Beam KafkaIO в качестве источника моего конвейера. Мне нужно прочитать две темы...

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

У меня медленно движущиеся данные в компактной теме кафки, а также быстро движущиеся данные в...

Я не уверен, что он уже ответил. Поскольку я не получил надлежащего объяснения, отправляю свой...

Существует узел-производитель Kafka, который отправляет содержимое файла в Kafka. Когда потребитель...

Я пытаюсь реализовать управление окнами с помощью Kafka Streams, в котором мы получаем несколько...

Я работаю над проектом централизации журналов. Я работаю с ELK для сбора / агрегирования / хранения...

Мы пытаемся измерить задержку записи сообщений в Infosphere CDC - Confluent kafka setup.У нас есть...

Я пытаюсь настроить один раз семантику в Kafka (Apache Beam).Вот изменения, которые я собираюсь...

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

В настоящее время мое потоковое приложение Kafka Consumer вручную фиксирует смещения в Kafka с...

Я реплицирую с конфлюэнтным репликатором одну тему через 3 кластера Kafka.но почему Confluent...

Итак, я оцениваю Кафку.В нашем случае использования пришлось бы создавать новые темы, содержащие...

У меня есть потоковое приложение kafka, которое в настоящее время берет 3 темы и объединяет их в...

Я пытаюсь читать авро-сообщения от Кафки, используя PySpark 2.4.0. Внешний модуль spark-avro может...

Я использую debezium для сбора изменений из 4 таблиц из моей БД книжного магазина, модель данных -...

Я пытаюсь отслеживать данные kafka с помощью yahoo kafka manager, и он работает нормально, без...

Я создал сервис SpringBoot, который использует SpringCloud @StreamListener для обработки сообщений...

Допустим, у меня есть тема, созданная с помощью потоков kafka из Confluent, которая содержит...

У меня есть тема Kafka и приложение Spark.Приложение Spark получает данные из раздела Kafka,...