Hi,
I do not have trace level logs as of now.
I am doing very basic operation with messages. The only time consuming part
is sending an e-mail. Our Email servers are very slow so sending one email
is taking upto 20 seconds. That's why I turned max.poll.records to just 2,
keppt session time out at 1
Hello Everyone,
I got duplicated results using kstreams for simple windowed aggregation.
The input event format is comma seperated: "event_id,event_type" and I
need to aggregate them by event type.
Following is the Kafka Stream processing logic:
events
.map((k, v) -> KeyValue.pair(v.spl
