Yes, we have indeed set the cleanup.policy=compact for the specific topic.



On 4/21/16, 11:58 PM, "Manikumar Reddy" <manikumar.re...@gmail.com> wrote:

>Did you set broker config property log.cleanup.policy=compact or topic
>level property cleanup.policy=compact ?
>
>On Thu, Apr 21, 2016 at 7:16 PM, Kasim Doctor <kdoc...@expedia.com> wrote:
>
>> Hi everyone,
>>
>> I have a cluster of 5 brokers with Kafka 2.10_0.8.2.1 and one of the
>> topics compacted (out of a total of 4 topics).
>>
>> In spite of repeated attempts to tune the configuration, compaction just
>> does not work. The messages that I push to this compacted topic are in the
>> range of 50 MB to 90 MB.
>>
>> Here are my broker configs related to compaction:
>>
>>
>>
>>         log.cleaner.enable=true
>>
>>
>>
>>         log.cleaner.backoff.ms=15000
>>
>>
>>         log.cleaner.delete.retention.ms=86400000
>>
>>
>>         log.cleaner.threads=5
>>
>>
>>         log.cleaner.dedupe.buffer.size=524288000
>>
>>
>>         log.cleaner.min.cleanable.ratio=0.01
>>
>>
>>
>>
>>
>> Additionally, I have set segment.ms = 86400000 at the topic level for the
>> specific compacted topic.
>>
>> I also don’t see any logs related to compaction in the kafka logs.
>>
>> As a result, I run of out of disk space in a matter of days since I was
>> relying on compaction to free up space by deleting old entries in the log
>> with the same key.
>>
>> Can someone please help me out here ?
>>
>> Thanks,
>> Kasim
>>

Reply via email to