This repository was archived by the owner on Mar 24, 2021. It is now read-only.
This repository was archived by the owner on Mar 24, 2021. It is now read-only.
how to ensure message not missing #1035
Description
we have a kafka cluster with 5 nodes, and producer gen through method 'get_producer', when we restart one node, the producer got error message bellow:
- pykafka.OwnedBroker.queue_reader for broker 4] Message not delivered!! SocketDisconnectedError()
- pykafka.OwnedBroker.queue_reader for broker 2] Message not delivered!! NotLeaderForPartition
in this situation, how we can identify which message missing or retry to send the missing message when the broken kafka broker is working