Why is compression disabled by default?

This is hopefully my final question for a while. I noticed that compression is disabled by default. Why is this? My best guess is that compression doesn't work well for short messages , which was maybe identified as the maj

Re: How can I repartition/rebalance topics processed by a Kafka Streams topology?

Matthias, Thank you for your detailed response. Yes—of course I can use the record timestamp when copying from topic to topic. For some reason that always slips my mind. > This will always be computed correctly, even if both records are not in the buffer at the same time :) This is music to my

Re: Consumer Offsets Being Deleted by Broker

Hey, I think what you looking for is offsets.retention.minutes from server side configuration. Best, Xin On 10.12.17, 07:13, "M. Musheer" wrote: Hi, We are using "kafka_2.11-1.0.0" kafka version with default "offset" related configurations. Issue: Consumer offsets are bein

Re: Consumer Offsets Being Deleted by Broker

Hi M.Musheer, Can you share some code ? It's difficult to tell without it ? Are you using synchronous or asyn commit ? Thanks, Best regards Le dim. 10 déc. 2017 à 07:13, M. Musheer a écrit : > Hi, > We are using "kafka_2.11-1.0.0" kafka version with default "offset" related > configurations.