Skip to content

Commit b7f9af2

Browse files
committed
Fixup ProduceResponse v8
1 parent 248eab2 commit b7f9af2

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

kafka/protocol/produce.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -112,12 +112,12 @@ class ProduceResponse_v8(Response):
112112
('error_code', Int16),
113113
('offset', Int64),
114114
('timestamp', Int64),
115-
('log_start_offset', Int64)),
115+
('log_start_offset', Int64),
116116
('record_errors', (Array(
117117
('batch_index', Int32),
118118
('batch_index_error_message', String('utf-8'))
119119
))),
120-
('error_message', String('utf-8'))
120+
('error_message', String('utf-8')))
121121
))),
122122
('throttle_time_ms', Int32)
123123
)

0 commit comments

Comments
 (0)