Hi Elias,

You can set compaction on a per topic basis while leaving
"log.cleanup.policy=delete" as the default on the broker. See "Topic-level
configuration" here:
http://kafka.apache.org/documentation.html#brokerconfigs

An example usage of the command line tools to do this is:

bin/kafka-topics.sh --zookeeper localhost:2181 --alter --topic my-topic
--config cleanup.policy=compact


Thanks,
Grant

On Mon, Aug 17, 2015 at 1:48 PM, Elias K <mariguanit...@gmail.com> wrote:

> Hi all,
>
> This is my first post here so please bear with me.
>
> I would like to have compaction enabled in some topics, but in others have
> purge after x amount of days.
>
> I did some searches and I couldn't find anything related to this and it
> appears that the compaction is enabled globally for all topics.
>
> Thanks for all the information
> Elias
>



-- 
Grant Henke
Software Engineer | Cloudera
gr...@cloudera.com | twitter.com/gchenke | linkedin.com/in/granthenke

Reply via email to