{"payload":{"feedbackUrl":"https://github.com/orgs/community/discussions/53140","repo":{"id":60346933,"defaultBranch":"main","name":"reactor-kafka","ownerLogin":"reactor","currentUserCanPush":false,"isFork":false,"isEmpty":false,"createdAt":"2016-06-03T12:44:46.000Z","ownerAvatar":"https://avatars.githubusercontent.com/u/4201559?v=4","public":true,"private":false,"isOrgOwned":true},"refInfo":{"name":"","listCacheKey":"v0:1712675722.0","currentOid":""},"activityList":{"items":[{"before":"229f85367cebb1510e295e239b0ca91803f5ff63","after":"2ae3abbc7a876008585eef4972d4fd4af30e2263","ref":"refs/heads/main","pushedAt":"2024-04-09T15:20:55.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"chemicL","name":"Dariusz Jędrzejczyk","path":"/chemicL","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/2554306?s=80&v=4"},"commit":{"message":"[release] Back to snapshots, next is 1.4.0-SNAPSHOT","shortMessageHtmlLink":"[release] Back to snapshots, next is 1.4.0-SNAPSHOT"}},{"before":"8326cc0795fa93b6fe156afa4c19caad2edec2af","after":"229f85367cebb1510e295e239b0ca91803f5ff63","ref":"refs/heads/main","pushedAt":"2024-04-09T15:04:10.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"chemicL","name":"Dariusz Jędrzejczyk","path":"/chemicL","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/2554306?s=80&v=4"},"commit":{"message":"[release] Prepare and release 1.4.0-M1","shortMessageHtmlLink":"[release] Prepare and release 1.4.0-M1"}},{"before":"c9a98e740ce956b1f3b3dcf761aabf5c6542d523","after":null,"ref":"refs/heads/prepare-1-4","pushedAt":"2024-03-20T08:46:32.000Z","pushType":"branch_deletion","commitsCount":0,"pusher":{"login":"chemicL","name":"Dariusz Jędrzejczyk","path":"/chemicL","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/2554306?s=80&v=4"}},{"before":"51d727cc32cb8582f76b50e1fb42ba0ee8bd6733","after":"8326cc0795fa93b6fe156afa4c19caad2edec2af","ref":"refs/heads/main","pushedAt":"2024-03-20T08:46:29.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"chemicL","name":"Dariusz Jędrzejczyk","path":"/chemicL","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/2554306?s=80&v=4"},"commit":{"message":"Start producing 1.4 snapshots with 1.4.0-SNAPSHOT (#387)\n\n\r\nCo-authored-by: Violeta Georgieva ","shortMessageHtmlLink":"Start producing 1.4 snapshots with 1.4.0-SNAPSHOT (#387)"}},{"before":"5b8ce992ffbec60207e0ef3ee86571ec50ab90a8","after":"c9a98e740ce956b1f3b3dcf761aabf5c6542d523","ref":"refs/heads/prepare-1-4","pushedAt":"2024-03-20T08:17:03.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"chemicL","name":"Dariusz Jędrzejczyk","path":"/chemicL","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/2554306?s=80&v=4"},"commit":{"message":"Update README.md\n\nCo-authored-by: Violeta Georgieva ","shortMessageHtmlLink":"Update README.md"}},{"before":"311bfe97779f32b5d96c0984fa96951186316c4d","after":"5b8ce992ffbec60207e0ef3ee86571ec50ab90a8","ref":"refs/heads/prepare-1-4","pushedAt":"2024-03-20T08:14:24.000Z","pushType":"force_push","commitsCount":0,"pusher":{"login":"chemicL","name":"Dariusz Jędrzejczyk","path":"/chemicL","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/2554306?s=80&v=4"},"commit":{"message":"Start producing 1.4 snapshots with 1.4.0-SNAPSHOT","shortMessageHtmlLink":"Start producing 1.4 snapshots with 1.4.0-SNAPSHOT"}},{"before":"6ed005a317cc115a155761b421f1ccaf0898c8c0","after":null,"ref":"refs/heads/ignore-mock-receiver-consumer-methods-test","pushedAt":"2024-03-20T08:13:51.000Z","pushType":"branch_deletion","commitsCount":0,"pusher":{"login":"chemicL","name":"Dariusz Jędrzejczyk","path":"/chemicL","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/2554306?s=80&v=4"}},{"before":"36a4a388a0e991825bef0e0f002635343103ee98","after":"51d727cc32cb8582f76b50e1fb42ba0ee8bd6733","ref":"refs/heads/main","pushedAt":"2024-03-20T08:13:46.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"chemicL","name":"Dariusz Jędrzejczyk","path":"/chemicL","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/2554306?s=80&v=4"},"commit":{"message":"Ignore temporarily MockReceiverTest#consumerMethods (#388)\n\nThis test fails consistently with reactor-core 3.7.0-SNAPSHOT","shortMessageHtmlLink":"Ignore temporarily MockReceiverTest#consumerMethods (#388)"}},{"before":"a0240ec1ac956dd2f0f99a79a9a945f1e1fa4184","after":"6ed005a317cc115a155761b421f1ccaf0898c8c0","ref":"refs/heads/ignore-mock-receiver-consumer-methods-test","pushedAt":"2024-03-20T07:54:20.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"chemicL","name":"Dariusz Jędrzejczyk","path":"/chemicL","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/2554306?s=80&v=4"},"commit":{"message":"Spotless","shortMessageHtmlLink":"Spotless"}},{"before":null,"after":"a0240ec1ac956dd2f0f99a79a9a945f1e1fa4184","ref":"refs/heads/ignore-mock-receiver-consumer-methods-test","pushedAt":"2024-03-20T07:51:33.000Z","pushType":"branch_creation","commitsCount":0,"pusher":{"login":"chemicL","name":"Dariusz Jędrzejczyk","path":"/chemicL","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/2554306?s=80&v=4"},"commit":{"message":"Ignore temporarily MockReceiverTest#consumerMethods","shortMessageHtmlLink":"Ignore temporarily MockReceiverTest#consumerMethods"}},{"before":"9d360e60f381508802d50cd0568c5cc7144224c5","after":"36a4a388a0e991825bef0e0f002635343103ee98","ref":"refs/heads/main","pushedAt":"2024-03-20T07:50:04.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"chemicL","name":"Dariusz Jędrzejczyk","path":"/chemicL","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/2554306?s=80&v=4"},"commit":{"message":"Include 1.3.x in publish workflow","shortMessageHtmlLink":"Include 1.3.x in publish workflow"}},{"before":null,"after":"311bfe97779f32b5d96c0984fa96951186316c4d","ref":"refs/heads/prepare-1-4","pushedAt":"2024-03-19T16:01:19.000Z","pushType":"branch_creation","commitsCount":0,"pusher":{"login":"chemicL","name":"Dariusz Jędrzejczyk","path":"/chemicL","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/2554306?s=80&v=4"},"commit":{"message":"Start producing 1.4 snapshots with 1.4.0-SNAPSHOT","shortMessageHtmlLink":"Start producing 1.4 snapshots with 1.4.0-SNAPSHOT"}},{"before":"9d360e60f381508802d50cd0568c5cc7144224c5","after":"36a4a388a0e991825bef0e0f002635343103ee98","ref":"refs/heads/1.3.x","pushedAt":"2024-03-19T15:33:36.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"chemicL","name":"Dariusz Jędrzejczyk","path":"/chemicL","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/2554306?s=80&v=4"},"commit":{"message":"Include 1.3.x in publish workflow","shortMessageHtmlLink":"Include 1.3.x in publish workflow"}},{"before":null,"after":"9d360e60f381508802d50cd0568c5cc7144224c5","ref":"refs/heads/1.3.x","pushedAt":"2024-03-19T15:30:23.000Z","pushType":"branch_creation","commitsCount":0,"pusher":{"login":"chemicL","name":"Dariusz Jędrzejczyk","path":"/chemicL","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/2554306?s=80&v=4"},"commit":{"message":"[release] Back to snapshots, next is 1.0.24-SNAPSHOT","shortMessageHtmlLink":"[release] Back to snapshots, next is 1.0.24-SNAPSHOT"}},{"before":"a7ba59b7f348087bd10a550f6c9afe26a5f11a7f","after":"9d360e60f381508802d50cd0568c5cc7144224c5","ref":"refs/heads/main","pushedAt":"2024-02-14T22:48:18.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"pderop","name":"Pierre De Rop","path":"/pderop","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/650758?s=80&v=4"},"commit":{"message":"[release] Back to snapshots, next is 1.0.24-SNAPSHOT","shortMessageHtmlLink":"[release] Back to snapshots, next is 1.0.24-SNAPSHOT"}},{"before":"9b09225a34508c4e9f5f01d32ad31dd620bc53f5","after":"a7ba59b7f348087bd10a550f6c9afe26a5f11a7f","ref":"refs/heads/main","pushedAt":"2024-02-13T08:00:32.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"pderop","name":"Pierre De Rop","path":"/pderop","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/650758?s=80&v=4"},"commit":{"message":"[release] Prepare and release 1.3.23","shortMessageHtmlLink":"[release] Prepare and release 1.3.23"}},{"before":"57b7085f81def57838ee992d4157a6493cee7dac","after":"9b09225a34508c4e9f5f01d32ad31dd620bc53f5","ref":"refs/heads/main","pushedAt":"2024-01-10T13:47:09.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"artembilan","name":"Artem Bilan","path":"/artembilan","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/1071590?s=80&v=4"},"commit":{"message":"GH-374: Support bootstrap server property as a list\n\nResolves #374\r\n\r\n* support read bootstrap server config when it is defined as list\r\n\r\n* update copyright year of the affected classes to 2024","shortMessageHtmlLink":"GH-374: Support bootstrap server property as a list"}},{"before":"c35681acdc05a21b1f76c57589957c44720f80c8","after":"57b7085f81def57838ee992d4157a6493cee7dac","ref":"refs/heads/main","pushedAt":"2023-11-14T14:18:01.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"pderop","name":"Pierre De Rop","path":"/pderop","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/650758?s=80&v=4"},"commit":{"message":"[release] Back to snapshots, next is 1.3.23-SNAPSHOT","shortMessageHtmlLink":"[release] Back to snapshots, next is 1.3.23-SNAPSHOT"}},{"before":"5436ae9063349432ceeff4caa18b14d953989526","after":"c35681acdc05a21b1f76c57589957c44720f80c8","ref":"refs/heads/main","pushedAt":"2023-11-14T13:45:09.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"pderop","name":"Pierre De Rop","path":"/pderop","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/650758?s=80&v=4"},"commit":{"message":"[release] Prepare and release 1.3.22","shortMessageHtmlLink":"[release] Prepare and release 1.3.22"}},{"before":"bf33c9f28055c4d85394ef557265083ecfadfa9e","after":"5436ae9063349432ceeff4caa18b14d953989526","ref":"refs/heads/main","pushedAt":"2023-10-26T19:58:32.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"garyrussell","name":"Gary Russell","path":"/garyrussell","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/483832?s=80&v=4"},"commit":{"message":"GH-321: Add Observation propagation (#325)\n\n* GH-321: Add Observation propagation\r\n\r\nFixes https://github.com/reactor/reactor-kafka/issues/321\r\n\r\n* Start version `1.4` since this requires some API changes and upgrades\r\n* Upgrade to Reactor `3.5.3` for new context propagation API\r\n* Copy-paste (and adjust) `KafkaReceiverObservation` & `KafkaSenderObservation`\r\ninfrastructure from Spring for Apache Kafka\r\n* Add an `Observation` handling into a `KafkaSender` with `contextCapture()`\r\nand `KafkaSenderObservation` around `producer.send()`\r\n* There is no yet automatic `Observation` handling on the consumer side since it is not\r\nclear how to handle each record transparently for end-user `Flux` downstream\r\n* The `ReactorKafkaObservationTests` demonstrates a single trace propagation from a sender via\r\nparent `Observation` and its restoration on a consumer side via `KafkaReceiverObservation`\r\nin the end-user code\r\n\r\n* * Fix Copyright date in the `build.gradle`\r\n\r\n* * Remove redundant code from the `ReactorKafkaObservationTests`\r\n\r\n* * Revert Reactor version\r\n* Revert new version `1.4`\r\n* Don't use `contextCapture()` in the `DefaultKafkaSender`:\r\nbetter to ask end-users to use a `contextWrite()` for the parent observation to propagate\r\n* `ReceiverObservations` factories to observe `ConsumerRecord` on the end-user side\r\nvia `transformDeferred()` on each record\r\n\r\n* * Revert changes in the `DefaultKafkaSender`\r\n\r\n* * Upgrade dependencies\r\n* Fix deprecation in the `ConsumerHandler` for `eventScheduler.start()`\r\n* Use generated `producerId` and `receiverId` if `CLIENT_ID_CONFIG` is not provided\r\n* Use an `Observation` in the `DefaultKafkaReceiver` to add a `CONSUMER` span to\r\nthe trace provided by the `PRODUCER` in the record.\r\n* Recommend to use a `KafkaReceiverObservation.RECEIVER_OBSERVATION` API directly\r\nin the target end-user code when need to have an observation context around record handling\r\n\r\n* * Revert `spotless` change in the `build.gradle`\r\n\r\n* * Some code clean up\r\n* Exclude `org.mockito` from Micrometer deps since we cannot use\r\na newer version of Mockito yet\r\n\r\n* * Add trace log for received consumer record\r\n\r\n* * Fix conflicts after rebase\r\n* Add docs about observation support\r\n\r\n* * Fix language in docs\r\n\r\nCo-authored-by: Gary Russell \r\n\r\n---------\r\n\r\nCo-authored-by: Gary Russell ","shortMessageHtmlLink":"GH-321: Add Observation propagation (#325)"}},{"before":"3e20f3dcab1a7c4a5160214a1c977008e9e2cc05","after":"05d82981e474a5ceb15df27100f80720941ac1cc","ref":"refs/heads/GH-321","pushedAt":"2023-10-26T19:33:52.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"artembilan","name":"Artem Bilan","path":"/artembilan","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/1071590?s=80&v=4"},"commit":{"message":"* Fix language in docs\n\nCo-authored-by: Gary Russell ","shortMessageHtmlLink":"* Fix language in docs"}},{"before":"f535b9cef8de9a7ddf0c56b018eefa7a3b52df96","after":"bf33c9f28055c4d85394ef557265083ecfadfa9e","ref":"refs/heads/main","pushedAt":"2023-10-26T14:36:37.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"artembilan","name":"Artem Bilan","path":"/artembilan","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/1071590?s=80&v=4"},"commit":{"message":"Fix broken example code 'retry(When' -> 'retryWhen'","shortMessageHtmlLink":"Fix broken example code 'retry(When' -> 'retryWhen'"}},{"before":"a30fb4bc4657a1408ccd23f0181b26408f278ded","after":"3e20f3dcab1a7c4a5160214a1c977008e9e2cc05","ref":"refs/heads/GH-321","pushedAt":"2023-10-25T18:53:20.000Z","pushType":"force_push","commitsCount":0,"pusher":{"login":"artembilan","name":"Artem Bilan","path":"/artembilan","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/1071590?s=80&v=4"},"commit":{"message":"* Fix conflicts after rebase\n* Add docs about observation support","shortMessageHtmlLink":"* Fix conflicts after rebase"}},{"before":"1a44d5c80b306696e3d442ebac74addf4d3a2cd5","after":"f535b9cef8de9a7ddf0c56b018eefa7a3b52df96","ref":"refs/heads/main","pushedAt":"2023-10-19T19:11:42.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"garyrussell","name":"Gary Russell","path":"/garyrussell","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/483832?s=80&v=4"},"commit":{"message":"RePause All Partitions After Rebalance if user paused any and requested (#363)\n\n* RePause All Partitions After Rebalance if user paused any and requested\r\n\r\n* RePause All Partitions After Rebalance if user paused any and requested\r\n\r\n* RePause All Partitions:fix pausedByUser and unit test\r\n\r\n* RePause All Partitions:code review feedback\r\n\r\n---------\r\n\r\nCo-authored-by: jyang1 ","shortMessageHtmlLink":"RePause All Partitions After Rebalance if user paused any and request…"}},{"before":"ab9f851b2d6bcd7992bc67a35d4d90d52f4be5e3","after":"1a44d5c80b306696e3d442ebac74addf4d3a2cd5","ref":"refs/heads/main","pushedAt":"2023-10-18T18:27:02.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"artembilan","name":"Artem Bilan","path":"/artembilan","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/1071590?s=80&v=4"},"commit":{"message":"GH-333: Support currentLag() in doOnConsumer\n\nResolves https://github.com/reactor/reactor-kafka/issues/333","shortMessageHtmlLink":"GH-333: Support currentLag() in doOnConsumer"}},{"before":"1c25a8e481a599a4f4f34414523424a9fbe043ef","after":"ab9f851b2d6bcd7992bc67a35d4d90d52f4be5e3","ref":"refs/heads/main","pushedAt":"2023-10-18T16:19:35.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"garyrussell","name":"Gary Russell","path":"/garyrussell","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/483832?s=80&v=4"},"commit":{"message":"Bump Kafka Clients Version to 3.6.0 (#361)\n\n* Bump Kafka Clients Version to 3.6.0\r\n\r\n* Bump Version to 2.0.00 to not require Backward Compatibility\r\n\r\n* Deleted deprecated test\r\n\r\n* Fix Version Schema\r\n\r\nCo-authored-by: Gary Russell \r\n\r\n* Revert to 1.3.x version line\r\n\r\n---------\r\n\r\nCo-authored-by: Justus Schneider \r\nCo-authored-by: Gary Russell ","shortMessageHtmlLink":"Bump Kafka Clients Version to 3.6.0 (#361)"}},{"before":"157ad0e117204a251a42bb0b62332cf73894817c","after":"1c25a8e481a599a4f4f34414523424a9fbe043ef","ref":"refs/heads/main","pushedAt":"2023-10-16T14:51:04.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"artembilan","name":"Artem Bilan","path":"/artembilan","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/1071590?s=80&v=4"},"commit":{"message":"GH-360: Fix `Sample Scenarios` title in the docs\n\nFixes https://github.com/reactor/reactor-kafka/issues/360","shortMessageHtmlLink":"GH-360: Fix Sample Scenarios title in the docs"}},{"before":"0ad5355c48458650d0587e48cfe8a1bc5b8b0544","after":"a30fb4bc4657a1408ccd23f0181b26408f278ded","ref":"refs/heads/GH-321","pushedAt":"2023-09-12T14:49:25.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"artembilan","name":"Artem Bilan","path":"/artembilan","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/1071590?s=80&v=4"},"commit":{"message":"* Add trace log for received consumer record","shortMessageHtmlLink":"* Add trace log for received consumer record"}},{"before":"c83ccd5bc858eb4cacae561dab6ab8ce4d34a71a","after":"157ad0e117204a251a42bb0b62332cf73894817c","ref":"refs/heads/main","pushedAt":"2023-09-12T09:10:38.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"chemicL","name":"Dariusz Jędrzejczyk","path":"/chemicL","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/2554306?s=80&v=4"},"commit":{"message":"[release] Back to snapshots, next is 1.3.22-SNAPSHOT","shortMessageHtmlLink":"[release] Back to snapshots, next is 1.3.22-SNAPSHOT"}},{"before":"9597c9388f33b03817c439159a81807ab6300123","after":"c83ccd5bc858eb4cacae561dab6ab8ce4d34a71a","ref":"refs/heads/main","pushedAt":"2023-09-12T08:35:45.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"chemicL","name":"Dariusz Jędrzejczyk","path":"/chemicL","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/2554306?s=80&v=4"},"commit":{"message":"[release] Prepare and release 1.3.21","shortMessageHtmlLink":"[release] Prepare and release 1.3.21"}}],"hasNextPage":true,"hasPreviousPage":false,"activityType":"all","actor":null,"timePeriod":"all","sort":"DESC","perPage":30,"cursor":"djE6ks8AAAAELCY0MAA","startCursor":null,"endCursor":null}},"title":"Activity · reactor/reactor-kafka"}