{"payload":{"feedbackUrl":"https://github.com/orgs/community/discussions/53140","repo":{"id":608561463,"defaultBranch":"master","name":"pulsar-client-go","ownerLogin":"tisonkun","currentUserCanPush":false,"isFork":true,"isEmpty":false,"createdAt":"2023-03-02T09:20:25.000Z","ownerAvatar":"https://avatars.githubusercontent.com/u/18818196?v=4","public":true,"private":false,"isOrgOwned":false},"refInfo":{"name":"","listCacheKey":"v0:1698234278.0","currentOid":""},"activityList":{"items":[{"before":"4e138228fe501ec39856afbc5e541e87a143b73f","after":"f476814a9e1bac484e9589d4fb3f299066f54ddc","ref":"refs/heads/master","pushedAt":"2024-02-18T05:52:04.000Z","pushType":"push","commitsCount":6,"pusher":{"login":"tisonkun","name":"tison","path":"/tisonkun","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/18818196?s=80&v=4"},"commit":{"message":"Added CodeQL static code scanner (#1169)\n\n* Added CodeQL static code scanner\r\n\r\n* Update codeql.yml","shortMessageHtmlLink":"Added CodeQL static code scanner (apache#1169)"}},{"before":"93476909e36b7344c1b623fbe1b0d5b93792eb2f","after":"4e138228fe501ec39856afbc5e541e87a143b73f","ref":"refs/heads/master","pushedAt":"2024-01-25T04:38:19.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"tisonkun","name":"tison","path":"/tisonkun","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/18818196?s=80&v=4"},"commit":{"message":"[fix] Fix DLQ producer name conflicts when multiples consumers send messages to DLQ (#1156)\n\n### Motivation\r\n\r\nTo keep consistent with the Java client.\r\nReleted PR: https://github.com/apache/pulsar/pull/21890\r\n\r\n### Modifications\r\n\r\nSet DLQ producerName `fmt.Sprintf(\"%s-%s-%s-DLQ\", r.topicName, r.subscriptionName, r.consumerName)`","shortMessageHtmlLink":"[fix] Fix DLQ producer name conflicts when multiples consumers send m…"}},{"before":"f491e09e025ad72806f2f49b4a195b3c5b27d55a","after":"93476909e36b7344c1b623fbe1b0d5b93792eb2f","ref":"refs/heads/master","pushedAt":"2024-01-15T01:50:40.000Z","pushType":"push","commitsCount":6,"pusher":{"login":"tisonkun","name":"tison","path":"/tisonkun","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/18818196?s=80&v=4"},"commit":{"message":"chore(deps): bump golang.org/x/net from 0.0.0-20220225172249-27dd8689420f to 0.17.0 (#1155)\n\nGolang 1.16 is nolonger compatible with pulsar-client-go because\r\n`unsafe.Slice` is not defined. Update the CI workflows to test the\r\nlatest 4 Golang major releases.\r\n\r\nActually Golang only maintains the latest two major releases, see\r\nhttps://go.dev/doc/devel/release#policy","shortMessageHtmlLink":"chore(deps): bump golang.org/x/net from 0.0.0-20220225172249-27dd8689…"}},{"before":"062fefe12be229617b1f7e499969355c02470793","after":"f491e09e025ad72806f2f49b4a195b3c5b27d55a","ref":"refs/heads/master","pushedAt":"2024-01-01T12:33:52.000Z","pushType":"push","commitsCount":2,"pusher":{"login":"tisonkun","name":"tison","path":"/tisonkun","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/18818196?s=80&v=4"},"commit":{"message":"[Improve][Producer] normalize and export the errors (#1143)\n\n* [Improve][Producer] normalize and export the errors\r\n\r\n* update schema error\r\n\r\n* update go version to 1.20 to support errors.Join()\r\n\r\n* use errors.Is() to test an error\r\n\r\n* use github.com/hashicorp/go-multierror to join errors instead of errors.Join() of Go 1.20\r\n\r\n* revert go version to 1.18\r\n\r\n* revert go version to 1.18\r\n\r\n* update ErrSchema according to the CR sugguestions\r\n\r\n* update ErrTransaction to a normal error\r\n\r\n* rename ErrProducerBlocked to ErrProducerBlockedQuotaExceeded\r\n\r\n* add license header\r\n\r\n* fix unit test error\r\n\r\n---------\r\n\r\nCo-authored-by: gunli ","shortMessageHtmlLink":"[Improve][Producer] normalize and export the errors (apache#1143)"}},{"before":"bd11581867c88f93e4b6f247d82914f9eb4ee476","after":"062fefe12be229617b1f7e499969355c02470793","ref":"refs/heads/master","pushedAt":"2023-12-26T16:42:34.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"tisonkun","name":"tison","path":"/tisonkun","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/18818196?s=80&v=4"},"commit":{"message":"Avoid a panic when using transaction (#1144)\n\n### Motivation\r\n\r\nWhen aborting or committing a transaction, it can happen that an error returned from the client triggers a panic when attempting to cast it to a Pulsar error.\r\n\r\n### Modifications\r\n\r\nA proper check is performed when casting the error.","shortMessageHtmlLink":"Avoid a panic when using transaction (apache#1144)"}},{"before":"067dca1f47e6aab9e65a24f8796aa09ca48c2f4a","after":"bd11581867c88f93e4b6f247d82914f9eb4ee476","ref":"refs/heads/master","pushedAt":"2023-12-12T00:30:32.000Z","pushType":"push","commitsCount":2,"pusher":{"login":"tisonkun","name":"tison","path":"/tisonkun","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/18818196?s=80&v=4"},"commit":{"message":"[Fix][Producer] handle TopicNotFound/TopicTerminated/ProducerBlockedQuotaExceededException/ProducerFenced when reconnecting (#1134)\n\nMaster Issue: #1128\r\n\r\n### Motivation\r\n\r\nIn Java client, when we get TopicNotFound/TopicTerminated/ProducerBlockedQuotaExceededException/ProducerFenced, we should failPendingMessages, and close producer. But in Go client, we forget to handle ProducerBlockedQuotaExceededException/ProducerFenced, and in #1128, we just call sr.done(), actually we should call failPendingMessages().\r\n\r\nhttps://github.com/apache/pulsar-client-go/pull/1128/files\r\nhttps://github.com/apache/pulsar/blob/master/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerImpl.java#L1663\r\n\r\n### Modifications\r\n1. rename `errMsgTopicNotFount` to `errMsgTopicNotFound`\r\n2. handle TopicTerminated/ProducerBlockedQuotaExceededException/ProducerFenced, call `failPendingMessages()`;\r\n\r\n---------\r\n\r\nCo-authored-by: gunli ","shortMessageHtmlLink":"[Fix][Producer] handle TopicNotFound/TopicTerminated/ProducerBlockedQ…"}},{"before":"42ded0d59c46fd3fdaad45f045f7e8bf091131a5","after":"067dca1f47e6aab9e65a24f8796aa09ca48c2f4a","ref":"refs/heads/master","pushedAt":"2023-12-07T12:23:54.000Z","pushType":"push","commitsCount":279,"pusher":{"login":"tisonkun","name":"tison","path":"/tisonkun","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/18818196?s=80&v=4"},"commit":{"message":"[Improve] Set dlq producerName (#1137)\n\n\r\n### Motivation\r\n\r\nTo keep consistent with the Java client.\r\n\r\nReleted PR: https://github.com/apache/pulsar/pull/21589\r\n\r\n*Explain here the context, and why you're making that change. What is the problem you're trying to solve.*\r\n\r\n### Modifications\r\n\r\nSet DLQ producerName `%s-%s-DLQ`","shortMessageHtmlLink":"[Improve] Set dlq producerName (apache#1137)"}},{"before":"0becdc346985b5fcd252ed54193532fa27a6ef4e","after":null,"ref":"refs/heads/resourcefix","pushedAt":"2023-10-25T11:44:38.000Z","pushType":"branch_deletion","commitsCount":0,"pusher":{"login":"tisonkun","name":"tison","path":"/tisonkun","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/18818196?s=80&v=4"}},{"before":"60ce0e00548e6aa66ed8ffb643fe03197e3d2757","after":"0becdc346985b5fcd252ed54193532fa27a6ef4e","ref":"refs/heads/resourcefix","pushedAt":"2023-10-25T08:16:07.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"tisonkun","name":"tison","path":"/tisonkun","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/18818196?s=80&v=4"},"commit":{"message":"block reserving resource in front\n\nSigned-off-by: tison ","shortMessageHtmlLink":"block reserving resource in front"}},{"before":"bdcaf528d8de18a1293f33749c38cbd9666605c9","after":"60ce0e00548e6aa66ed8ffb643fe03197e3d2757","ref":"refs/heads/resourcefix","pushedAt":"2023-10-25T07:44:29.000Z","pushType":"push","commitsCount":3,"pusher":{"login":"tisonkun","name":"tison","path":"/tisonkun","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/18818196?s=80&v=4"},"commit":{"message":"Merge branch 'master' into resourcefix","shortMessageHtmlLink":"Merge branch 'master' into resourcefix"}},{"before":"15135bfb6fb1c04ec9b650b6888898491ccfab99","after":null,"ref":"refs/heads/srdone","pushedAt":"2023-10-25T07:39:26.000Z","pushType":"branch_deletion","commitsCount":0,"pusher":{"login":"tisonkun","name":"tison","path":"/tisonkun","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/18818196?s=80&v=4"}},{"before":"0f3f849b3842774ec1fbb451db05e463d212f235","after":"bdcaf528d8de18a1293f33749c38cbd9666605c9","ref":"refs/heads/resourcefix","pushedAt":"2023-10-24T22:12:11.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"tisonkun","name":"tison","path":"/tisonkun","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/18818196?s=80&v=4"},"commit":{"message":"finish acquire message permis one by one\n\nSigned-off-by: tison ","shortMessageHtmlLink":"finish acquire message permis one by one"}},{"before":"65ecbb39c981790b3ea483e820aa24e9b675b1be","after":"0f3f849b3842774ec1fbb451db05e463d212f235","ref":"refs/heads/resourcefix","pushedAt":"2023-10-24T21:37:15.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"tisonkun","name":"tison","path":"/tisonkun","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/18818196?s=80&v=4"},"commit":{"message":"release exact memory\n\nSigned-off-by: tison ","shortMessageHtmlLink":"release exact memory"}},{"before":"cc63851a0e3e2e85c23b5e6b346e4f8453b598b5","after":"65ecbb39c981790b3ea483e820aa24e9b675b1be","ref":"refs/heads/resourcefix","pushedAt":"2023-10-24T21:16:01.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"tisonkun","name":"tison","path":"/tisonkun","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/18818196?s=80&v=4"},"commit":{"message":"fix reserveSemaphore need not to be at once\n\nSigned-off-by: tison ","shortMessageHtmlLink":"fix reserveSemaphore need not to be at once"}},{"before":"322335f9b502182d98340e1f05f0c865e8b954c7","after":"cc63851a0e3e2e85c23b5e6b346e4f8453b598b5","ref":"refs/heads/resourcefix","pushedAt":"2023-10-24T21:08:07.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"tisonkun","name":"tison","path":"/tisonkun","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/18818196?s=80&v=4"},"commit":{"message":"skip TestChunkBlockIfQueueFull\n\nSigned-off-by: tison ","shortMessageHtmlLink":"skip TestChunkBlockIfQueueFull"}},{"before":"2e74e62f2e34f2ea00ad276db329f1fb1b775f19","after":"322335f9b502182d98340e1f05f0c865e8b954c7","ref":"refs/heads/resourcefix","pushedAt":"2023-10-24T20:27:14.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"tisonkun","name":"tison","path":"/tisonkun","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/18818196?s=80&v=4"},"commit":{"message":"fix unprepared chunked message\n\nSigned-off-by: tison ","shortMessageHtmlLink":"fix unprepared chunked message"}},{"before":"166ec81060a2989b92a57ca3e03e9bb7e62e2624","after":"2e74e62f2e34f2ea00ad276db329f1fb1b775f19","ref":"refs/heads/resourcefix","pushedAt":"2023-10-24T19:51:07.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"tisonkun","name":"tison","path":"/tisonkun","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/18818196?s=80&v=4"},"commit":{"message":"fixup nil\n\nSigned-off-by: tison ","shortMessageHtmlLink":"fixup nil"}},{"before":"03f6bd09ba22b9c0b1457925498832eefefe151e","after":"166ec81060a2989b92a57ca3e03e9bb7e62e2624","ref":"refs/heads/resourcefix","pushedAt":"2023-10-24T19:32:43.000Z","pushType":"force_push","commitsCount":0,"pusher":{"login":"tisonkun","name":"tison","path":"/tisonkun","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/18818196?s=80&v=4"},"commit":{"message":"use sr.done everywhere\n\nSigned-off-by: tison ","shortMessageHtmlLink":"use sr.done everywhere"}},{"before":null,"after":"03f6bd09ba22b9c0b1457925498832eefefe151e","ref":"refs/heads/resourcefix","pushedAt":"2023-10-24T19:27:19.000Z","pushType":"branch_creation","commitsCount":0,"pusher":{"login":"tisonkun","name":"tison","path":"/tisonkun","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/18818196?s=80&v=4"},"commit":{"message":"use sr.done everywhere\n\nSigned-off-by: tison ","shortMessageHtmlLink":"use sr.done everywhere"}},{"before":"ce05e5288308ae64137cb7d32c62aa8370a5a553","after":"15135bfb6fb1c04ec9b650b6888898491ccfab99","ref":"refs/heads/srdone","pushedAt":"2023-10-24T18:14:51.000Z","pushType":"force_push","commitsCount":0,"pusher":{"login":"tisonkun","name":"tison","path":"/tisonkun","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/18818196?s=80&v=4"},"commit":{"message":"locate bug\n\nSigned-off-by: tison ","shortMessageHtmlLink":"locate bug"}},{"before":"5a8f3839a423670bca75e1eac83d5e38edf3a5d5","after":"ce05e5288308ae64137cb7d32c62aa8370a5a553","ref":"refs/heads/srdone","pushedAt":"2023-10-24T18:08:08.000Z","pushType":"force_push","commitsCount":0,"pusher":{"login":"tisonkun","name":"tison","path":"/tisonkun","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/18818196?s=80&v=4"},"commit":{"message":"locate bug\n\nSigned-off-by: tison ","shortMessageHtmlLink":"locate bug"}},{"before":"58106540c7b743ca6a319a1dcf83facc8559d0f9","after":"5a8f3839a423670bca75e1eac83d5e38edf3a5d5","ref":"refs/heads/srdone","pushedAt":"2023-10-24T17:55:15.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"tisonkun","name":"tison","path":"/tisonkun","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/18818196?s=80&v=4"},"commit":{"message":"locate bug\n\nSigned-off-by: tison ","shortMessageHtmlLink":"locate bug"}},{"before":"dea241ab9f959e6d588a0a91972ec6c922560054","after":"58106540c7b743ca6a319a1dcf83facc8559d0f9","ref":"refs/heads/srdone","pushedAt":"2023-10-24T16:17:11.000Z","pushType":"force_push","commitsCount":0,"pusher":{"login":"tisonkun","name":"tison","path":"/tisonkun","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/18818196?s=80&v=4"},"commit":{"message":"drop stopBlock\n\nSigned-off-by: tison ","shortMessageHtmlLink":"drop stopBlock"}},{"before":"1f62b38f16556917d267c0072413a6bd158a61c5","after":"dea241ab9f959e6d588a0a91972ec6c922560054","ref":"refs/heads/srdone","pushedAt":"2023-10-24T15:26:05.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"tisonkun","name":"tison","path":"/tisonkun","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/18818196?s=80&v=4"},"commit":{"message":"fixup\n\nSigned-off-by: tison ","shortMessageHtmlLink":"fixup"}},{"before":null,"after":"1f62b38f16556917d267c0072413a6bd158a61c5","ref":"refs/heads/srdone","pushedAt":"2023-10-24T15:21:53.000Z","pushType":"branch_creation","commitsCount":0,"pusher":{"login":"tisonkun","name":"tison","path":"/tisonkun","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/18818196?s=80&v=4"},"commit":{"message":"use sr.done to clear resources\n\nSigned-off-by: tison ","shortMessageHtmlLink":"use sr.done to clear resources"}},{"before":"77a23f0129d43f00009933dda54ba5319b3a5417","after":null,"ref":"refs/heads/pretxn","pushedAt":"2023-10-24T15:03:33.000Z","pushType":"branch_deletion","commitsCount":0,"pusher":{"login":"tisonkun","name":"tison","path":"/tisonkun","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/18818196?s=80&v=4"}},{"before":"d5a52f04d3c53e0ea7409c8353ae5f1ec3fc3ce2","after":"77a23f0129d43f00009933dda54ba5319b3a5417","ref":"refs/heads/pretxn","pushedAt":"2023-10-24T14:46:01.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"tisonkun","name":"tison","path":"/tisonkun","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/18818196?s=80&v=4"},"commit":{"message":"fix callback recur\n\nSigned-off-by: tison ","shortMessageHtmlLink":"fix callback recur"}},{"before":"c53c7e4fd501f3859794c2676a7a5eb948063650","after":"d5a52f04d3c53e0ea7409c8353ae5f1ec3fc3ce2","ref":"refs/heads/pretxn","pushedAt":"2023-10-24T14:42:30.000Z","pushType":"force_push","commitsCount":0,"pusher":{"login":"tisonkun","name":"tison","path":"/tisonkun","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/18818196?s=80&v=4"},"commit":{"message":"refactor: factor out prepareTransaction\n\nSigned-off-by: tison ","shortMessageHtmlLink":"refactor: factor out prepareTransaction"}},{"before":"a4944a9c2fffd41625b30436b921d09c45be6c09","after":"c53c7e4fd501f3859794c2676a7a5eb948063650","ref":"refs/heads/pretxn","pushedAt":"2023-10-24T14:09:46.000Z","pushType":"force_push","commitsCount":0,"pusher":{"login":"tisonkun","name":"tison","path":"/tisonkun","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/18818196?s=80&v=4"},"commit":{"message":"refactor: factor out prepareTransaction\n\nSigned-off-by: tison ","shortMessageHtmlLink":"refactor: factor out prepareTransaction"}},{"before":"7d25fc7edece3dc4d4dce72b5f7b8fa7ef49dd90","after":"a4944a9c2fffd41625b30436b921d09c45be6c09","ref":"refs/heads/pretxn","pushedAt":"2023-10-24T13:45:52.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"tisonkun","name":"tison","path":"/tisonkun","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/18818196?s=80&v=4"},"commit":{"message":"fix nil\n\nSigned-off-by: tison ","shortMessageHtmlLink":"fix nil"}}],"hasNextPage":true,"hasPreviousPage":false,"activityType":"all","actor":null,"timePeriod":"all","sort":"DESC","perPage":30,"startCursor":"Y3Vyc29yOnYyOpK7MjAyNC0wMi0xOFQwNTo1MjowNC4wMDAwMDBazwAAAAP9sQie","endCursor":"Y3Vyc29yOnYyOpK7MjAyMy0xMC0yNFQxMzo0NTo1Mi4wMDAwMDBazwAAAAOejQ1U"}},"title":"Activity · tisonkun/pulsar-client-go"}