THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
- reporting these as metrics
- We chose not to do this because we should mirror the consumer. It uses committed() method and doesn't report these with metrics
- adding a committed offset method to kafka streams
- This turns out to be unnecessary as we can just add the information to TaskMetadata which is already exposed. Now we can avoid complicating KafkaStreams further.