[GitHub] [incubator-inlong] LeBW commented on issue #1522: TubeMQ doesn't receive messages from Dataproxy

[GitBox <gi...@apache.org>]

LeBW commented on issue #1522:
URL: https://github.com/apache/incubator-inlong/issues/1522#issuecomment-912977549


   > @LeBW In the bin directory of tubemq, use tubemq-producer-test.sh to send data to the Topic test corresponding to b_test. Can the data be successfully produced?
   > 
   > If data not successfully produced, post the relevant error message; if you can, it means that there is an error when dataproxy reports data to tubemq, send and let me see the topic.properities file in the conf directory of dataproxy.
   
   I try it to send data to the topic, and it's ok. Here is the log.
   ```
   root@49c0683df4a2:/opt/tubemq-server/bin# ./tubemq-producer-test.sh --master-servers localhost:8715 --topicName test
   [2021-09-04 13:48:53,152] INFO Created Session Factory, the config is: {"masterInfo":["localhost:8715"],"rpcReadTimeoutMs":3000,"rpcConnProcessorCnt":17,"rpcNettyWorkMemorySize":10485760,"rpcRspCallBackThreadCnt":3,"nettyWriteBufferHighWaterMark":52428800,"nettyWriteBufferLowWaterMark":5242880,"maxRegisterRetryTimes":5,"regFailWaitPeriodMs":1000,"maxHeartBeatRetryTimes":5,"heartbeatPeriodMs":13000,"heartbeatPeriodAfterFail":60000,"linkStatsDurationMs":60000,"linkStatsForbiddenDurationMs":1800000,"linkStatsMaxAllowedFailTimes":5,"linkStatsMaxForbiddenRate":0.3,"maxSentForbiddenRate":0.15,"maxForbiddenCheckDuration":30000,"sessionStatisticCheckDuration":1000,"sessionWarnForbiddenRate":0.2,"sessionWarnDelayedMsgCount":300000,"linkMaxAllowedDelayedMsgCount":50000,"sessionMaxAllowedDelayedMsgCount":500000,"unAvailableFbdDurationMs":50000,"enableUserAuthentic":false,"usrName":"","usrPassWord":"","localAddress":"172.27.0.3","TLSConfig":{"tlsEnable":false,"tlsPort":8124,"tlsTrustStorePath
 ":"","tlsTrustStorePassword":"","tlsTwoWayAuthEnable":false,"tlsKeyStorePath":"","tlsKeyStorePassword":""}} (org.apache.inlong.tubemq.client.factory.TubeBaseSessionFactory)
   [2021-09-04 13:48:53,200] INFO [Producer] Producer status from ready to running! (org.apache.inlong.tubemq.client.producer.ProducerManager)
   [2021-09-04 13:48:53,202] INFO [Publish begin 2] publish topicSet [test], address = org.apache.inlong.tubemq.client.producer.ProducerManager@6c3708b3 (org.apache.inlong.tubemq.client.producer.ProducerManager)
   [2021-09-04 13:48:53,208] INFO [Publish begin 2] already get meta info, topicSet: [test], waste time 6 Ms (org.apache.inlong.tubemq.client.producer.ProducerManager)
   Required send count VS sent message count = -2 : 5000 (5000:0:0)
   Required send count VS sent message count = -2 : 10000 (10000:0: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.

To unsubscribe, e-mail: commits-unsubscribe@inlong.apache.org

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