yeenow123

StateStore API

1

Any plans to include the state store API in this project?

Commit after all connected multicasted observables are finished processing a record

4

I am creating multiple observables (per Kafka topic) ``` val kafkaConsumerConfig = KafkaConsumerConfig.default.copy( bootstrapServers = kConfig.bootstrapServers, groupId = kConfig.groupId, enableAutoCommit = false, observableCommitOrder = ObservableCommitOrder.AfterAck, observableCommitType = ObservableCommitType.Sync, autoOffsetReset =...