Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

Appearance settings

TypeError: '<' not supported between instances of 'NoneType' and 'float' #2635

Copy link
Copy link
Closed
@MrBIN89

Description

@MrBIN89
Issue body actions
Traceback (most recent call last):
  File "/opt/venv/lib/python3.9/site-packages/KafkaLibrary/Consumer.py", line 105, in get_position
    return self.consumer.position(topic_partition)
  File "/opt/venv/lib/python3.9/site-packages/kafka/consumer/group.py", line 758, in position
    if self._update_fetch_positions(timeout_ms=timer.timeout_ms):
  File "/opt/venv/lib/python3.9/site-packages/kafka/consumer/group.py", line 1156, in _update_fetch_positions
    return not self._fetcher.reset_offsets_if_needed()
  File "/opt/venv/lib/python3.9/site-packages/kafka/consumer/fetcher.py", line 193, in reset_offsets_if_needed
    partitions = self._subscriptions.partitions_needing_reset()
  File "/opt/venv/lib/python3.9/site-packages/kafka/consumer/subscription_state.py", line 383, in partitions_needing_reset
    if state.awaiting_reset and state.is_reset_allowed():
  File "/opt/venv/lib/python3.9/site-packages/kafka/consumer/subscription_state.py", line 444, in is_reset_allowed
    return self.next_allowed_retry_time is None or self.next_allowed_retry_time < time.time()
TypeError: '<' not supported between instances of 'NoneType' and 'float'

kafka-python==2.2.10
Python 3.9.13

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions

      Morty Proxy This is a proxified and sanitized view of the page, visit original site.