yufan022 opened a new issue #9227:
URL: https://github.com/apache/pulsar/issues/9227


   **Describe the bug**
   Start debezium for the first time and everything is OK. When restart 
debezium after running for a while, it often fails to start. There's a very 
small chance that it will success.
   
   **To Reproduce**
   Steps to reproduce the behavior:
   1. start debezium mysql connector - success
   2. stop debezium mysql connector
   3. start debezium mysql connector - failed
   
   **Screenshots**
   If applicable, add screenshots to help explain your problem.
   
![image](https://user-images.githubusercontent.com/30121694/104876107-ead6ae80-5991-11eb-8f6a-72b38c40322c.png)
   
   **Desktop (please complete the following information):**
    - OS: linux
   
   **Additional context**
   ```
   bin/pulsar-admin sources localrun --archive 
connectors/pulsar-io-debezium-mysql-2.7.0.nar --name debezium-mysql-source 
--destination-topic-name public/xxxx/debezium-mysql-topic --tenant public 
--namespace xxxx --cpu 2 --ram 1073741824 --source-config 
'{"database.hostname": "x.x.x.x","database.port": "xxxx","database.user": 
"xxxx","database.password": "xxxx","database.server.id": 
"184054","database.server.name": "xxxx","database.whitelist": 
"xxxx","database.history": 
"org.apache.pulsar.io.debezium.PulsarDatabaseHistory","database.history.pulsar.topic":
 "public/xxxx/history-topic","database.history.pulsar.service.url": 
"pulsar://pulsar-mini-proxy:6650","key.converter": 
"org.apache.kafka.connect.json.JsonConverter","value.converter": 
"org.apache.kafka.connect.json.JsonConverter","pulsar.service.url": 
"pulsar://pulsar-mini-proxy:6650","offset.storage.topic": 
"public/xxxx/offset-topic","decimal.handling.mode": "string"}'
   ```
   
   ```
   05:26:48.269 [pulsar-client-io-7-1] INFO  
org.apache.pulsar.client.impl.ConsumerStatsRecorderImpl - Pulsar client config: 
{
     "serviceUrl" : "pulsar://pulsar-mini-proxy:6650",
     "authPluginClassName" : null,
     "operationTimeoutMs" : 30000,
     "statsIntervalSeconds" : 60,
     "numIoThreads" : 1,
     "numListenerThreads" : 1,
     "connectionsPerBroker" : 1,
     "useTcpNoDelay" : true,
     "useTls" : false,
     "tlsTrustCertsFilePath" : "",
     "tlsAllowInsecureConnection" : false,
     "tlsHostnameVerificationEnable" : false,
     "concurrentLookupRequest" : 5000,
     "maxLookupRequest" : 50000,
     "maxLookupRedirects" : 20,
     "maxNumberOfRejectedRequestPerConnection" : 50,
     "keepAliveIntervalSeconds" : 30,
     "connectionTimeoutMs" : 10000,
     "requestTimeoutMs" : 60000,
     "initialBackoffIntervalNanos" : 100000000,
     "maxBackoffIntervalNanos" : 60000000000,
     "listenerName" : null,
     "useKeyStoreTls" : false,
     "sslProvider" : null,
     "tlsTrustStoreType" : "JKS",
     "tlsTrustStorePath" : null,
     "tlsTrustStorePassword" : null,
     "tlsCiphers" : [ ],
     "tlsProtocols" : [ ],
     "proxyServiceUrl" : null,
     "proxyProtocol" : null,
     "enableTransaction" : false
   }
   05:26:48.275 [pulsar-client-io-7-1] INFO  
org.apache.pulsar.client.impl.ConsumerImpl - 
[public/3427/offset-topic][reader-5579d7a108] Subscribing to topic on cnx [id: 
0xa3f72b6f, L:/10.42.14.92:40958 - 
R:pulsar-mini-proxy.pulsar.svc.cluster.local/10.43.18.5:6650], consumerId 0
   05:26:48.282 [pulsar-client-io-7-1] INFO  
org.apache.pulsar.client.impl.ConsumerImpl - 
[public/3427/offset-topic][reader-5579d7a108] Subscribed to topic on 
pulsar-mini-proxy.pulsar.svc.cluster.local/10.43.18.5:6650 -- consumer: 0
   05:26:48.297 [pulsar-client-io-7-1] INFO  
com.scurrilous.circe.checksum.Crc32cIntChecksum - SSE4.2 CRC32C provider 
initialized
   05:26:48.402 [pulsar-client-io-7-1] INFO  
org.apache.pulsar.client.impl.ConsumerImpl - 
[public/3427/offset-topic][reader-5579d7a108] Successfully getLastMessageId 
1969:96
   05:27:48.271 [pulsar-timer-10-1] INFO  
org.apache.pulsar.client.impl.ConsumerStatsRecorderImpl - 
[public/3427/offset-topic] [reader-5579d7a108] [ca99a] Prefetched messages: 858 
--- Consume throughput received: 10.70 msgs/s --- 0.01 Mbit/s --- Ack sent 
rate: 0.00 ack/s --- Failed messages: 0 --- batch messages: 0 ---Failed acks: 0
   
   ```


----------------------------------------------------------------
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.

For queries about this service, please contact Infrastructure at:
[email protected]


Reply via email to