summaryrefslogtreecommitdiff
path: root/kafka/protocol
diff options
context:
space:
mode:
authorDana Powers <dana.powers@gmail.com>2017-08-06 17:41:13 -0700
committerGitHub <noreply@github.com>2017-08-06 17:41:13 -0700
commitda25df6d3c6380e27bf638f3620613d05ac9fd03 (patch)
treea3fb9defc65a4256dfb11dab08be6b36b1b2a416 /kafka/protocol
parent6b97eaefb23f637bc5095e49fd4ab9ee6755ce6e (diff)
downloadkafka-python-da25df6d3c6380e27bf638f3620613d05ac9fd03.tar.gz
Add private map of api key -> min/max versions to BrokerConnection (#1169)
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',
+}