Я должен реализовать управление смещением в Spark для потокового задания на Java, которое читает из...
Я сгенерировал свои классы Avro Java из схемы Avro с помощью avro-maven-plugin. Я сериализую свой...
Когда я пытаюсь запустить hello world ( опубликовано здесь ) для confluent-kafka==1.0.1, мой...
Я пытаюсь создать поток «Разница» из KStream в Kafka Java. У меня есть входной поток, где значения...
Я использую debezium-kafka для записи изменений в MySQL. Для MySQL я использую AWS RDS. У меня есть...
Я использую confluent avro продюсер в java, но пока я запускаю его, выполняя ниже проблему. Я...
Мне интересно, как добавить свойства к AvroProducer в python. Вот код, который я пробовал, вы...
Я хочу использовать приемник kafka в документации по потоковой передаче для записи моих данных в...
Возможно ли это? Я в основном пишу приложение, которое добавляет определенное количество входящих...
У меня есть приложение Kafka Streams с несколькими схемами, которое обогащает запись через...
У меня есть PCollection<KV<String,String>> Pcol, я обрабатываю каждый элемент в методе...
Я обрабатываю каждый элемент PCollection> PCol.Я хочу отправить элементы с ключом = "abc" в...
В моем преобразовании на основе DSL у меня есть поток -> ветвь, где я хочу, чтобы разветвленный...
Мне нужен SpringReatch ItemReader для приема сообщений Kafka, результаты которых будут обработаны и...
from confluent_kafka import Producer p = Producer({'bootstrap.servers':...
По умолчанию .windowedBy(SessionWindows.with(...)) будет возвращать каждую новую входящую запись
Я пытаюсь реализовать пользовательский разделитель Kafka, используя привязки весеннего потока...
Я хочу вставлять около 500 тыс. Данных в секунду в KAFKA, а затем синхронизировать их с базой...
Я пытаюсь реплицировать данные из mysql в greenplum, используя debezium, kafka и gpkafka.Вставка...
Существует ли какой-либо другой более простой подход для вычисления нескольких политик истечения...
При создании Kafka Streams с использованием Kafka Streams DSL https://kafka.apache
У нас есть настройки следующим образом: mysql -> maxwell -> kafka -> последующие услуги, рабы и т....
У меня есть логика: я получаю сообщения из одной темы (1 раздел), делаю медленный расчет (может...
Получение исключения при чтении из темы kafka: вызвано: org.apache.kafka.common.errors
Мы создали поток данных для kafka и используем flink sql, чтобы отловить сценарий для правила...