Home | About | Sematext search-lucene.com search-hadoop.com
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB
 Search Hadoop and all its subprojects:

Switch to Threaded View
Kafka >> mail # dev >> Does Kafka "message manager" tool (read messages from console, delete messages) exist?


Copy link to this message
-
Re: Does Kafka "message manager" tool (read messages from console, delete messages) exist?
For 1, you can write a tool that uses our getOffsetBefore api and
SimpleConsumer. The offset returned is at the log segment boundary. So it's
not going to match the specified time precisely.

For 2, you can configure a topic to be rolled by timestamp
("log.roll.hours" and "topic.log.roll.hours"). Then set the retention time
accordingly.

Thanks,

Jun
On Tue, Jul 23, 2013 at 5:21 AM, Vladimir Tretyakov <
[EMAIL PROTECTED]> wrote:
 
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB