Я пытаюсь создать приложение Kafka Streams, в котором я пытаюсь вычислить уникальные устройства для...
Conflunet Kafka 5.0.0 была установлена на AWS EC2 с публичным IP-адресом, скажем, 54.XX.XX.XX...
У меня есть приложение потоков Kafka, которое работает с входящим состоянием, и мне нужно сохранить...
Краткое объяснение того, чего я хочу достичь: я хочу сделать функциональные тесты для топологии...
Я использую клиент confluent_kafka в python.В настоящее время я не получаю ошибок при попытке...
Я хочу суммировать данные одного столбца на основе указанного ключа.Поток похож на id (String) Ключ...
Я недавно включил SSL и попытался запустить Kafka connect в распределенном режиме.При запуске...
Я пытаюсь создать приложение, управляемое событиями.Требуется, чтобы некоторые службы использовали...
Сценарий: У меня есть приложение KafkaStreams с полным хранением.У него есть одна тема событий и...
Я новичок в Apache Kafka.Я прочитал код приложения Steam и наткнулся на операцию агрегации.Я...
Я хочу прочитать таблицу из Hive и написать в Kafka Producer (пакетное задание). В настоящее время...
Я смотрю на Apache Kafka v2.0.0 и не могу понять, какую версию java он поддерживает (OpenJDK или...
Мы используем коннектор Confluent MS SQL CDC, а дескриптор соединения: curl -X POST -H \...
Я работаю в среде разработки с 3 (докеризованными) брокерами kafka в моей системе.У брокеров для...
В приложении моей компании, чтобы применить несколько преобразований к 2 группам сообщений,...
Я передаю данные в режиме реального времени от Кафки.Но данные в формате Avro.Невозможно...
У меня есть 2 модульных теста , когда я их запускаю, у меня появляется ошибка ниже 1) test @Test...
Описание Я пытался проверить правильность фрагмента данных, которые я посылаю Кафке.Когда я пытался...
У меня в приложении обрабатывается поток Kafka: myStream .mapValues(customTransformer::transform)
Spark имеет полезный API для накопления данных безопасным для потоков способом https://spark.apache
Я использую пример объединения потоков Python Kafka, приведенный в этом, API потокового Python...
Я использую confluent и kafka для сбора данных из темы Kafka в таблицу Mysql. Мои конфиги...
Для многих ситуаций в больших данных предпочтительно работать с небольшим буфером записей на ходу,...
Дочерний модуль получает запрос от производителя родительского кафки.Дочерний модуль имеет только...
Я пытаюсь использовать записи из таблицы MySQL, которая содержит 3 столбца (Axis, Price, lastname)...