[GitHub] [incubator-seatunnel] wenyongning1 opened a new issue, #4498: [Bug] [Module Name] Bug title

[via GitHub]

wenyongning1 opened a new issue, #4498:
URL: https://github.com/apache/incubator-seatunnel/issues/4498

   ### Search before asking
   
   - [X] I had searched in the 
[issues](https://github.com/apache/incubator-seatunnel/issues?q=is%3Aissue+label%3A%22bug%22)
 and found no similar issues.
   
   
   ### What happened
   
   seatunne sink kafka error
   
   ### SeaTunnel Version
   
   2.3.1
   
   ### SeaTunnel Config
   
   ```conf
   env {
       execution.parallelism = 1
   }
   
   source {
       Jdbc {
           url = "jdbc:mysql://node04:3306/db_test?serverTimezone=GMT%2b8"
           driver = "com.mysql.cj.jdbc.Driver"
           connection_check_timeout_sec = 100
           user = "hadoop",
           password = "hadoop",
           query = "select province_id,area_code from ads_order_by_province"
       }
   }
   
   transform {
   }
   
   sink {
     kafka {
         topic = "wyn_test"
         bootstrap.servers = "192.168.0.101:9092"
         partition = 1
         format = json
         kafka.request.timeout.ms = 6000
         semantics = EXACTLY_ONCE
         kafka.config = {
           acks = "all"
           request.timeout.ms = 6000
           buffer.memory = 33554432
         }
     }
   }
   ```
   
   
   ### Running Command
   
   ```shell
   seatunnel.sh --config 
/opt/soft/seatunnel/seatunnel-2.3.1/job/seatunnel_mysql_kafka.conf -e local
   ```
   
   
   ### Error Exception
   
   ```log
   2023-04-04 16:29:20,764 INFO  org.apache.kafka.clients.Metadata              
              [] - [Producer clientId=producer-SeaTunnel0614-1, 
transactionalId=SeaTunnel0614-1] Resetting the last seen epoch of partition 
wyn_test-0 to 0 since the associated topicId changed from null to 
nS8WxqKRQEipTsX003--bA
   2023-04-04 16:30:20,760 INFO  
org.apache.kafka.clients.producer.internals.TransactionManager [] - [Producer 
clientId=producer-SeaTunnel0614-1, transactionalId=SeaTunnel0614-1] Transiting 
to abortable error state due to 
org.apache.kafka.common.errors.TimeoutException: Topic wyn_test not present in 
metadata after 60000 ms.
   2023-04-04 16:31:20,761 INFO  
org.apache.kafka.clients.producer.internals.TransactionManager [] - [Producer 
clientId=producer-SeaTunnel0614-1, transactionalId=SeaTunnel0614-1] Transiting 
to abortable error state due to 
org.apache.kafka.common.errors.TimeoutException: Topic wyn_test not present in 
metadata after 60000 ms.
   2023-04-04 16:32:20,763 INFO  
org.apache.kafka.clients.producer.internals.TransactionManager [] - [Producer 
clientId=producer-SeaTunnel0614-1, transactionalId=SeaTunnel0614-1] Transiting 
to abortable error state due to 
org.apache.kafka.common.errors.TimeoutException: Topic wyn_test not present in 
metadata after 60000 ms.
   ```
   
   
   ### 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