Re: Timeout not getting applied on KafkaAdminClient.create

2023-02-13 Thread shruti pandey
Hi, Tuning SOCKET_CONNECTION_SETUP_TIMEOUT_MAX_MS_CONFIG / SOCKET_CONNECTION_SETUP_TIMEOUT_MS_CONFIG didn't helped, what i fail to understand is why timeout is not happening after 30seconds. These are the properties i have configured. {ssl.protocol=TLSv1.2, request.timeout.ms=1000, acks=0, batch.

Timeout not getting applied on KafkaAdminClient.create

2023-02-13 Thread shruti pandey
Hi, I want to add timeout for KafkaAdminClient creation. AdminClient admin1 = KafkaAdminClient.create(properties); I have thread which gets killed after 10seconds. I want that if KafkaAdminClient creation is taking more time it should timeout. But when kafka-broker is not present my code gets st

Kafka AdminClient DEFAULT_API_TIMEOUT_MS_CONFIG property not working as expected.

2022-12-19 Thread shruti pandey
Hi, I have previously send this query. In my java application for kafkaProducer i created Admin and used this to list topics. Admin admin1 = Admin.create(properties). ListTopicsResult listTopicResult = admin1.listTopics(); When producer was not able to connect to broker, thread get stucks at l

RE: [External] : Re: Kafka AdminClient DEFAULT_API_TIMEOUT_MS_CONFIG property not working as expected

2022-12-12 Thread Shruti Pandey
Diz7B-fhT01GR-OHbz3oR9CRhisbAc5rq6RtORRbEzUuWonu1NrwvyYtQ$ Try also set request.timeout.ms=2000, please. Thank you. Luke On Mon, Dec 12, 2022 at 2:54 PM Shruti Pandey wrote: > Hi, > > In my java application for kafkaProducer i created Admin and used this > to list topics. > > Admin a

Kafka AdminClient DEFAULT_API_TIMEOUT_MS_CONFIG property not working as expected

2022-12-11 Thread Shruti Pandey
Hi, In my java application for kafkaProducer i created Admin and used this to list topics. Admin admin1 = Admin.create(properties). ListTopicsResult listTopicResult = admin1.listTopics(); When producer was not able to connect to broker, thread get stucks at listTopic step. To avoid this i ha