{"payload":{"feedbackUrl":"https://github.com/orgs/community/discussions/53140","repo":{"id":185278617,"defaultBranch":"master","name":"pulsar-client-go","ownerLogin":"apache","currentUserCanPush":false,"isFork":false,"isEmpty":false,"createdAt":"2019-05-06T22:08:46.000Z","ownerAvatar":"https://avatars.githubusercontent.com/u/47359?v=4","public":true,"private":false,"isOrgOwned":true},"refInfo":{"name":"","listCacheKey":"v0:1714602441.0","currentOid":""},"activityList":{"items":[{"before":"b0111a2dc473317e4b41ab4af09e42b09a72384c","after":"2d51323103a65ba522dc73f56f052cc81d663245","ref":"refs/heads/master","pushedAt":"2024-05-28T10:45:16.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"RobertIndie","name":"Zike Yang","path":"/RobertIndie","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/16974619?s=80&v=4"},"commit":{"message":"[Improve] PIP-313 Add GetLastMessageIDs API (#1221)\n\n### Motivation\r\nTo keep consistent with the Java client.\r\n\r\nReleted PR: https://github.com/apache/pulsar/pull/20040\r\n\r\n### Modifications\r\n- Add `GetLastMessageIDs`api for consumer.","shortMessageHtmlLink":"[Improve] PIP-313 Add GetLastMessageIDs API (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2310648917\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/pulsar-client-go/issues/1221\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/apache/pulsar-client-go/pull/1221/hovercard\" href=\"https://github.com/apache/pulsar-client-go/pull/1221\">#1221</a>)"}},{"before":"a09ae3225334fb9587e5087e3adb2f944e89635d","after":"b0111a2dc473317e4b41ab4af09e42b09a72384c","ref":"refs/heads/master","pushedAt":"2024-05-20T10:59:31.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"RobertIndie","name":"Zike Yang","path":"/RobertIndie","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/16974619?s=80&v=4"},"commit":{"message":"[Improve] PIP-313 Support force unsubscribe using consumer api (#1220)\n\n### Motivation\r\nTo keep consistent with the Java client.\r\nReleted PR: https://github.com/apache/pulsar/pull/21687\r\n\r\n### Modifications\r\n- Add `UnsubscribeForce`api for consumer.","shortMessageHtmlLink":"[Improve] PIP-313 Support force unsubscribe using consumer api (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2299447668\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/pulsar-client-go/issues/1220\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/apache/pulsar-client-go/pull/1220/hovercard\" href=\"https://github.com/apache/pulsar-client-go/pull/1220\">#1220</a>)"}},{"before":"43d8cfc414aff426ae9cc74e905d280332c86e3c","after":"a09ae3225334fb9587e5087e3adb2f944e89635d","ref":"refs/heads/master","pushedAt":"2024-05-20T10:43:05.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"RobertIndie","name":"Zike Yang","path":"/RobertIndie","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/16974619?s=80&v=4"},"commit":{"message":"[Issue 1218][Reader] Reader Next returns on closed consumer (#1219)\n\nFixes #1218 \r\n\r\n### Motivation\r\n\r\nCalling Next on a reader already closed will block forever unless the context is canceled. Similarly, the call will not return if a different go routine closes the reader.\r\n\r\n### Modifications\r\n\r\nNext now listens for the close channel of the consumer to return an error when it closes.\r\n\r\nSigned-off-by: Gaylor Bosson <gb@taurusgroup.ch>","shortMessageHtmlLink":"[Issue 1218][Reader] Reader Next returns on closed consumer (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2298080198\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/pulsar-client-go/issues/1219\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/apache/pulsar-client-go/pull/1219/hovercard\" href=\"https://github.com/apache/pulsar-client-go/pull/1219\">#1219</a>)"}},{"before":"8e9087339d0d004231d3f8fc5f823e561840182b","after":"43d8cfc414aff426ae9cc74e905d280332c86e3c","ref":"refs/heads/master","pushedAt":"2024-05-16T12:25:04.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"RobertIndie","name":"Zike Yang","path":"/RobertIndie","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/16974619?s=80&v=4"},"commit":{"message":"[cleanup] Remove AvroCodec from JSONSchema (#1216)\n\n### Modifications\r\n\r\n`AvroCodec` is not used.\r\nRemove `AvroCodec` from `JSONSchema`.","shortMessageHtmlLink":"[cleanup] Remove AvroCodec from JSONSchema (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2293070622\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/pulsar-client-go/issues/1216\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/apache/pulsar-client-go/pull/1216/hovercard\" href=\"https://github.com/apache/pulsar-client-go/pull/1216\">#1216</a>)"}},{"before":"49fce72614c37fd8644c6305eb3405fcf48d4f52","after":"8e9087339d0d004231d3f8fc5f823e561840182b","ref":"refs/heads/master","pushedAt":"2024-05-14T09:20:31.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"RobertIndie","name":"Zike Yang","path":"/RobertIndie","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/16974619?s=80&v=4"},"commit":{"message":"[fix] Return an error when AckCumulative on a Shared/KeyShared subscription (#1217)\n\n### Motivation\r\n\r\nThe consumer should return error when AckCumulative on a Shared/KeyShared subscription","shortMessageHtmlLink":"[fix] Return an error when AckCumulative on a Shared/KeyShared subscr…"}},{"before":"007d14e50c886a0bbfc73d2a43d3cc932c9221d8","after":"49fce72614c37fd8644c6305eb3405fcf48d4f52","ref":"refs/heads/master","pushedAt":"2024-05-10T14:08:57.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"RobertIndie","name":"Zike Yang","path":"/RobertIndie","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/16974619?s=80&v=4"},"commit":{"message":"[Improve] Supplement schema admin api (#1215)\n\n### Motivation\r\nTo keep consistent with the Java client.\r\n\r\n### Modifications\r\n- CreateSchemaBySchemaInfo\r\n- GetVersionBySchemaInfo\r\n- GetVersionByPayload\r\n- TestCompatibilityWithSchemaInfo\r\n- TestCompatibilityWithPostSchemaPayload","shortMessageHtmlLink":"[Improve] Supplement schema admin api (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2287164256\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/pulsar-client-go/issues/1215\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/apache/pulsar-client-go/pull/1215/hovercard\" href=\"https://github.com/apache/pulsar-client-go/pull/1215\">#1215</a>)"}},{"before":"a086d3257cfbe1226ca9727211de449857b178e4","after":"007d14e50c886a0bbfc73d2a43d3cc932c9221d8","ref":"refs/heads/master","pushedAt":"2024-05-09T05:46:42.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"nodece","name":"Zixuan Liu","path":"/nodece","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/16235121?s=80&v=4"},"commit":{"message":"[improve] Upgrade golang-jwt to v5 (#1214)","shortMessageHtmlLink":"[improve] Upgrade golang-jwt to v5 (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2286761214\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/pulsar-client-go/issues/1214\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/apache/pulsar-client-go/pull/1214/hovercard\" href=\"https://github.com/apache/pulsar-client-go/pull/1214\">#1214</a>)"}},{"before":"8fa0878c88ee4b6e002c7764a10c79012b14be90","after":"a086d3257cfbe1226ca9727211de449857b178e4","ref":"refs/heads/master","pushedAt":"2024-05-07T15:13:47.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"RobertIndie","name":"Zike Yang","path":"/RobertIndie","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/16974619?s=80&v=4"},"commit":{"message":"[Improve] Add admin api ForceDeleteSchema (#1213)\n\n### Motivation\r\n\r\nTo keep consistent with the Java client.\r\n\r\n\r\n### Modifications\r\n\r\nAdd admin api ForceDeleteSchema","shortMessageHtmlLink":"[Improve] Add admin api ForceDeleteSchema (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2282197530\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/pulsar-client-go/issues/1213\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/apache/pulsar-client-go/pull/1213/hovercard\" href=\"https://github.com/apache/pulsar-client-go/pull/1213\">#1213</a>)"}},{"before":"86054c5f0f4aa211a0785ca2b040854629a0b196","after":"8fa0878c88ee4b6e002c7764a10c79012b14be90","ref":"refs/heads/master","pushedAt":"2024-05-07T03:13:11.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"RobertIndie","name":"Zike Yang","path":"/RobertIndie","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/16974619?s=80&v=4"},"commit":{"message":"[Improve] Add admin api GetListActiveBrokers (#1212)\n\n### Motivation\r\n\r\nTo keep consistent with the [Java client](https://github.com/apache/pulsar/pull/14702).\r\n\r\n\r\n### Modifications\r\n\r\nAdd admin api GetListActiveBrokers","shortMessageHtmlLink":"[Improve] Add admin api GetListActiveBrokers (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2279942557\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/pulsar-client-go/issues/1212\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/apache/pulsar-client-go/pull/1212/hovercard\" href=\"https://github.com/apache/pulsar-client-go/pull/1212\">#1212</a>)"}},{"before":"cfd27420e9591361ae2fa99d329d3698f2f98977","after":null,"ref":"refs/heads/blue-green","pushedAt":"2024-05-01T22:27:21.000Z","pushType":"branch_deletion","commitsCount":0,"pusher":{"login":"heesung-sn","name":"Heesung Sohn","path":"/heesung-sn","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/103456639?s=80&v=4"}},{"before":null,"after":"cfd27420e9591361ae2fa99d329d3698f2f98977","ref":"refs/heads/blue-green","pushedAt":"2024-05-01T22:26:19.000Z","pushType":"branch_creation","commitsCount":0,"pusher":{"login":"heesung-sn","name":"Heesung Sohn","path":"/heesung-sn","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/103456639?s=80&v=4"},"commit":{"message":"test","shortMessageHtmlLink":"test"}},{"before":"458defe3ca66ba87664966bcafd58d1350b46acf","after":"86054c5f0f4aa211a0785ca2b040854629a0b196","ref":"refs/heads/master","pushedAt":"2024-04-23T16:30:50.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"BewareMyPower","name":"Yunze Xu","path":"/BewareMyPower","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/18204803?s=80&v=4"},"commit":{"message":"[improve] PIP-307: Use assigned broker URL hints during broker reconnection (#1208)","shortMessageHtmlLink":"[improve] PIP-307: Use assigned broker URL hints during broker reconn…"}},{"before":"43818365e1ee0538a7d8cf3f7576a7d95b845213","after":null,"ref":"refs/heads/dependabot/go_modules/golang.org/x/net-0.23.0","pushedAt":"2024-04-22T16:06:45.000Z","pushType":"branch_deletion","commitsCount":0,"pusher":{"login":"dependabot[bot]","name":null,"path":"/apps/dependabot","primaryAvatarUrl":"https://avatars.githubusercontent.com/in/29110?s=80&v=4"}},{"before":"b4d45cd360599b52e3f160db9d39d619889c556a","after":"458defe3ca66ba87664966bcafd58d1350b46acf","ref":"refs/heads/master","pushedAt":"2024-04-22T16:06:38.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"merlimat","name":"Matteo Merli","path":"/merlimat","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/62500?s=80&v=4"},"commit":{"message":"chore(deps): bump golang.org/x/net from 0.17.0 to 0.23.0 (#1209)\n\nBumps [golang.org/x/net](https://github.com/golang/net) from 0.17.0 to 0.23.0.\r\n- [Commits](https://github.com/golang/net/compare/v0.17.0...v0.23.0)\r\n\r\n---\r\nupdated-dependencies:\r\n- dependency-name: golang.org/x/net\r\n  dependency-type: indirect\r\n...\r\n\r\nSigned-off-by: dependabot[bot] <support@github.com>\r\nCo-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>","shortMessageHtmlLink":"chore(deps): bump golang.org/x/net from 0.17.0 to 0.23.0 (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2252869802\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/pulsar-client-go/issues/1209\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/apache/pulsar-client-go/pull/1209/hovercard\" href=\"https://github.com/apache/pulsar-client-go/pull/1209\">#1209</a>)"}},{"before":"13ecca24ffb6b65ac7ec36da53ecb67479518647","after":"b4d45cd360599b52e3f160db9d39d619889c556a","ref":"refs/heads/master","pushedAt":"2024-04-22T13:25:00.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"BewareMyPower","name":"Yunze Xu","path":"/BewareMyPower","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/18204803?s=80&v=4"},"commit":{"message":"[Improve] Add admin api GetLeaderBroker (#1203)\n\n### Motivation\r\n\r\nTo keep consistent with the [Java client](https://github.com/apache/pulsar/pull/9799).\r\n\r\n### Modifications\r\n\r\nAdd `GetLeaderBroker` interface.","shortMessageHtmlLink":"[Improve] Add admin api GetLeaderBroker (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2242783268\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/pulsar-client-go/issues/1203\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/apache/pulsar-client-go/pull/1203/hovercard\" href=\"https://github.com/apache/pulsar-client-go/pull/1203\">#1203</a>)"}},{"before":"26e80855bb9848d41781840368e53d74f7df1102","after":"13ecca24ffb6b65ac7ec36da53ecb67479518647","ref":"refs/heads/master","pushedAt":"2024-04-22T13:23:49.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"BewareMyPower","name":"Yunze Xu","path":"/BewareMyPower","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/18204803?s=80&v=4"},"commit":{"message":"[improve] add a lint-docker command in makefile (#1207)\n\nCo-authored-by: ninjazhou <ninjazhou@tencent.com>","shortMessageHtmlLink":"[improve] add a lint-docker command in makefile (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2250072875\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/pulsar-client-go/issues/1207\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/apache/pulsar-client-go/pull/1207/hovercard\" href=\"https://github.com/apache/pulsar-client-go/pull/1207\">#1207</a>)"}},{"before":null,"after":"43818365e1ee0538a7d8cf3f7576a7d95b845213","ref":"refs/heads/dependabot/go_modules/golang.org/x/net-0.23.0","pushedAt":"2024-04-19T12:34:12.000Z","pushType":"branch_creation","commitsCount":0,"pusher":{"login":"dependabot[bot]","name":null,"path":"/apps/dependabot","primaryAvatarUrl":"https://avatars.githubusercontent.com/in/29110?s=80&v=4"},"commit":{"message":"chore(deps): bump golang.org/x/net from 0.17.0 to 0.23.0\n\nBumps [golang.org/x/net](https://github.com/golang/net) from 0.17.0 to 0.23.0.\n- [Commits](https://github.com/golang/net/compare/v0.17.0...v0.23.0)\n\n---\nupdated-dependencies:\n- dependency-name: golang.org/x/net\n  dependency-type: indirect\n...\n\nSigned-off-by: dependabot[bot] <support@github.com>","shortMessageHtmlLink":"chore(deps): bump golang.org/x/net from 0.17.0 to 0.23.0"}},{"before":"a6f4b712c130a2219a73bbfd7d78717bbc9c739f","after":"26e80855bb9848d41781840368e53d74f7df1102","ref":"refs/heads/master","pushedAt":"2024-04-18T13:08:33.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"RobertIndie","name":"Zike Yang","path":"/RobertIndie","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/16974619?s=80&v=4"},"commit":{"message":"[improve] Use physical address information in connection pool key (#1206)\n\n### Motivation\r\n\r\nMigrate https://github.com/apache/pulsar/pull/22085/ and (parts of) https://github.com/apache/pulsar-client-cpp/pull/411/ over to the Go client. Context for this idea [here](https://github.com/apache/pulsar/pull/22085/files#r1497008116).\r\n\r\nGolang client support for blue-green migration needs the connection pool to differentiate between connections with the same logical address, but different physical addresses. Otherwise, the wrong connection might be used by the client, in effect pointing to the old cluster, instead of the new one.\r\n\r\n### Modifications\r\n\r\nThe connection pool maintains a map of connections, keyed by their logical address and a random connection id. This PR proposes including the physical address in the key also, therefore allowing the upper layer to differentiate between connections with identical logical addresses, but different physical addresses. \r\n\r\nIn addition to this change, the test setup had to be fixed to address breakages in `TestRetryWithMultipleHosts` and `TestReaderWithMultiHosts`. All tests in the repository are using a local standalone setup currently. This unusual configuration has broker lookup operations reply with flag `proxyThroughServiceUrl=true` ([ref](https://github.com/apache/pulsar/blob/e7c2a75473b545134a3b292ae0e87a79d65cb756/pulsar-broker/src/main/java/org/apache/pulsar/broker/lookup/TopicLookupBase.java#L369)). This in turn has the Go lookup service attempt a name resolution of the configured service addresses ([ref](https://github.com/apache/pulsar-client-go/blob/c3e94e243a730ae22d59bf9d330c4539733b7eef/pulsar/internal/lookup_service.go#L124)). The resolver picks addresses in round-robin mode. Because these two tests use a correct (reachable) broker address _and_ an unreachable address, the resolved address can end up pointing to the unreachable address. The connection pool is then corrupted with a logically invalid entry, causing the tests to fail:\r\n\r\n| Logical Address | Physical Address | Notes |\r\n| --------------- | ---------------- | ----- |\r\n| reachable-broker | reachable-broker | Valid |\r\n| unreachable-broker | unreachable-broker | Valid, but currently unusable |\r\n| reachable-broker | unreachable-broker | *Invalid entry* |\r\n\r\nTo address the issue:\r\n- Switch the test setup to a more common cluster configuration. File `integration-tests/clustered/docker-compose.yml` instructs how this setup should look like.\r\n- Migrate the tests to separate files and test suites. New test files `pulsar/client_impl_clustered_test.go` and `pulsar/reader_clustered_test.go` contain Go tag `clustered`, allowing them to be ignored during the standalone test runs by virtue of the Go build process.\r\n- Add script `run-ci-clustered.sh`, specifying the \"clustered\" tests to run.\r\n- Changes in the `Makefile` add targets `make test_clustered` `make test_standalone` to run the respective test suites independently, while allowing `make test` to run all the tests, as before.\r\n- `Dockerfile` and `run-ci.sh` are modified to run the Go build process in the container build, such that it does not need to be run again in the new `run-ci-clustered.sh` script. The image is locally consumed by the tests only and is not published, so there is no risk of contaminating users.","shortMessageHtmlLink":"[improve] Use physical address information in connection pool key (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2247031796\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/pulsar-client-go/issues/1206\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/apache/pulsar-client-go/pull/1206/hovercard\" href=\"https://github.com/apache/pulsar-client-go/pull/1206\">#1206</a>"}},{"before":"c3e94e243a730ae22d59bf9d330c4539733b7eef","after":"a6f4b712c130a2219a73bbfd7d78717bbc9c739f","ref":"refs/heads/master","pushedAt":"2024-04-18T01:15:22.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"freeznet","name":"Rui Fu","path":"/freeznet","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/1381618?s=80&v=4"},"commit":{"message":"expose RuntimeFlags (#1204)","shortMessageHtmlLink":"expose RuntimeFlags (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2245123162\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/pulsar-client-go/issues/1204\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/apache/pulsar-client-go/pull/1204/hovercard\" href=\"https://github.com/apache/pulsar-client-go/pull/1204\">#1204</a>)"}},{"before":"10819739d8c0f66bf97745ba0bdf5630e09f58d4","after":"c3e94e243a730ae22d59bf9d330c4539733b7eef","ref":"refs/heads/master","pushedAt":"2024-04-17T02:29:08.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"RobertIndie","name":"Zike Yang","path":"/RobertIndie","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/16974619?s=80&v=4"},"commit":{"message":"[fix][build] Build test container image using current hardware platform (#1205)\n\n### Motivation\r\n\r\nTest container image is built for `amd64` platforms only. This makes it difficult to test and run on others, notably Apple Silicon chips running `arm64`.\r\n\r\n### Modifications\r\n\r\nThe source of the problem is using the hardcoded `amd64` Go binary distribution during the image build. On Apple Silicon, running `make test` yields the following error:\r\n\r\n```\r\n...\r\ndocker run -i pulsar-client-go-test:latest bash -c \"cd /pulsar/pulsar-client-go && ./scripts/run-ci.sh\"\r\n+ export GOPATH=/pulsar/go\r\n+ GOPATH=/pulsar/go\r\n+ export GOCACHE=/tmp/go-cache\r\n+ GOCACHE=/tmp/go-cache\r\n+ go mod download\r\nrosetta error: failed to open elf at /lib64/ld-linux-x86-64.so.2\r\n ./scripts/run-ci.sh: line 26:     7 Trace/breakpoint trap   go mod download\r\nmake: *** [test] Error 133\r\n```\r\n\r\nSourcing the local platform name from `uname -m` and using it to download the corresponding Go distribution solves the issue:\r\n\r\n```\r\n...\r\ndocker run -i pulsar-client-go-test:latest bash -c \"cd /pulsar/pulsar-client-go && ./scripts/run-ci.sh\"\r\n+ export GOPATH=/pulsar/go\r\n+ GOPATH=/pulsar/go\r\n+ export GOCACHE=/tmp/go-cache\r\n+ GOCACHE=/tmp/go-cache\r\n+ go mod download\r\n+ go build ./pulsar\r\n+ go build -o bin/pulsar-perf ./perf\r\n+ scripts/pulsar-test-service-start.sh\r\n...\r\n```","shortMessageHtmlLink":"[fix][build] Build test container image using current hardware platfo…"}},{"before":"3096ba59d93570dc48417da36042e499a670030b","after":"10819739d8c0f66bf97745ba0bdf5630e09f58d4","ref":"refs/heads/master","pushedAt":"2024-04-12T05:08:54.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"BewareMyPower","name":"Yunze Xu","path":"/BewareMyPower","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/18204803?s=80&v=4"},"commit":{"message":"[improve] Update topic admin interface comment, add topic admin test cases (#1202)","shortMessageHtmlLink":"[improve] Update topic admin interface comment, add topic admin test …"}},{"before":"393f80b4b93faa36936380b643426026a2b2cd02","after":"3096ba59d93570dc48417da36042e499a670030b","ref":"refs/heads/master","pushedAt":"2024-04-09T16:53:11.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"nodece","name":"Zixuan Liu","path":"/nodece","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/16235121?s=80&v=4"},"commit":{"message":"[Improve] Add admin api HealthCheckWithTopicVersion (#1200)\n\n* add HealthCheckWithTopicVersion api\r\n\r\n* add HealthCheckWithTopicVersion api\r\n\r\n* add HealthCheckWithTopicVersion api\r\n\r\n* read from admin-token\r\n\r\n* fix with cr","shortMessageHtmlLink":"[Improve] Add admin api HealthCheckWithTopicVersion (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2212387312\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/pulsar-client-go/issues/1200\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/apache/pulsar-client-go/pull/1200/hovercard\" href=\"https://github.com/apache/pulsar-client-go/pull/1200\">#1200</a>)"}},{"before":"9023d880c394f60d899e916a4e50249db654c994","after":null,"ref":"refs/heads/dependabot/go_modules/google.golang.org/protobuf-1.33.0","pushedAt":"2024-03-21T14:24:52.000Z","pushType":"branch_deletion","commitsCount":0,"pusher":{"login":"dependabot[bot]","name":null,"path":"/apps/dependabot","primaryAvatarUrl":"https://avatars.githubusercontent.com/in/29110?s=80&v=4"}},{"before":"3693b3695e2f072f9506b64b5e3000e5f107070d","after":"393f80b4b93faa36936380b643426026a2b2cd02","ref":"refs/heads/master","pushedAt":"2024-03-21T14:24:44.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"RobertIndie","name":"Zike Yang","path":"/RobertIndie","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/16974619?s=80&v=4"},"commit":{"message":"chore(deps): bump google.golang.org/protobuf from 1.30.0 to 1.33.0 (#1198)\n\nBumps google.golang.org/protobuf from 1.30.0 to 1.33.0.\r\n\r\n---\r\nupdated-dependencies:\r\n- dependency-name: google.golang.org/protobuf\r\n  dependency-type: direct:production\r\n...\r\n\r\nSigned-off-by: dependabot[bot] <support@github.com>\r\nCo-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>","shortMessageHtmlLink":"chore(deps): bump google.golang.org/protobuf from 1.30.0 to 1.33.0 (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2184999207\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/pulsar-client-go/issues/1198\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/apache/pulsar-client-go/pull/1198/hovercard\" href=\"https://github.com/apache/pulsar-client-go/pull/1198\">#…</a>"}},{"before":"3935fd7b1efe0afe7643fdcc5687559a4d00a40b","after":"3693b3695e2f072f9506b64b5e3000e5f107070d","ref":"refs/heads/master","pushedAt":"2024-03-21T07:39:08.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"RobertIndie","name":"Zike Yang","path":"/RobertIndie","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/16974619?s=80&v=4"},"commit":{"message":"[fix] Change the wrong `SourceInstanceStatusData` in SinkInstanceStatus (#1199)","shortMessageHtmlLink":"[fix] Change the wrong <code>SourceInstanceStatusData</code> in SinkInstanceStat…"}},{"before":null,"after":"9023d880c394f60d899e916a4e50249db654c994","ref":"refs/heads/dependabot/go_modules/google.golang.org/protobuf-1.33.0","pushedAt":"2024-03-13T22:29:17.000Z","pushType":"branch_creation","commitsCount":0,"pusher":{"login":"dependabot[bot]","name":null,"path":"/apps/dependabot","primaryAvatarUrl":"https://avatars.githubusercontent.com/in/29110?s=80&v=4"},"commit":{"message":"chore(deps): bump google.golang.org/protobuf from 1.30.0 to 1.33.0\n\nBumps google.golang.org/protobuf from 1.30.0 to 1.33.0.\n\n---\nupdated-dependencies:\n- dependency-name: google.golang.org/protobuf\n  dependency-type: direct:production\n...\n\nSigned-off-by: dependabot[bot] <support@github.com>","shortMessageHtmlLink":"chore(deps): bump google.golang.org/protobuf from 1.30.0 to 1.33.0"}},{"before":"4f213796979cdf6ffb3477f595b25c4544d76811","after":"3935fd7b1efe0afe7643fdcc5687559a4d00a40b","ref":"refs/heads/master","pushedAt":"2024-03-09T05:33:30.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"RobertIndie","name":"Zike Yang","path":"/RobertIndie","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/16974619?s=80&v=4"},"commit":{"message":"Add change log for 0.12.1 (#1189)\n\n### Motivation\r\n\r\nAdd 0.12.1 change log","shortMessageHtmlLink":"Add change log for 0.12.1 (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2160256103\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/pulsar-client-go/issues/1189\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/apache/pulsar-client-go/pull/1189/hovercard\" href=\"https://github.com/apache/pulsar-client-go/pull/1189\">#1189</a>)"}},{"before":"143fa23228621414784cefae347286e797e4ef84","after":"4f213796979cdf6ffb3477f595b25c4544d76811","ref":"refs/heads/master","pushedAt":"2024-03-08T15:53:30.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"RobertIndie","name":"Zike Yang","path":"/RobertIndie","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/16974619?s=80&v=4"},"commit":{"message":"[Improve]Change base image to apachepulsar/pulsar (#1195)\n\n### Motivation\r\nThere are related discussion records [here](https://github.com/apache/pulsar-client-go/pull/1037). It is recommended to switch the base image to `apachepulsar/pulsar`.\r\n\r\n\r\n### Modifications\r\n\r\nChange base image to `apachepulsar/pulsar`.","shortMessageHtmlLink":"[Improve]Change base image to apachepulsar/pulsar (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2175670500\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/pulsar-client-go/issues/1195\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/apache/pulsar-client-go/pull/1195/hovercard\" href=\"https://github.com/apache/pulsar-client-go/pull/1195\">#1195</a>)"}},{"before":"6d9cbd8ba3aa08b5285cceb0a4688dad57ae3171","after":"143fa23228621414784cefae347286e797e4ef84","ref":"refs/heads/master","pushedAt":"2024-03-08T15:52:51.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"RobertIndie","name":"Zike Yang","path":"/RobertIndie","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/16974619?s=80&v=4"},"commit":{"message":"[Improve] getMessagesById gets all messages (#1194)\n\n### Motivation\r\nTo keep consistent with the Java client.\r\n\r\nReleted PR: https://github.com/apache/pulsar/pull/21918\r\n\r\n\r\n### Modifications\r\n\r\nAdd `getMessagesById` interface.\r\n\r\n---------\r\n\r\nCo-authored-by: Zike Yang <zike@apache.org>","shortMessageHtmlLink":"[Improve] getMessagesById gets all messages (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2175133863\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/pulsar-client-go/issues/1194\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/apache/pulsar-client-go/pull/1194/hovercard\" href=\"https://github.com/apache/pulsar-client-go/pull/1194\">#1194</a>)"}},{"before":"c4f47abd7c82402e7d4e95b55b24ebfef4bdb029","after":"6d9cbd8ba3aa08b5285cceb0a4688dad57ae3171","ref":"refs/heads/master","pushedAt":"2024-03-06T11:20:55.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"BewareMyPower","name":"Yunze Xu","path":"/BewareMyPower","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/18204803?s=80&v=4"},"commit":{"message":"Remove `VERSION` and `stable.txt` files (#1158)\n\n### Motivation\r\n\r\nWe currently have two hardcoded version files in place: `VERSION` which represents the current version and `stable.txt` which represents the current stable version. However, I'm curious about the intended function of these files. Are they merely for developers to conveniently reference the current and stable versions? And what is our approach to managing these files? For instance, how do we determine what constitutes a stable version? If there's no compelling reason to keep these files, I'd propose to remove them.\r\n\r\nPlease see more discussion here: https://lists.apache.org/thread/mrntb1y7ws173ohtdvz1v8q86pg50cn2\r\n\r\n### Modifications\r\n\r\n- Remove `VERSION` and `stable.txt` files.","shortMessageHtmlLink":"Remove <code>VERSION</code> and <code>stable.txt</code> files (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2093211324\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/pulsar-client-go/issues/1158\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/apache/pulsar-client-go/pull/1158/hovercard\" href=\"https://github.com/apache/pulsar-client-go/pull/1158\">#1158</a>)"}}],"hasNextPage":true,"hasPreviousPage":false,"activityType":"all","actor":null,"timePeriod":"all","sort":"DESC","perPage":30,"cursor":"djE6ks8AAAAEVbr2EwA","startCursor":null,"endCursor":null}},"title":"Activity · apache/pulsar-client-go"}