DUE TO SPAM, SIGN-UP IS DISABLED. Goto Selfserve wiki signup and request an account.
...
- New TxnShareAcknowledge RPC (apiKey 80 or next free).
- Schema mirrors TxnOffsetCommitRequest shape but carries AcknowledgementBatch instead of OffsetCommitInfo.
| Code Block |
|---|
New RPC: TxnShareAcknowledgeRequest (apiKey 93)
Listeners: broker.
Acknowledge type values: 0=Gap, 1=Accept, 2=Release, 3=Reject, 4=Renew.
Transactional constraint: only 1 (Accept) and 3 (Reject) are valid inside a transaction.
A batch containing any other value is rejected with INVALID_RECORD_STATE. |
| Field | Type | Notes |
|---|---|---|
| TransactionalId | string (nullable) | The producer's transactional.id. |
| GroupId | string, entityType=groupId | The share group ID. |
| ProducerId | int64, entityType=producerId | For fencing. |
| ProducerEpoch | int16 | For fencing. |
| MemberId | string, entityType=memberId | The share group member ID. |
| MemberEpoch | int32 | For share-group fencing. |
| Topics | []TxnShareAcknowledgeTopic | mapKey=true on TopicId. |
| Topics.TopicId | uuid, mapKey=true | |
| Topics.Partitions | []TxnShareAcknowledgePartition | mapKey=true on PartitionIndex. |
| Partitions.PartitionIndex | int32, mapKey=true | |
| Partitions.AcknowledgementBatches | []TxnShareAcknowledgeBatch | |
| Batch.FirstOffset | int64 | Inclusive. |
| Batch.LastOffset | int64 | Inclusive. |
| Batch.AcknowledgeTypes | []int8 | Per-offset ack type byte. Size 1 = uniform type for whole range. |
Broker / coordinator additions:
...