{"payload":{"feedbackUrl":"https://github.com/orgs/community/discussions/53140","repo":{"id":399046935,"defaultBranch":"main","name":"rocketmq-flink","ownerLogin":"apache","currentUserCanPush":false,"isFork":false,"isEmpty":false,"createdAt":"2021-08-23T09:34:44.000Z","ownerAvatar":"https://avatars.githubusercontent.com/u/47359?v=4","public":true,"private":false,"isOrgOwned":true},"refInfo":{"name":"","listCacheKey":"v0:1690772247.0","currentOid":""},"activityList":{"items":[{"before":"0a1a03367ca422f3f4d5011b368e8e0ab0f91db8","after":"5e13440321e1844adba3a75e6415d3ec08d60e9a","ref":"refs/heads/main","pushedAt":"2024-05-17T03:02:21.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"lizhimins","name":null,"path":"/lizhimins","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/22487634?s=80&v=4"},"commit":{"message":"[ISSUE #118] fix: concurrency problem caused by batchFlushOnCheckpoint (#119)","shortMessageHtmlLink":"[ISSUE <a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2292794715\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/rocketmq-flink/issues/118\" data-hovercard-type=\"issue\" data-hovercard-url=\"/apache/rocketmq-flink/issues/118/hovercard\" href=\"https://github.com/apache/rocketmq-flink/issues/118\">#118</a>] fix: concurrency problem caused by batchFlushOnCheckpoint ("}},{"before":"b6865013b7a54883727a2b4cd712087d6e8a6d4d","after":"0a1a03367ca422f3f4d5011b368e8e0ab0f91db8","ref":"refs/heads/main","pushedAt":"2024-01-10T09:31:20.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"SteNicholas","name":"Nicholas Jiang","path":"/SteNicholas","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/10048174?s=80&v=4"},"commit":{"message":"[ISSUE #105] Fix sink retryTimes does not work (#106)","shortMessageHtmlLink":"[ISSUE <a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2038992472\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/rocketmq-flink/issues/105\" data-hovercard-type=\"issue\" data-hovercard-url=\"/apache/rocketmq-flink/issues/105/hovercard\" href=\"https://github.com/apache/rocketmq-flink/issues/105\">#105</a>] Fix sink retryTimes does not work (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2038993803\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/rocketmq-flink/issues/106\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/apache/rocketmq-flink/pull/106/hovercard\" href=\"https://github.com/apache/rocketmq-flink/pull/106\">#106</a>)"}},{"before":"1576ae2d4d51604a464df0fb21074f67c9e50c0f","after":"b6865013b7a54883727a2b4cd712087d6e8a6d4d","ref":"refs/heads/main","pushedAt":"2024-01-10T09:29:24.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"SteNicholas","name":"Nicholas Jiang","path":"/SteNicholas","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/10048174?s=80&v=4"},"commit":{"message":"[ISSUE #95] Fix source can not consume new queue's messages when topic queue expansion (#96)","shortMessageHtmlLink":"[ISSUE <a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"1840765619\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/rocketmq-flink/issues/95\" data-hovercard-type=\"issue\" data-hovercard-url=\"/apache/rocketmq-flink/issues/95/hovercard\" href=\"https://github.com/apache/rocketmq-flink/issues/95\">#95</a>] Fix source can not consume new queue's messages when topi…"}},{"before":"48e88d7b471bf430278f469f37327ea3428cbb5c","after":"1576ae2d4d51604a464df0fb21074f67c9e50c0f","ref":"refs/heads/main","pushedAt":"2023-12-04T06:34:52.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"lizhimins","name":null,"path":"/lizhimins","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/22487634?s=80&v=4"},"commit":{"message":"[ISSUE #103] Fix seek offset and deserialize bug in newSource (#104)","shortMessageHtmlLink":"[ISSUE <a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2010852340\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/rocketmq-flink/issues/103\" data-hovercard-type=\"issue\" data-hovercard-url=\"/apache/rocketmq-flink/issues/103/hovercard\" href=\"https://github.com/apache/rocketmq-flink/issues/103\">#103</a>] Fix seek offset and deserialize bug in newSource (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2010859338\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/rocketmq-flink/issues/104\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/apache/rocketmq-flink/pull/104/hovercard\" href=\"https://github.com/apache/rocketmq-flink/pull/104\">#104</a>)"}},{"before":"b9efd1ed897c83e836cc16a2427da033d9c165ad","after":"48e88d7b471bf430278f469f37327ea3428cbb5c","ref":"refs/heads/main","pushedAt":"2023-11-15T09:48:25.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"lizhimins","name":null,"path":"/lizhimins","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/22487634?s=80&v=4"},"commit":{"message":"[ISSUE #101] Fix bug, the optional param 'startup.offset.timestamp' is not set, a NPE will be thrown. (#102)","shortMessageHtmlLink":"[ISSUE <a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"1993978450\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/rocketmq-flink/issues/101\" data-hovercard-type=\"issue\" data-hovercard-url=\"/apache/rocketmq-flink/issues/101/hovercard\" href=\"https://github.com/apache/rocketmq-flink/issues/101\">#101</a>] Fix bug, the optional param 'startup.offset.timestamp' i…"}},{"before":"135301b5368fd524735b3f92b8c4b80c6181265c","after":null,"ref":"refs/heads/dependabot/maven/org.apache.rocketmq-rocketmq-namesrv-4.9.7","pushedAt":"2023-07-31T02:57:27.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":"45590d1bc44f49681fb2505aff7511e0b736d3e3","after":"b9efd1ed897c83e836cc16a2427da033d9c165ad","ref":"refs/heads/main","pushedAt":"2023-07-31T02:56:50.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"lizhimins","name":null,"path":"/lizhimins","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/22487634?s=80&v=4"},"commit":{"message":"Implement new flink-connector-rocketmq base on FLIP-27/FLIP-191 (#94)","shortMessageHtmlLink":"Implement new flink-connector-rocketmq base on FLIP-27/FLIP-191 (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"1804511659\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/rocketmq-flink/issues/94\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/apache/rocketmq-flink/pull/94/hovercard\" href=\"https://github.com/apache/rocketmq-flink/pull/94\">#94</a>)"}},{"before":"e82cbb504c060acd226b65e5fd8a97cd34132751","after":null,"ref":"refs/heads/dependabot/maven/org.apache.rocketmq-rocketmq-namesrv-4.9.6","pushedAt":"2023-07-12T17:31:16.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":null,"after":"135301b5368fd524735b3f92b8c4b80c6181265c","ref":"refs/heads/dependabot/maven/org.apache.rocketmq-rocketmq-namesrv-4.9.7","pushedAt":"2023-07-12T17:31:11.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":"Bump rocketmq-namesrv from 4.9.2 to 4.9.7\n\nBumps [rocketmq-namesrv](https://github.com/apache/rocketmq) from 4.9.2 to 4.9.7.\n- [Release notes](https://github.com/apache/rocketmq/releases)\n- [Commits](https://github.com/apache/rocketmq/compare/rocketmq-all-4.9.2...rocketmq-all-4.9.7)\n\n---\nupdated-dependencies:\n- dependency-name: org.apache.rocketmq:rocketmq-namesrv\n  dependency-type: direct:production\n...\n\nSigned-off-by: dependabot[bot] <support@github.com>","shortMessageHtmlLink":"Bump rocketmq-namesrv from 4.9.2 to 4.9.7"}},{"before":null,"after":"e82cbb504c060acd226b65e5fd8a97cd34132751","ref":"refs/heads/dependabot/maven/org.apache.rocketmq-rocketmq-namesrv-4.9.6","pushedAt":"2023-07-06T23:48:45.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":"Bump rocketmq-namesrv from 4.9.2 to 4.9.6\n\nBumps [rocketmq-namesrv](https://github.com/apache/rocketmq) from 4.9.2 to 4.9.6.\n- [Release notes](https://github.com/apache/rocketmq/releases)\n- [Commits](https://github.com/apache/rocketmq/compare/rocketmq-all-4.9.2...rocketmq-all-4.9.6)\n\n---\nupdated-dependencies:\n- dependency-name: org.apache.rocketmq:rocketmq-namesrv\n  dependency-type: direct:production\n...\n\nSigned-off-by: dependabot[bot] <support@github.com>","shortMessageHtmlLink":"Bump rocketmq-namesrv from 4.9.2 to 4.9.6"}},{"before":null,"after":"45590d1bc44f49681fb2505aff7511e0b736d3e3","ref":"refs/heads/main-latest","pushedAt":"2023-05-25T05:50:31.541Z","pushType":"branch_creation","commitsCount":0,"pusher":{"login":"lizhimins","name":null,"path":"/lizhimins","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/22487634?s=80&v=4"},"commit":{"message":"Merge pull request #86 from ni-ze/main\n\n[ISSUE #85]add the generic type into SimpleKeyValueDeserializationSchema","shortMessageHtmlLink":"Merge pull request <a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"1675867880\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/rocketmq-flink/issues/86\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/apache/rocketmq-flink/pull/86/hovercard\" href=\"https://github.com/apache/rocketmq-flink/pull/86\">#86</a> from ni-ze/main"}},{"before":"422909f352808b15f9eef1e699af0bd0fff17a88","after":"45590d1bc44f49681fb2505aff7511e0b736d3e3","ref":"refs/heads/main","pushedAt":"2023-04-25T01:41:34.000Z","pushType":"pr_merge","commitsCount":2,"pusher":{"login":"ni-ze","name":"Ni Ze","path":"/ni-ze","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/31175234?s=80&v=4"},"commit":{"message":"Merge pull request #86 from ni-ze/main\n\n[ISSUE #85]add the generic type into SimpleKeyValueDeserializationSchema","shortMessageHtmlLink":"Merge pull request <a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"1675867880\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/rocketmq-flink/issues/86\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/apache/rocketmq-flink/pull/86/hovercard\" href=\"https://github.com/apache/rocketmq-flink/pull/86\">#86</a> from ni-ze/main"}}],"hasNextPage":false,"hasPreviousPage":false,"activityType":"all","actor":null,"timePeriod":"all","sort":"DESC","perPage":30,"cursor":"djE6ks8AAAAETHtl4AA","startCursor":null,"endCursor":null}},"title":"Activity · apache/rocketmq-flink"}