summaryrefslogtreecommitdiff
path: root/kafka/protocol
diff options
context:
space:
mode:
Diffstat (limited to 'kafka/protocol')
-rw-r--r--kafka/protocol/__init__.py37
1 files changed, 37 insertions, 0 deletions
diff --git a/kafka/protocol/__init__.py b/kafka/protocol/__init__.py
index 2a269a5..4dcf4a4 100644
--- a/kafka/protocol/__init__.py
+++ b/kafka/protocol/__init__.py
@@ -6,3 +6,40 @@ from .legacy import (
CODEC_NONE, CODEC_GZIP, CODEC_SNAPPY, ALL_CODECS,
ATTRIBUTE_CODEC_MASK, KafkaProtocol,
)
+
+API_KEYS = {
+ 0: 'Produce',
+ 1: 'Fetch',
+ 2: 'ListOffsets',
+ 3: 'Metadata',
+ 4: 'LeaderAndIsr',
+ 5: 'StopReplica',
+ 6: 'UpdateMetadata',
+ 7: 'ControlledShutdown',
+ 8: 'OffsetCommit',
+ 9: 'OffsetFetch',
+ 10: 'FindCoordinator',
+ 11: 'JoinGroup',
+ 12: 'Heartbeat',
+ 13: 'LeaveGroup',
+ 14: 'SyncGroup',
+ 15: 'DescribeGroups',
+ 16: 'ListGroups',
+ 17: 'SaslHandshake',
+ 18: 'ApiVersions',
+ 19: 'CreateTopics',
+ 20: 'DeleteTopics',
+ 21: 'DeleteRecords',
+ 22: 'InitProducerId',
+ 23: 'OffsetForLeaderEpoch',
+ 24: 'AddPartitionsToTxn',
+ 25: 'AddOffsetsToTxn',
+ 26: 'EndTxn',
+ 27: 'WriteTxnMarkers',
+ 28: 'TxnOffsetCommit',
+ 29: 'DescribeAcls',
+ 30: 'CreateAcls',
+ 31: 'DeleteAcls',
+ 32: 'DescribeConfigs',
+ 33: 'AlterConfigs',
+}