RobertIndie commented on issue #1331:
URL:
https://github.com/apache/pulsar-client-go/issues/1331#issuecomment-2699756222
Sorry for the late reply. Seems I misunderstood and thought it was just a
logging issue.
> {"log":{"consumerID":76,
"error":"unexpected
EOF","level":"ERROR","local_addr":{"IP":"10.108.35.29","Port":51180,"Zone":""},
"msg":"handle message Id: ledgerId:60350 entryId:361 partition:-1",
"remote_addr":{"ForceQuery":false,"Fragment":"","Host":"platform-pulsar-broker-0.platform-pulsar-broker.t-bt.svc.cluster.local:6650","OmitHost":false,"Opaque":"","Path":"","RawFragment":"","RawPath":"","RawQuery":"","Scheme":"pulsar","User":null},"time":"2025-02-20T13:46:26.095528909Z"},"stream":"stdout","timestamp":1740059186095}
Which compression algorithm were you using?
Could you try using another client, like a Java client, to consume that
topic if the issue happens again? This will help us determine if the message is
actually corrupted or if there's a problem with the Go client's decompression.
How often does this issue occur? Does it only affect a few messages within a
topic?
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
