shaodong-hub opened a new issue, #8614:
URL: https://github.com/apache/seatunnel/issues/8614

   ### Search before asking
   
   - [x] I had searched in the 
[issues](https://github.com/apache/seatunnel/issues?q=is%3Aissue+label%3A%22bug%22)
 and found no similar issues.
   
   
   ### What happened
   
   按照官方文档写的例子,拉取最新的 docker 镜像,运行会报连接本地kafka 错误
   
   
   
   ### SeaTunnel Version
   
   image: apache/seatunnel:2.3.9
   
   ### SeaTunnel Config
   
   ```conf
   env {
       parallelism=5
       job.mode=STREAMING
       job.name=SeaTunnel_Job
       read_limit.bytes_per_second=7000000
       read_limit.rows_per_second=400
   }
   
   source {
       MySQL-CDC {
           username = "user_cdc"
           password = "******"
           table-names = ["cdc_test_db.account"]
           base-url = "jdbc:mysql://172.18.0.11:3306/cdc_test_db"
           schema-changes.enabled = true
       }
   }
   
   sink {
       kafka {
           topic = "cdc_test_db"
           bootstrap.servers = "172.18.0.14:9092"
           format = json
           kafka.request.timeout.ms = 60000
           semantics = EXACTLY_ONCE
           kafka.config = {
               acks = "all"
               request.timeout.ms = 60000
               buffer.memory = 33554432
           }
       }
   }
   ```
   
   ### Running Command
   
   ```shell
   command: ./bin/seatunnel.sh -DJvmOption="-Xms500M -Xmx500M" -m local -c 
/config/mysql_to_kafka.conf
   ```
   
   ### Error Exception
   
   ```log
   seatunnel  | 2025-02-06 08:39:17,445 INFO  [o.a.k.c.NetworkClient         ] 
[kafka-producer-network-thread | producer-SeaTunnel3486-1] - [Producer 
clientId=producer-SeaTunnel3486-1, transactionalId=SeaTunnel3486-1] Node 1 
disconnected.
   seatunnel  | 2025-02-06 08:39:17,445 WARN  [o.a.k.c.NetworkClient         ] 
[kafka-producer-network-thread | producer-SeaTunnel3486-1] - [Producer 
clientId=producer-SeaTunnel3486-1, transactionalId=SeaTunnel3486-1] Connection 
to node 1 (localhost/127.0.0.1:9092) could not be established. Broker may not 
be available.
   seatunnel  | 2025-02-06 08:39:17,517 WARN  [o.a.k.c.NetworkClient         ] 
[kafka-producer-network-thread | producer-SeaTunnel9182-1] - [Producer 
clientId=producer-SeaTunnel9182-1, transactionalId=SeaTunnel9182-1] Connection 
to node 1 (localhost/127.0.0.1:9092) could not be established. Broker may not 
be available.
   seatunnel  | 2025-02-06 08:39:17,517 INFO  [o.a.k.c.NetworkClient         ] 
[kafka-producer-network-thread | producer-SeaTunnel9182-1] - [Producer 
clientId=producer-SeaTunnel9182-1, transactionalId=SeaTunnel9182-1] Node 1 
disconnected.
   ```
   
   ### Zeta or Flink or Spark Version
   
   _No response_
   
   ### Java or Scala Version
   
   _No response_
   
   ### Screenshots
   
   _No response_
   
   ### Are you willing to submit PR?
   
   - [ ] Yes I am willing to submit a PR!
   
   ### Code of Conduct
   
   - [x] I agree to follow this project's [Code of 
Conduct](https://www.apache.org/foundation/policies/conduct)
   


-- 
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: commits-unsubscr...@seatunnel.apache.org.apache.org

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

Reply via email to