Hello frens, is there a difference in efficiency between: a) streaming from stream: final KStream<String, String> firstStream = streamsBuilder .stream(myTopic, ...); firstStream.to(myTopic2, ...); final KStream<String, String> secondStream = firstStream .filter(.…

Sorry, Fren. I’ve made an amendment.

The first example should be slightly more performant, because it saves you one read operations, resulting in higher throughput and lower latency. The first program will basically “fan-out” (thing of it like a broadcast) the stream, and does the write into the topic “on-the-side” while also forwardi…

Streaming from stream vs streaming from kafka - throughput

Stream Processing Kafka Streams

mjsax 22 May 2021 19:22 2

Your example is hard to understand. You cannot call sourceStream.to(myTopic2, ...); before you create it in your examples. Can you update your example accordingly?

Topic		Replies	Views
Stream data from from another stream delay time Kafka Streams	0	2806	27 August 2022
Stream processing from a Topic A on Broker A within Cluster A and write to a Topic B on Broker B within Cluster B Kafka Streams	3	3014	22 December 2021
Throughput &metrics Kafka Streams	0	59	24 January 2025
How to Transform a Stream of Events Using Kafka Streams \| Kafka Tutorials Kafka Streams	0	3392	16 November 2020
Streaming vs micro-batching Kafka Streams	1	3655	17 January 2022

Streaming from stream vs streaming from kafka - throughput

Related topics