DUE TO SPAM, SIGN-UP IS DISABLED. Goto Selfserve wiki signup and request an account.
...
- New TxnShareAcknowledge RPC (apiKey 80 93 or next free).
- Schema mirrors TxnOffsetCommitRequest shape but carries AcknowledgementBatch instead of OffsetCommitInfo.
...
| 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. |
| Code Block |
|---|
New RPC: TxnShareAcknowledgeResponse (apiKey 94, v0)
Top-level supported errors:
- GROUP_AUTHORIZATION_FAILED
- TOPIC_AUTHORIZATION_FAILED
- TRANSACTIONAL_ID_AUTHORIZATION_FAILED
- TRANSACTIONAL_ID_NOT_FOUND
- INVALID_PRODUCER_EPOCH / PRODUCER_FENCED
- INVALID_PRODUCER_ID_MAPPING
- INVALID_TXN_STATE
- UNKNOWN_MEMBER_ID
- STALE_MEMBER_EPOCH
- TRANSACTION_ABORTABLE (KIP-890)
- UNKNOWN_SERVER_ERROR
Per-partition supported errors:
- UNKNOWN_TOPIC_OR_PARTITION / UNKNOWN_TOPIC_ID
- NOT_LEADER_OR_FOLLOWER (with CurrentLeader populated)
- INVALID_RECORD_STATE
- INVALID_REQUEST
- KAFKA_STORAGE_ERROR
|
| Field | Type | Notes |
|---|---|---|
| ThrottleTimeMs | int32 | |
| ErrorCode | int16 | Top-level error. |
| Responses | []TxnShareAcknowledgeTopicResponse | |
| Responses.TopicId | uuid, mapKey=true | |
| Responses.Partitions | []TxnShareAcknowledgePartitionResponse | |
| Partitions.PartitionIndex | int32 | |
| Partitions.ErrorCode | int16 | Per-partition error. |
| Partitions.ErrorMessage | string (nullable) | |
| Partitions.CurrentLeader | LeaderIdAndEpoch (tagged) | Populated on NOT_LEADER_OR_FOLLOWER. |
| NodeEndpoints | []NodeEndpoint (tagged) | Top-level: address of any new leader referenced above. |
Broker / coordinator additions:
...