Re: Prioritized Topics for Kafka

2019-01-26 Thread nick
> On Jan 16, 2019, at 9:51 PM, n...@afshartous.com wrote: > > Hi all, > > On the dev list we’ve been discussing a proposed new feature (prioritized > topics). In a nutshell, when consuming from a set of topics with assigned > priorities, consumption from lower-priority topics only occurs if

Re: Kafka streams messages duplicates with non-overlapping gap-less windows

2019-01-26 Thread Matthias J. Sax
I am not 100% sure, what you mean by >> I've a input topic where I'm 100% sure there are no duplicate keys or >> messaged If this is the case (ie, each key is unique), it would imply that each window contains exactly one record per key. Hence, why do you aggregate? Each aggregate would consist o

Re: Bug in TopologyTestDriver

2019-01-26 Thread Matthias J. Sax
This question is cross posted on SO. I answered it there: https://stackoverflow.com/questions/54372134/topologytestdriver-sending-incorrect-message-on-ktable-aggregations On 1/25/19 6:32 PM, Murilo Tavares wrote: > Hi > I am new to this mailing list, so not sure if this is the right place to >