Skip to content

Commit 5581649

Browse files
author
Ashish Walia
committed
Syncing offset commit and fetch api keys with Kafka trunk code
1 parent 354fcdb commit 5581649

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

kafka/protocol.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -29,8 +29,8 @@ class KafkaProtocol(object):
2929
FETCH_KEY = 1
3030
OFFSET_KEY = 2
3131
METADATA_KEY = 3
32-
OFFSET_COMMIT_KEY = 6
33-
OFFSET_FETCH_KEY = 7
32+
OFFSET_COMMIT_KEY = 8
33+
OFFSET_FETCH_KEY = 9
3434

3535
ATTRIBUTE_CODEC_MASK = 0x03
3636
CODEC_NONE = 0x00

0 commit comments

Comments
 (0)