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.
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
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
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
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