DUE TO SPAM, SIGN-UP IS DISABLED. Goto Selfserve wiki signup and request an account.
...
| Code Block |
|---|
ShareConsumer (clients module)
public interface ShareConsumer<K, V> {
/**
* Returns an immutable snapshot of this consumer's share-group identity for use
* with Producer.sendShareAcknowledgementsToTransaction.
*
* The snapshot captures groupId, memberId, and memberEpoch atomically; if a
* rebalance changes the memberEpoch between the snapshot and the producer call,
* the broker will reject the staging request with STALE_MEMBER_EPOCH and the
* user must abort the transaction and retry the read-process-write loop.
*
* @throws UnsupportedVersionException if the cluster does not support KIP-1289.
* @throws TimeoutException if the snapshot cannot be obtained within the
* configured default.api.timeout.ms.
*
* Threading: thread-safe; safe to call concurrently with poll() and acknowledge().
*/
ShareGroupMetadata shareGroupMetadata();
} |
| Code Block |
|---|
ShareGroupMetadata (new class in clients module, package o.a.k.clients.consumer)
public final class ShareGroupMetadata {
public ShareGroupMetadata(String groupId, String memberId, int memberEpoch);
public String groupId();
public String memberId();
public int memberEpoch();
@Override public boolean equals(Object other);
@Override public int hashCode();
@Override public String toString();
} |
Wire protocol additions:
- New TxnShareAcknowledge RPC (apiKey 80 or next free).
- Schema mirrors TxnOffsetCommitRequest shape but carries AcknowledgementBatch instead of OffsetCommitInfo.
...