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.