Re: Kafka Streams Internal Topic Retention not applied

th null-value), the record will never be deleted > for a compacted topic. > > > -Matthias > > On 4/6/18 2:10 PM, Björn Häuser wrote: >> Hello Guozhang >> >> thanks. >> >> So after reading much more docs I still do not have the complete pi

Re: Kafka Streams Internal Topic Retention not applied

; > > > On Wed, Mar 28, 2018 at 3:23 AM, Björn Häuser > wrote: > >> Hello Everyone, >> >> we are running a Kafka Streams Application with does time window >> aggregates (using kafka 1.0.0). >> >> Unfortunately one of the changelog topics is

Kafka Streams Internal Topic Retention not applied

Hello Everyone, we are running a Kafka Streams Application with does time window aggregates (using kafka 1.0.0). Unfortunately one of the changelog topics is now growing quite a bit in size maxing out the brokers. I did not find any settings in the kafka stream properties to configure retentio

Re: Scala type mismatch after upgrade to 0.10.2.1

> Yeah with 0.10.2 some Scala applications need to explicitly declare the type > of certain variables. See this: > http://docs.confluent.io/current/streams/upgrade-guide.html#scala > <http://docs.confluent.io/current/streams/upgrade-guide.html#scala> > > Thanks > Eno &g

Scala type mismatch after upgrade to 0.10.2.1

Hi! I am maintaining an application which is written in Kafka and uses the kafka-streams library. As said in the topic, after trying to upgrade from 0.10.1.1 to 0.10.2.1, I am getting the following compilation error: [error] found : service.streams.transformers.FilterMainCoverSupplier [erro