Я смотрю учебник по Pipe . Мне нужно нечто подобное, но только местное.
Другими словами, код в примере:
final StreamsBuilder builder = new StreamsBuilder();
builder.stream("streams-plaintext-input").to("streams-pipe-output");
final Topology topology = builder.build();
final KafkaStreams streams = new KafkaStreams(topology, props);
, которая будет принимать сообщения из темы streams-plaintext-input и помещать их в тему streams-pipe-output.
Есть ли способ сделать это без создания темы вывода? Другими словами, каждый клиент должен использовать потоки и просто получать выходные данные локально?
Вариант использования в основном предназначен для получения сообщений и выполнения некоторой фильтрации, группировки и тому подобного, а затем для использования этого потока, как если бы он был исходным потоком.
Тем не менее, будет много потребителей с разными критериями преобразования, и я не хотел бы иметь тему для каждого из них, тем более что это временные данные, больше напоминающие непрерывный кеш.
Если есть какие-то учебники или примеры, которые я могу пройти, пожалуйста, дайте мне знать.