SocketTimeOut with Kafka connector

Hi Team,

We are using kafka connect elasticsearch sink connector. From a kafka topic having avro data, we are dumping it into an elasticsearch index with the sink connector. With minimal load like manual pushing of few records, the connector works fine and index is also updated.

However during bulk loads, we are getting java.net.SocketTimeoutException multiple times, which leads to the connector failure. Could anyone please guide us?

Thanks in advance.

The connector in turn uses JEST client. Any help is appreciated.

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.