THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
To help get access to consumer state for txn producer, consumer will expose a new API for some of its internal states as an opaque struct:. This is already done by KIP-429, and we just take the details here for convenience.
| Code Block | ||
|---|---|---|
| ||
// public interface GroupMetadata { } // private interface ConsumerGroupMetadata extends GroupMetadata { finalpublic String groupId(); final public int generationId(); finalpublic String memberId(); final Optional<String> groupInstanceId; } // Consumer API public GroupMetadataOptional<String> groupMetadatagroupInstanceId(); } |
Thus producer could poll the metadata as it needs during normal processing.
...