xiaolong ran
xiaolong ran
ping @addisonj any update for this?
Hello @zzzming , in `connection` struct, we have defined the maxMessageSize field and obtained the current maxMessageSize value from the broker during the handshake. Does this function not take effect?...
@baomingyu Commulated ack does not actually bring much performance improvement, but will increase the complexity of the current Go SDK implementation. Therefore, we deliberately abandoned this feature in the Go...
cc @cckellogg PTAL
@EAHITechnology Any update for this?
> I think we already tested the topics with `func validateTopicNames(topics ...string) ([]*internal.TopicName, error)`, so could you please fill this PR's content to help us understand the context and what...
@alexec Good ideas, Maybe we can send a PIP or email for this change.
> Awesome! What is a PIP please? Reference to: https://github.com/apache/pulsar/wiki/Pulsar-Improvement-Proposal-%28PIP%29 https://github.com/apache/pulsar/wiki/Pulsar-Improvement-Proposal-Template
Reference to: https://github.com/apache/pulsar/pull/6183
The point is wrong, can MessageRouter not meet our functions? e.g: ``` producer, err := client.CreateProducer(ProducerOptions{ Topic: "my-partitioned-topic", MessageRouter: func(msg *ProducerMessage, tm TopicMetadata) int { fmt.Println("Routing message ", msg, "...