Hi,
in your first example with .print() "before" and "after" .to() I want to
clarify, that the order you use to add operators does not really matter
here. The DAG you build will branch out anyway:
+--> print()
|
KTable -> changelog --+--> to()
Hi there, I'm testing Kafka Streams's print() method, here is the code:
props.put(StreamsConfig.APPLICATION_ID_CONFIG, "dsl-wc1");
props.put(StreamsConfig.CACHE_MAX_BYTES_BUFFERING_CONFIG, 0);
KStream source = builder.stream("dsl-input1");
KTable countTable = source
