Kafka-python - "Fetch to node %i failed: Cancelled

IcyRoad · 5 October 2021 18:42

We are facing the same issue mentioned in below thread. Increased the fetch.max.time.ms but still seeing the same. Any quick thoughts?

github.com/dpkp/kafka-python

Handling "Fetch to node %i failed: Cancelled: ..." error

opened 02:52PM - 04 Sep 18 UTC

closed 06:26PM - 23 Nov 18 UTC

xpyy

Hello. I have kafka with 3 brokers on different servers. I use kafka-python t…o read messages from one topic until i get timeout, like so: ```python def handle(self): consumer = KafkaConsumer(topic, **settings) while True: message = consumer.poll(timeout) if not message: break process_message(message) consumer.close() ``` I'm getting a lot of errors like "Fetch to node %i failed: Cancelled: ..." on 1 or 2 brokers. Debug log tells me that they actually have in flight requests with type "FetchRequest_v3". My questions: 1. Am i do something wrong? 2. If not, how can i fix it?

Thx,
Liz.

IcyRoad · 6 October 2021 16:21

Appreciate any comments on this.

Topic		Replies	Views
Disconnecting from node 1 due to request timeout Kafka Connect	1	225	18 October 2024
Not work Kafka Transactions client developed by Python Non-Java Clients	2	3482	24 March 2022
Kafka Producer Error: Failed to Find Transaction Coordinator and Timed Out Waiting for Operation to Finish Clients	0	467	3 June 2024
[Python] How to capture Application maximum poll interval exceeded error? Non-Java Clients	1	5493	7 June 2022
Nodejs Consumer Timed Out Confluent Cloud	0	3312	3 August 2021

Kafka-python - "Fetch to node %i failed: Cancelled

Related topics