You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
With the kafka-console-consumer, there's a --from-beginning option for getting all messages across a topic's partitions. I've tried setting the startingOffset:
const consumer = new kafka.GroupConsumer({
connectionString: KAFKA_URLS,
startingOffset: kafka.EARLIEST_OFFSET
});
With the
kafka-console-consumer
, there's a--from-beginning
option for getting all messages across a topic's partitions. I've tried setting thestartingOffset
:as well as the
time
in the subscribe call:but neither of these seemed to do it. Is there a way to mimic that
--from-beginning
behavior from the console consumer?The text was updated successfully, but these errors were encountered: