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
I found that after running a stream to get a nonempty collection of messages, the offsets weren't incremented. Is there a way in this client to commit offsets while the stream is running?
I used code something like the following, which threw NoOffsetForPartitionException. The groupIds on the clients are the same , and there was only one partition.
@shawjef3 we do not commit any offset. The client form fs-kafka is not durable, so you need to commit offsets in different persistent store, or eventually, you may want to use compacting kafka topic to do so.
I found that after running a stream to get a nonempty collection of messages, the offsets weren't incremented. Is there a way in this client to commit offsets while the stream is running?
I used code something like the following, which threw
NoOffsetForPartitionException
. The groupIds on the clients are the same , and there was only one partition.The text was updated successfully, but these errors were encountered: