Possible issue with Confluent Cloud?

jonathansant / Orleans.Streams.Kafka

An implementation of a PersistentStreamProvider for Microsoft Orleans and Kafka using the Confluent API

GNU General Public License v3.0

79 stars 31 forks source link

Possible issue with Confluent Cloud? #21

Closed simplifymatt closed 5 years ago

simplifymatt commented 5 years ago

Having a one message lag in confluent cloud for each partition, if I manually consume it via the example confluent app, it goes to 0, ie SystemStream. Any ideas?

lag

jonathansant commented 5 years ago

Hi, actually I found an issue with Confluent's consumer. Seems that the commit operation is failing. I'll investigate and keep you posted

jonathansant commented 5 years ago

Fixed using this pr (use version: 3.0.0-dev-97)