unsubscribe
On Mon, Aug 29, 2022 at 8:56 AM Derek Mok wrote:
> Hi, I'd like some help with understanding how exactly max.task.idle.ms
> works. I have a topology that consumes from an input topic A, and a join
> operator that enriches the topic A messages with a KTable from a compacted
> topic B.
Howdy,
I'm trying to make a Mafka application which will join two topics with
different semantics than the KStreams join has natively.
Specifically I'd like to:
- Immediately emit matches to a topic.
- Track when matches are found so subsequent matches (which within the join
window would be consi
