apache-kafka-streams

6зной

1ответ

Как обрабатывать ошибки и не совершать при использовании Kafka Streams DSL

Для потоков Kafka, если мы используем API-интерфейс более низкого уровня, мы можем управлять фиксацией или нет. Поэтому, если в нашем коде возникают проблемы, и мы не хотим передавать это сообщение. В

0зной

2ответ

как изменить сообщение одной темы kafka и отправить другую тему кафки с помощью java?

Я создал производителя, который производит MSG для одной темы. А мне нужно, чтобы я делал изменения в этой MSG и хочу отправить ее в другую тему B, я пытаюсь сделать это потоками Kafka, но не уверен,

1зной

1ответ

Query Кафка для сообщения (ий) по ключевым

У меня есть простая конфигурация Кафка: по умолчанию консоли-производитель записывает на одну тему с одним разделом пользовательского процессором (который реализует org.apache.kafka.streams.processor.

2зной

1ответ

Не удалось перезагрузить ошибку в потоках Kafka с более чем одним разделом тем

Работает нормально, если исходный раздел разделов = 1. Если я разбиваю разделы на любое значение> 1, я вижу ошибку ниже. Применимо как к низкому уровню, так и к API DSL. Любые указатели? Что может быт

2зной

1ответ

Потоковая передача сообщений по нескольким темам

У меня есть одна основная тема и несколько предикатов, каждая из которых имеет связанный с ней тему вывода. Я хочу отправить каждую запись во ВСЕ темы, чей предикат разрешает true. Я использую Luwak д

3зной

1ответ

Несколько потоков из одной основной темы

Как создать несколько потоков из одной главной темы? Когда я делаю что-то вроде этого: KStreamBuilder builder = new KStreamBuilder(); builder.stream(Serdes.String(), Serdes.String(), "master")