{"payload":{"feedbackUrl":"https://github.com/orgs/community/discussions/53140","repo":{"id":38764029,"defaultBranch":"main","name":"spring-cloud-stream","ownerLogin":"spring-cloud","currentUserCanPush":false,"isFork":false,"isEmpty":false,"createdAt":"2015-07-08T15:51:38.000Z","ownerAvatar":"https://avatars.githubusercontent.com/u/7815877?v=4","public":true,"private":false,"isOrgOwned":true},"refInfo":{"name":"","listCacheKey":"v0:1711545233.0","currentOid":""},"activityList":{"items":[{"before":"d534e840dcd488de5bdd5b30bd539c165a728991","after":"c2754de2ab01c744103e1812f50a72ee5247159e","ref":"refs/heads/main","pushedAt":"2024-05-01T17:46:54.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"sobychacko","name":"Soby Chacko","path":"/sobychacko","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/827682?s=80&v=4"},"commit":{"message":"GH-2943: EmbeddedKafka usage improvements in Kafka binder\n\n* Currently, EmbeddedKafka is initialized as part of the class initialization in a few tests\n in the Kafka binder. This is preventing individual JUnit tests from being executed from an IDE (IntelliJ, for example).\n If we move this initialization to the JUnit method, then that seems to be working.\n\nResolves https://github.com/spring-cloud/spring-cloud-stream/issues/2943","shortMessageHtmlLink":"GH-2943: EmbeddedKafka usage improvements in Kafka binder"}},{"before":"1d241583c34af6d33217d8793a8adfc7eba17944","after":"d534e840dcd488de5bdd5b30bd539c165a728991","ref":"refs/heads/main","pushedAt":"2024-05-01T15:53:53.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"sobychacko","name":"Soby Chacko","path":"/sobychacko","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/827682?s=80&v=4"},"commit":{"message":"GH-2942: EmbeddedKafka usage improvements in Kafka Streams binder\n\n* Currently, EmbeddedKafka is initialized as part of the class initialization.\n This is preventing individual JUnit tests from being executed from an IDE (IntelliJ, for example).\n If we move this initialization to the JUnit `BeforeAll` method, then that seems to be working.\n\nResolves https://github.com/spring-cloud/spring-cloud-stream/issues/2942","shortMessageHtmlLink":"GH-2942: EmbeddedKafka usage improvements in Kafka Streams binder"}},{"before":"f230d873c746e271145ca7a7d99ad4854ae62bad","after":"1d241583c34af6d33217d8793a8adfc7eba17944","ref":"refs/heads/main","pushedAt":"2024-05-01T01:00:54.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"sobychacko","name":"Soby Chacko","path":"/sobychacko","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/827682?s=80&v=4"},"commit":{"message":"GH-2941: Kafka Streams Component beans composition\n\nResolves https://github.com/spring-cloud/spring-cloud-stream/issues/2941\n\n* Introduce function composition for Kafka Streams Component beans","shortMessageHtmlLink":"GH-2941: Kafka Streams Component beans composition"}},{"before":"9cbd45910ef1b3873070a7547b44c004efc338d8","after":"f230d873c746e271145ca7a7d99ad4854ae62bad","ref":"refs/heads/main","pushedAt":"2024-04-30T14:54:05.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"sobychacko","name":"Soby Chacko","path":"/sobychacko","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/827682?s=80&v=4"},"commit":{"message":"Adding Kafka docker-compose script for kraft","shortMessageHtmlLink":"Adding Kafka docker-compose script for kraft"}},{"before":"7845be50effe311891a72243556cd3d11cad7cc9","after":"9cbd45910ef1b3873070a7547b44c004efc338d8","ref":"refs/heads/main","pushedAt":"2024-04-29T22:34:10.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"sobychacko","name":"Soby Chacko","path":"/sobychacko","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/827682?s=80&v=4"},"commit":{"message":"GH-2926: Clarify docs on observablity when consuming in batches\n\nResolves https://github.com/spring-cloud/spring-cloud-stream/issues/2926\n\n* Clarify docs on Observability when consuming records in batch mode in Kafka binder","shortMessageHtmlLink":"GH-2926: Clarify docs on observablity when consuming in batches"}},{"before":"3d679c491c70bdb79e359746c6dc95099ffab55d","after":"7845be50effe311891a72243556cd3d11cad7cc9","ref":"refs/heads/main","pushedAt":"2024-04-17T21:33:17.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"sobychacko","name":"Soby Chacko","path":"/sobychacko","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/827682?s=80&v=4"},"commit":{"message":"GH-2932: Sanitize sensitive data on bindings endpoint\n\nResolves https://github.com/spring-cloud/spring-cloud-stream/issues/2932\n\nSpring Boot provides `SanitizingFunction` to allow the applicaitons to clear out\nsensitive data when using certain actuator endpoints. This feature can be\nextended to custom endpoints as well. Enable the bindings actuator endpoint\nto sanitze sensitive data based on user-provided logic in `SantizingFuction`\nbeans in the application.","shortMessageHtmlLink":"GH-2932: Sanitize sensitive data on bindings endpoint"}},{"before":"3298d0d3c75fbfe7c7cb30fcbf298a4e64bdc1af","after":"3d679c491c70bdb79e359746c6dc95099ffab55d","ref":"refs/heads/main","pushedAt":"2024-04-15T13:44:38.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"sobychacko","name":"Soby Chacko","path":"/sobychacko","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/827682?s=80&v=4"},"commit":{"message":"Fix custom test PulsarProducerFactory\n\nSpring Pulsar 1.1.x introduced a new method `getPulsarClient`\r\non `PulsarProducerFactory` and the PulsarBinderIntegrationTests\r\nhas a custom factory that must be updated in order to run\r\non both Pulsar 1.0.x and 1.1.x (i.e. Spring Boot 3.2.x and 3.3.x).","shortMessageHtmlLink":"Fix custom test PulsarProducerFactory"}},{"before":"5fb122e5a9e429533846fff86d903451201f5637","after":"3298d0d3c75fbfe7c7cb30fcbf298a4e64bdc1af","ref":"refs/heads/main","pushedAt":"2024-04-13T02:10:18.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"sobychacko","name":"Soby Chacko","path":"/sobychacko","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/827682?s=80&v=4"},"commit":{"message":"SBFM issues with afterSingletonsInstantiated\n\nRelated to GH-2935. Ensure that afterSingletonsInstantiated is called\neven when autoStartup is not enabled.","shortMessageHtmlLink":"SBFM issues with afterSingletonsInstantiated"}},{"before":"5ab62e1aa17c5281ae539a4f4101a272440ebaca","after":"5fb122e5a9e429533846fff86d903451201f5637","ref":"refs/heads/main","pushedAt":"2024-04-12T21:41:09.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"sobychacko","name":"Soby Chacko","path":"/sobychacko","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/827682?s=80&v=4"},"commit":{"message":"SBFM changes for Boot 3.2/3.3 compatibility","shortMessageHtmlLink":"SBFM changes for Boot 3.2/3.3 compatibility"}},{"before":"24556fd79e8d3afc66b30921cb42f0195ee3f10a","after":"5ab62e1aa17c5281ae539a4f4101a272440ebaca","ref":"refs/heads/main","pushedAt":"2024-04-12T20:42:39.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"sobychacko","name":"Soby Chacko","path":"/sobychacko","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/827682?s=80&v=4"},"commit":{"message":"Fix Kafka binder tests for Boot 3.3.x compatibility","shortMessageHtmlLink":"Fix Kafka binder tests for Boot 3.3.x compatibility"}},{"before":"b736b4a8fa8d8fb60a69977ce9321d542952afcf","after":"24556fd79e8d3afc66b30921cb42f0195ee3f10a","ref":"refs/heads/main","pushedAt":"2024-04-10T18:06:55.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"sobychacko","name":"Soby Chacko","path":"/sobychacko","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/827682?s=80&v=4"},"commit":{"message":"GH-2935: Call afterSingletonsInitialized() in SBFM\n\nStreamsBuilderFactoryBean: Call afterSingletonsInitialized() programmatically in StreamsBuilderFactoryManager\n\nResolves https://github.com/spring-cloud/spring-cloud-stream/issues/2935","shortMessageHtmlLink":"GH-2935: Call afterSingletonsInitialized() in SBFM"}},{"before":"a636eec47c0a4aafb0915c3eb3e5560acdc4e866","after":"b736b4a8fa8d8fb60a69977ce9321d542952afcf","ref":"refs/heads/main","pushedAt":"2024-04-09T22:21:00.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"sobychacko","name":"Soby Chacko","path":"/sobychacko","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/827682?s=80&v=4"},"commit":{"message":"Remove @AutoConfiguration from TestChannelBinderConfiguration\n\nBackout changes introduced in https://github.com/spring-cloud/spring-cloud-stream/commit/4174657a356478cdb1d7e648a0793dd6d87af19c\n\nResolves https://github.com/spring-cloud/spring-cloud-stream/issues/2931","shortMessageHtmlLink":"Remove @autoConfiguration from TestChannelBinderConfiguration"}},{"before":"99f1f1eb4a153dbdedce49cdb700c280b59c2666","after":"a636eec47c0a4aafb0915c3eb3e5560acdc4e866","ref":"refs/heads/main","pushedAt":"2024-04-09T18:45:02.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"sobychacko","name":"Soby Chacko","path":"/sobychacko","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/827682?s=80&v=4"},"commit":{"message":"GH-2933: Clarify docs on adding global state stores\n\nResolves https://github.com/spring-cloud/spring-cloud-stream/issues/2933","shortMessageHtmlLink":"GH-2933: Clarify docs on adding global state stores"}},{"before":"5a231df52dbc76f438e8fd4a2bd0b456ddbe2545","after":"99f1f1eb4a153dbdedce49cdb700c280b59c2666","ref":"refs/heads/main","pushedAt":"2024-03-27T13:18:09.000Z","pushType":"push","commitsCount":3,"pusher":{"login":"spring-builds","name":"Spring Builds","path":"/spring-builds","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/1134463?s=80&v=4"},"commit":{"message":"Bumping versions to 4.1.2-SNAPSHOT after release","shortMessageHtmlLink":"Bumping versions to 4.1.2-SNAPSHOT after release"}},{"before":"4862f9e9687652809656ba8efbfa162d7031b5dc","after":"9cdc619f175f43708d7d2d29e7781677471c4be1","ref":"refs/heads/docs-build","pushedAt":"2024-03-26T19:15:02.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"ryanjbaxter","name":"Ryan Baxter","path":"/ryanjbaxter","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/524254?s=80&v=4"},"commit":{"message":"Update antora-playbook.yml","shortMessageHtmlLink":"Update antora-playbook.yml"}},{"before":"70495a00f5f62d6ff702b39878ce00bf0a8dc70c","after":"5a231df52dbc76f438e8fd4a2bd0b456ddbe2545","ref":"refs/heads/main","pushedAt":"2024-03-25T21:52:26.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"sobychacko","name":"Soby Chacko","path":"/sobychacko","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/827682?s=80&v=4"},"commit":{"message":"fixed typo in configuration-options.adoc","shortMessageHtmlLink":"fixed typo in configuration-options.adoc"}},{"before":"568c82d889e1c1bf6ed95d8fce1d8c7d3853710c","after":"70495a00f5f62d6ff702b39878ce00bf0a8dc70c","ref":"refs/heads/main","pushedAt":"2024-03-22T02:19:01.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"sobychacko","name":"Soby Chacko","path":"/sobychacko","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/827682?s=80&v=4"},"commit":{"message":"Remove hard-coded reactor version\n\n* Remove hard-coded reactor version in lieu of Boot managed version","shortMessageHtmlLink":"Remove hard-coded reactor version"}},{"before":"eab86f81a8b34569f8075c352b4bb9602150fbc5","after":"568c82d889e1c1bf6ed95d8fce1d8c7d3853710c","ref":"refs/heads/main","pushedAt":"2024-03-21T20:22:49.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"sobychacko","name":"Soby Chacko","path":"/sobychacko","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/827682?s=80&v=4"},"commit":{"message":"Fixing typo - consuming batch docs","shortMessageHtmlLink":"Fixing typo - consuming batch docs"}},{"before":"9190e9b8358478c022f1e96e7511f64b79f1661f","after":"eab86f81a8b34569f8075c352b4bb9602150fbc5","ref":"refs/heads/main","pushedAt":"2024-03-20T21:16:33.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"sobychacko","name":"Soby Chacko","path":"/sobychacko","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/827682?s=80&v=4"},"commit":{"message":"GH-2922: Timestamp extractor - Kafka Streams 3.7.0\n\n * Address immutability changes for the call to `Consumed#withTimestampExtractor`.\n\n * In 3.7.0, this call returns a new instance of `Consumed` as oppposed to\n mutating the existing instance in the previous versions. Address this\n change in behavior in the Kafka Streams binder.\n\nResolves https://github.com/spring-cloud/spring-cloud-stream/issues/2922","shortMessageHtmlLink":"GH-2922: Timestamp extractor - Kafka Streams 3.7.0"}},{"before":"f836e1cf54195aebf03bbf9c79bcc5ef7f38ea12","after":"9190e9b8358478c022f1e96e7511f64b79f1661f","ref":"refs/heads/main","pushedAt":"2024-03-20T20:14:16.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"sobychacko","name":"Soby Chacko","path":"/sobychacko","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/827682?s=80&v=4"},"commit":{"message":"GH-2921: Output-bindings and RabbitMQ r-k-e issues \n\n* When output-bindings config is explicitly used for StreamBridge\r\n and the RabbitMQ routing-key-expression is provided, Spring Cloud Stream\r\n is throwing an exception due to a proper function is not found in\r\n the catalog. Bypassing this step and letting the bootstrapping continues\r\n if output-bindings and RabbitMQ routing-key-expression combination is used.\r\n* Adding tests to verify\r\n\r\nResolves https://github.com/spring-cloud/spring-cloud-stream/issues/2921","shortMessageHtmlLink":"GH-2921: Output-bindings and RabbitMQ r-k-e issues"}},{"before":"e80f53fbe805ea41f6422cf27101e9a649db7491","after":"f836e1cf54195aebf03bbf9c79bcc5ef7f38ea12","ref":"refs/heads/main","pushedAt":"2024-03-19T20:40:10.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"sobychacko","name":"Soby Chacko","path":"/sobychacko","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/827682?s=80&v=4"},"commit":{"message":"GH-2923: StreamBridge and Kafka send with virtual threads\n\n * Sending Kafka events via StreamBridge#send using virtual threads causes pinning. \r\n Use a ReentrantLock to avoid pinning.","shortMessageHtmlLink":"GH-2923: StreamBridge and Kafka send with virtual threads"}},{"before":"e03b993c3b6d5bf78f4949ce13d9982d4ee5d3a5","after":"e80f53fbe805ea41f6422cf27101e9a649db7491","ref":"refs/heads/main","pushedAt":"2024-03-19T19:28:37.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"sobychacko","name":"Soby Chacko","path":"/sobychacko","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/827682?s=80&v=4"},"commit":{"message":"Adding rabbitmq docker-compose","shortMessageHtmlLink":"Adding rabbitmq docker-compose"}},{"before":"fcdaf2fdd8d6c6a7e6fdd11077ed316268242e9b","after":"e03b993c3b6d5bf78f4949ce13d9982d4ee5d3a5","ref":"refs/heads/main","pushedAt":"2024-03-18T21:39:04.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"sobychacko","name":"Soby Chacko","path":"/sobychacko","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/827682?s=80&v=4"},"commit":{"message":"GH-2919: Eager loading `FunctionConfiguation`\n\n* Always eager loading `FunctionConfiguration`\r\n\r\nResolves https://github.com/spring-cloud/spring-cloud-stream/issues/2919","shortMessageHtmlLink":"GH-2919: Eager loading FunctionConfiguation"}},{"before":"a2458f30290d915018b01e4c8fa20a875b8d2578","after":"fcdaf2fdd8d6c6a7e6fdd11077ed316268242e9b","ref":"refs/heads/main","pushedAt":"2024-03-14T19:47:21.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"sobychacko","name":"Soby Chacko","path":"/sobychacko","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/827682?s=80&v=4"},"commit":{"message":"Fix Pulsar binder for Java 21 (#2918)\n\nResolves https://github.com/spring-cloud/spring-cloud-stream/issues/2915\r\n\r\nRunning the Pulsar binder with Java 21 surfaced a bug where the layered\r\nbinder/binding config props are not properly applied to the targeted\r\nconsumer/producer builders.\r\n\r\nThe bug existed before Java 21 and is unrelated.\r\n\r\nThe binder/binding config props are converted to a Pulsar\r\nProducerConfigurationData object via Jackson. This conversion process iterates\r\nover a map of config props. The iteration order of the map changed between Java\r\n17 and 21. This results in object setters getting called in different orders, \r\nwhich in turn causes cross-field validation errors.\r\n\r\nSee #2915 for more details","shortMessageHtmlLink":"Fix Pulsar binder for Java 21 (#2918)"}},{"before":"d2e66b76a19f9fb749945de7d3b21dc204dd1ee4","after":"a2458f30290d915018b01e4c8fa20a875b8d2578","ref":"refs/heads/main","pushedAt":"2024-03-14T14:55:21.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"sobychacko","name":"Soby Chacko","path":"/sobychacko","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/827682?s=80&v=4"},"commit":{"message":"Clarify batch-consuming docs for Kafka binder\n\nBased on this issue: https://github.com/spring-cloud/spring-cloud-stream/issues/2917","shortMessageHtmlLink":"Clarify batch-consuming docs for Kafka binder"}},{"before":"fac0c143aded04a3d869f923857d0dce5f2ffb1e","after":"d2e66b76a19f9fb749945de7d3b21dc204dd1ee4","ref":"refs/heads/main","pushedAt":"2024-03-12T14:35:33.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"ryanjbaxter","name":"Ryan Baxter","path":"/ryanjbaxter","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/524254?s=80&v=4"},"commit":{"message":"Update antora-playbook.yml to 0.4.11","shortMessageHtmlLink":"Update antora-playbook.yml to 0.4.11"}},{"before":"b08fe14dd70c265609e0ea04a8c7a4aed7f43074","after":"fac0c143aded04a3d869f923857d0dce5f2ffb1e","ref":"refs/heads/main","pushedAt":"2024-03-08T23:21:40.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"sobychacko","name":"Soby Chacko","path":"/sobychacko","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/827682?s=80&v=4"},"commit":{"message":"GH-2560: Clarify docs on error handling/DLQ\n\n * Clarify the docs on retry behavior in Kafka binder when max-attempts set to 1 and no DLQ\n\nResolves https://github.com/spring-cloud/spring-cloud-stream/issues/2560","shortMessageHtmlLink":"GH-2560: Clarify docs on error handling/DLQ"}},{"before":"05b1eadd7885e2825ccece3037ac7d9614f15a42","after":"b08fe14dd70c265609e0ea04a8c7a4aed7f43074","ref":"refs/heads/main","pushedAt":"2024-03-08T22:40:53.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"sobychacko","name":"Soby Chacko","path":"/sobychacko","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/827682?s=80&v=4"},"commit":{"message":"Move core error handling docs to top-level\n\nKafka binder error channels docs cleanup","shortMessageHtmlLink":"Move core error handling docs to top-level"}},{"before":"b595302f9ca1d776e61e231b80da94fcecf92c9e","after":"05b1eadd7885e2825ccece3037ac7d9614f15a42","ref":"refs/heads/main","pushedAt":"2024-03-08T21:00:07.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"sobychacko","name":"Soby Chacko","path":"/sobychacko","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/827682?s=80&v=4"},"commit":{"message":"Docs cleanup","shortMessageHtmlLink":"Docs cleanup"}},{"before":"c7b24a3d3cb96bdf037660192ac8052207e54dc3","after":"b595302f9ca1d776e61e231b80da94fcecf92c9e","ref":"refs/heads/main","pushedAt":"2024-03-08T20:51:31.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"sobychacko","name":"Soby Chacko","path":"/sobychacko","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/827682?s=80&v=4"},"commit":{"message":"Cleanup default properties docs\n\nResolves https://github.com/spring-cloud/spring-cloud-stream/issues/2906","shortMessageHtmlLink":"Cleanup default properties docs"}}],"hasNextPage":true,"hasPreviousPage":false,"activityType":"all","actor":null,"timePeriod":"all","sort":"DESC","perPage":30,"cursor":"djE6ks8AAAAEPxdpjwA","startCursor":null,"endCursor":null}},"title":"Activity ยท spring-cloud/spring-cloud-stream"}