Map<K,V> divergentOffsets
Set<E> partitions
long offset
String metadata
Integer leaderEpoch
Map<K,V> offsetOutOfRangePartitions
int hash
int partition
String topic
int brokerId
String groupId
Set<E> invalidTopics
Map<K,V> recordTooLargePartitions
Set<E> unauthorizedTopics
org.apache.kafka.streams.processor.internals.Task task