kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Yang <teddyyyy...@gmail.com>
Subject java API equivalent of --from-beginning?
Date Fri, 06 Feb 2015 10:48:10 GMT
we are trying to achive the equivalent of
bin/kafka-console-consumer.sh


we tried " props.put("auto.offset.reset", "smallest");

but it still doesn't work.

how can I achieve --from-beginning in java code? thanks

(we are using 8.1.1)

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message