道君- Tao Jiuming
道君- Tao Jiuming
The rest API returns binary data response, not JSON. To decode the message, you have to use Pulsar Client API.
Related BK PR: https://github.com/apache/bookkeeper/pull/4485 https://github.com/apache/bookkeeper/pull/4487
there was a PIP to handle the issue
> Hi, did you mean https://github.com/apache/pulsar/wiki/PIP-18:-Pulsar-Replicator? Oh, I searched the mail lists, it not a PIP: https://lists.apache.org/thread/qmt8fvhoodtr3jq2yhm1mvq81l6nnxj1
@lhotari @eolivelli @hangc0276 @zymap Could you please take a look?
> I am not familiar with netty reference count. I have two questions. > > 1. why we need `onSendResponseFinished`? Can we just change to `UnsafeByteOperations.unsafeWrap(entryBody.nioBuffer())`? It may leak memory?...
1. Pulsar-client-go not supports BOOLEAN schema yet 2. You didn't set a `Schema` for the producer and use the `Value` field, the `Value` field needs a `Schema` to encode it...
I created a PR to introduce BooleanSchema: https://github.com/apache/pulsar-client-go/pull/1108
I don't think create missing topic partition metadata in runtime is OK, as @nodece says, it would introduce unpredictable consequences. Actually, I think add a new config is the relatively...