Re: Kafka Streams Internal Topic Retention not applied

> records, ie, a record with 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 no

Re: Kafka Streams Internal Topic Retention not applied

; > > Guozhang > > > > On Wed, Mar 28, 2018 at 3:23 AM, Björn Häuser <bjoernhaeu...@gmail.com> > wrote: > >> Hello Everyone, >> >> we are running a Kafka Streams Application with does time window >> aggregates (using kafka 1.0.0). >

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

Re: Scala type mismatch after upgrade to 0.10.2.1

; > > Thanks > Eno > >> On Jun 17, 2017, at 10:03 PM, Björn Häuser <bjoernhaeu...@gmail.com> wrote: >> >> Hi! >> >> I am maintaining an application which is written in Kafka and uses the >> kafka-streams library. >> >> A

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