Я изучал руководства Beam KafkaIO и пытался найти документацию по аутентификации клиента kafka, но...

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

Так что я использую этот пример Embedded Kafka и это тоже Я немного изменил этот пример и обновил...

У меня возник вопрос при прохождении через это удивительное руководство https://kafka.apache

Я реализовал простой процессор записи мертвых букв Kafka. Он отлично работает при использовании...

Для моей дипломной работы я пытаюсь отправить машинные данные (в данном случае исторические данные,...

Я хочу подключиться к экземпляру mongoDB через ssh в моем Debezium. Для подключения к mongoDB не...

Я разрабатываю асинхронный почтовый сервер при весенней загрузке с использованием kafka. Я написал...

Приведенный ниже код работает и фиксирует смещение после обработки данных.Но проблема в том, что он...

Рассмотрим этот драйвер Kafka Streams public class TestDriver { private static final String SOURCE...

Я следовал по этой ссылке , чтобы создать шаблон, который создает лучевой конвейер для чтения из...

Запуск в Confluent Cloud с потоками kafka версии 2.1.0. При запуске приложения kafka streams...

Мы пытаемся запустить тестовые примеры JUNIT на WINDOWS, которые включают встроенный kafka и...

У меня проблема с десериализацией сообщений из тем Кафки.Сообщения были сериализованы с...

Я использую kafka 2.11-2.1.0 с Java 11, и когда я запускаю скрипт kafka-acl для изменения ACL, я...

В настоящее время я использую библиотеку kafka-streams. Что я пытаюсь сделать : (Используя потоки...

Я пишу приложение для пакетных заданий spark, которое будет считывать данные из темы kafka и...

Это продолжение предыдущего вопроса, который я послал относительно высокой задержки в наших потоках...

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

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

Я подключаюсь к Kafka Brokers, защищенным с помощью SSL, и опрашиваю каждые 60 секунд. затем,...

Я хочу правильно удалить объект из KTable. У меня есть следующие данные потоковой обработки: input

Я внедряю платформу для агрегирования данных.Он должен занимать операции создания, обновления и...

С сервера я смог подключиться и получить данные из раздела удаленного сервера kafka, для которого...

Приложение собирает тысячи метрик в теме Кафки «raw-метрики». Хранение их в необработанном формате...