confluent-kafka-dotnet icon indicating copy to clipboard operation
confluent-kafka-dotnet copied to clipboard

Published 20 hours ago • verified publisher icon confluentinc

APIVERSION_QUERY timeout

Open rashmiann opened this issue 1 year ago • 9 comments

Hi, We are facing apiversion query request failure after 2 hours of running producer client (first two hours everything runs smoothly) and then broker connection fails. Producer client running on c5 large machine kafka version used 2.8.1

Timed out ApiVersionRequest in flight (after 10129ms, timeout #0) ApiVersionRequest failed: Local: Timed out: probably due to broker version < 0.10 (see api.version.request configuration) (after 10130ms in state APIVERSION_QUERY) Local: Timed out: probably due to broker version < 0.10 (see api.version.request configuration) (after 10130ms in state APIVERSION_QUERY) Timed out 1 in-flight, 0 retry-queued, 0 out-queue, 0 partially-sent requests Timed out ApiVersionRequest in flight (after 10105ms, timeout #0) failed: Unknown error (after 15402ms in state CONNECT) failed: Unknown error (after 21354ms in state CONNECT) Unknown error (after 15160ms in state CONNECT) failed: Unknown error (after 15237ms in state CONNECT)

How to reproduce

Checklist

Please provide the following information:

  • [ ] A complete (i.e. we can run it), minimal program demonstrating the problem. No need to supply a project file.
  • [ ] Confluent.Kafka nuget version.
  • [ ] Apache Kafka version.
  • [ ] Client configuration.
  • [ ] Operating system.
  • [ ] Provide logs (with "debug" : "..." as necessary in configuration).
  • [ ] Provide broker log excerpts.
  • [ ] Critical issue.

rashmiann avatar Jan 08 '24 08:01 rashmiann

Was the broker reachable from the client? Can you also check the broker logs?

anchitj avatar Feb 01 '24 12:02 anchitj

Hi @anchitj , I also faced the same issue. In my case, broker is reachable only.

@rashmiann Did you able to resolve this error?

ksdvishnukumar avatar Feb 27 '24 07:02 ksdvishnukumar

Getting same error and after this Kafka client(Consumer code) not able to connect again, only option is to restart the pods(service). Kindly let me know of there is any way to configure consumer code to re-initiates the connection

%4|1710193417.943|FAIL|rdkafka#consumer-9886| [thrd:sasl_ssl://brokeraddress.amazonaws.com]: sasl_ssl://b-3.msk-wbrokeraddress.amazonaws.com:9096/3: Connection setup timed out in state APIVERSION_QUERY (after 29924ms in state APIVERSION_QUERY, 1 identical error(s) suppressed) %4|1710193447.946|FAIL|rdkafka#consumer-9886| [thrd:sasl_ssl://b-2.brokeraddress.amazonaws.com]: sasl_ssl://b-2.msk-wbroker.com:9096/2: Connection setup timed out in state APIVERSION_QUERY (after 29912ms in state APIVERSION_QUERY, 1 identical error(s) suppressed)

neerajk22 avatar Mar 15 '24 03:03 neerajk22

Please try to reproduce the issue with Debug="all" and upload the logs here.

anchitj avatar Apr 17 '24 11:04 anchitj

Is this error solved, I am also facing the same when consuming messages from aws msk kafka

rohitgupta333 avatar May 09 '24 14:05 rohitgupta333

Facing same issue on consumer: Connection setup timed out in state APIVERSION_QUERY

darshanambre-gep avatar May 10 '24 19:05 darshanambre-gep

This problem is solved now, I have installed java 11.0.23 in C:\Java and after that registered the environment variables with the same path.

@darshanambre-gep , you can follow the same.

rohitgupta333 avatar May 14 '24 12:05 rohitgupta333

im getting the samue issue on some of my workers, it just random started happening on a few owrkers error

running kafka in k8s , havent changed anything to kafka on the serverside past 6 months .

neither in my client apps that is related to kafka at all for some time

any idea whats going on ? and how to fix this issue ?

fontexD avatar Jul 23 '24 07:07 fontexD