Re: kafka message expiry question

2014-11-20 Thread Manikumar Reddy
HI, > as far as i understand, log retention time in kafka will delete message > that's older than the retention time. log retention is applicable to log segment files. In kafka, each topic can have multiple partitions and each partition data stored in multiple log segment files. > say i h

kafka message expiry question

2014-11-19 Thread Weide Zhang
hi, as far as i understand, log retention time in kafka will delete message that's older than the retention time. i'm wonder what it implies for consumer since i'm using simple consumer to manage offsets in predefined consumer group. say i have a list of messages for a partition of topic: 1,2,3,