xiaolong ran

Signed-off-by: xiaolongran ### Motivation Currently, when Go SDK creates a connection, the version information set is fixed to Pulsar Go 0.1. When we maintain multiple versions of Go SDK in...

Signed-off-by: xiaolongran ### Motivation In #775 and #776, we support the error information that may occur when the Go SDK side processes the Ack Command, but there is a bug...

Signed-off-by: xiaolongran ### Motivation When producer send message or consumer receive message in non-batch, return the batchIdx is `0` ``` msgId: pulsar.trackingMessageID{messageID:pulsar.messageID{ledgerID:11653378, entryID:3807, batchIdx:0, partitionIdx:2} ``` In fact, when we...

[Go schema] Support multi version schema for repo

1

Currently, we already support a single topic schema in producer and consumer for Go client. The following are other functions of the schema that need to be supported: - [...

Add unit test case for SubscriptionProperties, refer to: https://github.com/apache/pulsar-client-go/pull/671#issuecomment-981257522

[Reader] The topic not found when create reader with listener name

2

**Describe the bug** A clear and concise description of what the bug is. **To Reproduce** ``` package main import ( "context" "fmt" "log" "github.com/apache/pulsar-client-go/pulsar" ) func main() { client, err...

#### Expected behavior When a request error occurs, expect the pendingRequest resource to be shut down normally #### Actual behavior When we clean up the cache resources of the producer...

Support Kerberos auth for Go client

1

Support Kerberos auth for Go client

Add offload-policies commands to pulsarctl

1

- pulsarctl namespaces set-offload-policies [options] - pulsarctl namespaces get-offload-policies [options]

[pulsarctl] [schemas] `Extract ` command is not supported

1

In `CmdSchemas.java`, code logic as follows: ``` File file = new File(jarFilePath); ClassLoader cl = new URLClassLoader(new URL[]{ file.toURI().toURL() }); Class cls = cl.loadClass(className); PostSchemaPayload input = new PostSchemaPayload(); SchemaDefinition...