datayoga
datayoga copied to clipboard
`read_redis_stream`, `read_kafka_stream`: consider not acking messages, but managing offsets instead
@zalmane - should be discussed.