ZhangRui
ZhangRui
### Contact Details _No response_ ### Is there an existing issue for this? - [X] I have searched all the existing issues ### Priority low (Default) ### Environment ```markdown client-v3.3.1-20240417...
kafka 1.1.1 个别topic 这样,1.8.2 就有这个问题回退到logstash 一直正常,今天打了一个最新的1.10 hangout 还是有这个问题 ``` I1011 17:45:51.257189 1 simple_consumer.go:163] "get leader" logger="healer" topic="welland_g117_logtail" partitionID=40 leaderID=2 I1011 17:45:51.258221 1 simple_consumer.go:225] "get commited offset" logger="healer" topic="welland_g117_logtail" partitionID=4 I1011...
1. The log clearly analyzes the failed value of mt. 2. When the client is compatible with parsing the server message, the time zone is set to UTC.
### Contact Details _No response_ ### Is there an existing issue for this? - [X] I have searched all the existing issues ### Priority low (Default) ### Environment ```markdown CubeFS...
``` 2025-08-18T10:28:09.779+0800 | DEBUG | [logger/pulsar_log.go:58] Got command! type:SEND_RECEIPT send_receipt:{producer_id:2 sequence_id:63 message_id:{ledgerId:18446744073709551615 entryId:18446744073709551615} highest_sequence_id:18446744073709551615} with payload size: 0 maxMsgSize: 11534336 {"remote_addr": "pulsar://7.34ds79:6650", "local_addr": "7.dsds.43:58326" ``` This message msgId returned -1:-1:x...