У меня есть объект A: public class A { String id; List<String> otherIds; SomeOtherObject...
Я создал потоковую топологию, и у меня 1 Source и 2 Sink. Я использую Spring Boot (2.1.9) с Kafka...
После долгих чтений в Интернете я наконец-то обратился к этому форуму. Моя задача состоит в том,...
Я новичок в Kafka / Kafka Stream. Я использую последний Кафка / Кафка-поток и Кафка-клиент и...
Мне действительно нужна помощь!Я не могу извлечь временную метку для сообщения, отправленного...
Я занимаюсь разработкой приложения java kafka-stream.Я использую команду mvn clean package для...
Я сгенерировал свои классы Avro Java из схемы Avro с помощью avro-maven-plugin. Я сериализую свой...
У меня есть приложение Kafka Streams с несколькими схемами, которое обогащает запись через...
У меня такое ощущение, что пунктуатор может получить доступ к данным локального хранилища, в то...
У меня есть данные в теме, которые необходимо подсчитать на нескольких уровнях, и во всех кодах и...
У меня есть приложение kafka streams (Kafka v1.1.0) с несколькими (24) темами.Четыре из этих тем...
Я пишу в тему вывода, используя KStream.to ("outputtopic"); В документах apache упоминалось, что он...
Я пытаюсь запросить хранилище состояний, чтобы получить данные в окне за 5 минут.Для этого я...
Используя DSL Kafka Streams, я десериализирую событие в bean-компонент, который затем помещаю в...
У меня есть одно приложение Kafka Streams (V 2.1.1), которое создает записи и помещает их в тему...
Можно ли в Kafka Stream API пересылать более одной записи одновременно разным дочерним процессорам?...
Должна ли версия org.apache.kafka / kafka-streams-scala, которую я использую в проекте, быть...
Я пытаюсь реализовать управление окнами с помощью Kafka Streams, в котором мы получаем несколько...
Я использую оба Kafka и Kafka Streams в моем приложении Spring.В то время как обычная Kafka связь,...
Я работаю над POC на Kafka Streams, в котором я обрабатываю авро-сообщения с использованием Kafka...
Исключение ниже выдается при изменении баланса.Мне интересно, является ли это проблемой определения...
Я получаю эту ошибку в Kafka 2.0, в то время как код работает для Kafka 1.1 "Exception in...
Я использую потоковую передачу Kafka, и у меня есть сомнения. Мой код: final KStream<String,...
Я делаю проект и застрял на KTable. Я хочу взять записи из темы и поместить их в KTable (хранилище)...
Привет, вот проблема, с которой я сталкиваюсь уже несколько дней и не могу найти ответ...