You also may want to check if the cleaner thread in the broker is still
alive (using jstack). I've run into this issue and used the fix mentioned
in the ticket to get compaction working again.
https://issues.apache.org/jira/browse/KAFKA-1641
I'd just like to mention that a possible workaround (de
Just curious,
Can you double check if you have log compaction enabled on your Kafka
brokers ?
On Wed, Jul 29, 2015 at 8:30 AM, Vladimir Lebedev wrote:
> Hello,
>
> I have a problem with changelog in one of my samza jobs grows indefinitely.
>
> The job is quite simple, it reads messages from the
