Skip to content

UnknownTopicOrPartitionError should be retriable #1155

Closed
@tvoinarovskyi

Description

@tvoinarovskyi

This ticket is a result of aio-libs/aiokafka#176. The issue is that producer will raise UnknownTopicOrPartitionError to the user if a manual partition reassignment is in process.
How to reproduce:

As I understand NotLeaderForPartition is only raised if node actually contains replication data on it. On reassignment a previous Leader partition will migrate data to a new node and remove it's data, so the error raised will be UnknownTopicOrPartitionError instead.

Java client treats UnknownTopicOrPartitionError as retriable too:
https://kafka.apache.org/protocol#protocol_error_codes
https://github.com/apache/kafka/blob/0.11.0.0/clients/src/main/java/org/apache/kafka/common/errors/UnknownTopicOrPartitionException.java

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