farbodahm opened a new pull request, #16166:
URL: https://github.com/apache/kafka/pull/16166

   I was using Kafka Connect ([Confluent 
Image](https://hub.docker.com/r/confluentinc/cp-kafka-connect)) to run an 
Iceberg Sink connector on 2 different AWS environments (running on ECS) and 
same Kafka cluster.
   
   One of the connectors was working fine, but the other was continuously 
getting error below:
   
   > {"error_code":500,"message":"IO Error trying to forward REST request: 
java.net.SocketTimeoutException: Connect Timeout"}
   
   After hours of debugging, I found that the Connect in second AWS environment 
was trying to reach out to the Connect in first AWS environment (apparently, 
that was the leader) and our firewall was dropping the request. By fixing the 
firewall, issue solved.
   By having the URL in the error log message, we could easily find issue by 
looking at which IP it's trying to reach.
   
   ### Committer Checklist (excluded from commit message)
   - [ ] Verify design and implementation 
   - [ ] Verify test coverage and CI build status
   - [ ] Verify documentation (including upgrade notes)
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

Reply via email to