-
Notifications
You must be signed in to change notification settings - Fork 1.4k
Closed
Description
I am using version 1.3.5 and got the following error when trying to fetch messages using poll
File "/home/runner/pipeline.runfiles/kafka_python_git/kafka/consumer/group.py", line 567, in poll
records = self._poll_once(remaining, max_records)
File "/home/runner/pipeline.runfiles/kafka_python_git/kafka/consumer/group.py", line 602, in _poll_once
records, partial = self._fetcher.fetched_records(max_records)
File "/home/runner/pipeline.runfiles/kafka_python_git/kafka/consumer/fetcher.py", line 386, in fetched_records
max_records -= self._append(drained, part, max_records)
File "/home/runner/pipeline.runfiles/kafka_python_git/kafka/consumer/fetcher.py", line 412, in _append
part_records = part.take(max_records)
File "/home/runner/pipeline.runfiles/kafka_python_git/kafka/consumer/fetcher.py", line 945, in take
res = self.messages[self.message_idx:next_idx]
TypeError: slice indices must be integers or None or have an __index__ method
Metadata
Metadata
Assignees
Labels
No labels