Я новичок в Kafka и потоках архитектуры данных, и у меня есть вопрос относительно дизайна тем и...
Использование Java Kafka Streams API.Я хочу выбрать новый ключ для темы, которую я использую.Новый...
У меня есть микросервис, использующий Streams 1.1.1 (в ближайшее время планируется обновление до 2
Kafka 2 добавил поддержку динамической маршрутизации через интерфейс TopicNameExtractor, который...
Я пытаюсь установить Spring Boot Application для прослушивания Kafka. Я использую Kafka Streams...
Рассмотрим этот драйвер Kafka Streams public class TestDriver { private static final String SOURCE...
Недавно я наткнулся на эту статью о документации Apache Kafka, касающуюся обработки сообщений о...
Запуск в Confluent Cloud с потоками kafka версии 2.1.0. При запуске приложения kafka streams...
Я новичок в Kafka Streams. Я использую метод подавления KTable для обработки только окончательного...
Меня немного смущает формулировка этой темы в документации kafka, поэтому я хочу спросить здесь,...
В настоящее время я использую библиотеку kafka-streams. Что я пытаюсь сделать : (Используя потоки...
Текущая настройка - я передаю данные из 16 разделенных разделов, выполняю соединения KTable-KTable...
Я получаю эту ошибку при выполнении kstream для получения агрегированного подсчета. Exception in...
У меня есть следующее: KTable<Integer, A> tableA = builder.table("A");...
Я использую Kafka Streams для соединения по двум различным типам сообщений, приходящих из двух...
Используя Kafka Streams, мы не смогли определить конфигурацию, необходимую для сжатия сообщений,...
Я только начинаю тему фреймворков для обработки потоковых данных в реальном времени, и у меня есть...
Это продолжение предыдущего вопроса, который я послал относительно высокой задержки в наших потоках...
У меня есть 2 экземпляра моего приложения для потоков kafka, занимающих 2 раздела в одной теме....
Итак, я оценивал потоки Кафки и то, что он может сделать, чтобы увидеть, может ли он...
Я создал приложение, используя Kafka Streams, и выполнил некоторые агрегации по моей теме ввода....
Мой вопрос касается выгрузки KTable, значения которого соответствуют определенным критериям при...
Когда я обновляю до потоков Кафки 2.1, он говорит, что Serialized устарел.Как явно указать serdes с...
Я работаю над API-интерфейсом kafka-streams. По сути, Kafka-stream получает данные из исходного...
У меня есть топология, которая агрегируется в KTable. Это общий метод, который я создал, чтобы...