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
fix(consumer lag): commit offset + 1 to reduce lag to 0 #22
Closed
jonathansant closed 5 years ago