Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

  • 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.