Set auto.offset.reset to "smallest"
On Thu, Jul 31, 2014 at 08:25:35PM +, Srividhya Shanmugam wrote:
> Kafka Team,
>
> I am using high level consumer API as shown below to read contents from the
> topic.
>
> Properties props = new Properties();
> props.put("zookeeper.connect"
Kafka Team,
I am using high level consumer API as shown below to read contents from the
topic.
Properties props = new Properties();
props.put("zookeeper.connect"
,"localhost:2181");
props.put" zookeeper.session.timeout.ms","1