1// OffsetDeleteRequest, proposed in KIP-496 and implemented in Kafka 2.4.0, is
2// a request to delete group offsets.
3//
4// ACL wise, this requires DELETE on GROUP for the group and READ on TOPIC for
5// each topic.
6OffsetDeleteRequest => key 47, max version 0, group coordinator
7 // Group is the group to delete offsets in.
8 Group: string
9 // Topics are topics to delete offsets in.
10 Topics: [=>]
11 // Topic is a topic to delete offsets in.
12 Topic: string
13 // Partitions are partitions to delete offsets for.
14 Partitions: [=>]
15 // Partition is a partition to delete offsets for.
16 Partition: int32
17
18// OffsetDeleteResponse is a response to an offset delete request.
19OffsetDeleteResponse =>
20 // ErrorCode is any group wide error.
21 //
22 // GROUP_AUTHORIZATION_FAILED is returned if the client is not authorized
23 // for the group.
24 //
25 // INVALID_GROUP_ID is returned in the requested group ID is invalid.
26 //
27 // COORDINATOR_NOT_AVAILABLE is returned if the coordinator is not available.
28 //
29 // COORDINATOR_LOAD_IN_PROGRESS is returned if the group is loading.
30 //
31 // NOT_COORDINATOR is returned if the requested broker is not the coordinator
32 // for the requested group.
33 //
34 // GROUP_ID_NOT_FOUND is returned if the group ID does not exist.
35 ErrorCode: int16
36 ThrottleMillis
37 // Topics are responses to requested topics.
38 Topics: [=>]
39 // Topic is the topic being responded to.
40 Topic: string
41 // Partitions are partitions being responded to.
42 Partitions: [=>]
43 // Partition is the partition being responded to.
44 Partition: int32
45 // ErrorCode is any per partition error code.
46 //
47 // TOPIC_AUTHORIZATION_FAILED is returned if the client is not authorized
48 // for the topic / partition.
49 //
50 // UNKNOWN_TOPIC_OR_PARTITION is returned if the broker does not know of
51 // the requested topic.
52 //
53 // GROUP_SUBSCRIBED_TO_TOPIC is returned if the topic is still subscribed to.
54 ErrorCode: int16
View as plain text