right behavior with a new group.id.
>
> Thanks,
> Neha
>
>
> On Fri, Mar 7, 2014 at 3:54 PM, Adam Phelps wrote:
>
>> I've been trying to write a test consumer in Java for a new use of our
>> Kafka cluster (currently used solely with Storm), however this u
I've been trying to write a test consumer in Java for a new use of our
Kafka cluster (currently used solely with Storm), however this use needs
to always start from the earliest offset in the topic. From reading
around it looked like setting "autooffset.reset" = "smallest" would do
this, however I
We have a realtime analysis system setup using a Kafka 7 cluster to
queue incoming data, but occasionally have a need to take one of the
nodes offline. Is there a method to set a broker to be read-only so
that we can drain unprocessed data from it prior to shutting it down?
- Adam
