SpringCloud/spring-cloud-stream
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Commit Graph

  • 13874dc2aa Addressing checkstyle issues Soby Chacko 2024-11-05 16:28:12 -05:00
  • 505a33be9e Add additional utility methods Oleg Zhurakousky 2024-11-01 07:39:20 +01:00
  • baaf8d555a GH-2969 Initial commit to add StandardBatchUtils Oleg Zhurakousky 2024-10-15 16:57:23 +02:00
  • a8fb34db0e Adding Spring Cloud Stream Version To Message Headers For Easier Debugging Of Issues. Ömer Çelik 2024-11-04 13:23:01 +03:00
  • 17ac6352e4 Fix FunctionConfiguration.sanitize() for generics Artem Bilan 2024-11-04 16:25:24 -05:00
  • ba09e401e8 Add additional utility methods GH-2969 Oleg Zhurakousky 2024-11-01 07:39:20 +01:00
  • 824403d8e5 GH-2969 Initial commit to add StandardBatchUtils Oleg Zhurakousky 2024-10-15 16:57:23 +02:00
  • ffb62cb81b Merge pull request #3025 from aviv-amdocs/patch-1 Oleg Zhurakousky 2024-10-30 19:24:38 +01:00
  • 01a508187c Update timeout default aviv-amdocs 2024-10-30 15:01:00 +02:00
  • c5b3201fa2 Fixing build failure issues in reactive Kafka binder Soby Chacko 2024-10-29 11:29:18 -04:00
  • cca19a5772 Fix avro tests Oleg Zhurakousky 2024-10-28 17:13:58 +01:00
  • d84f6a4b1e Add kotlin stdlib Oleg Zhurakousky 2024-10-28 14:04:30 +01:00
  • 05de9a8222 Fix broken build Oleg Zhurakousky 2024-10-28 13:52:07 +01:00
  • 4dfd9c1df6 GH-3024: Add logging for exceptions in KafkaTopicProvisioner Soby Chacko 2024-10-24 15:02:50 -04:00
  • 8b6b1271ef GH-3024: Add logging for exceptions in KafkaTopicProvisioner Soby Chacko 2024-10-24 15:02:50 -04:00
  • 9888a08dff Fix checkstyles Oleg Zhurakousky 2024-10-21 17:57:07 +02:00
  • 12468dcd0a Fix checkstyles Oleg Zhurakousky 2024-10-21 17:57:07 +02:00
  • 28e0a69e55 Merge pull request #3022 from cppwfs/SCSt-CONN-NAME-FIX Oleg Zhurakousky 2024-10-21 16:16:43 +02:00
  • efbe2cd005 Update docs to show correct prefix for connection-name-prefix Glenn Renfro 2024-10-21 10:06:50 -04:00
  • 93478a8922 Bumping versions spring-builds 2024-10-17 14:21:53 +00:00
  • c96a62f163 GH-2939: Rely on custom AmqpHeaders.RETRY_COUNT for server retries Artem Bilan 2024-10-07 17:34:46 -04:00
  • bf9ea9e626 Fix Rabbit binder compiliation issues Soby Chacko 2024-10-14 14:19:45 -04:00
  • d9326ada75 Adding kotlin-stdlib-jdk8 depedency in spring-cloud-stream-integration-tests Soby Chacko 2024-10-14 12:33:23 -04:00
  • 723f44dd83 Merge pull request #3021 from spring-cloud/dependabot/maven/schema-registry/org.apache.avro-avro-1.11.4 Oleg Zhurakousky 2024-10-09 08:32:21 +02:00
  • d68dece939 Bump org.apache.avro:avro from 1.11.3 to 1.11.4 in /schema-registry dependabot[bot] 2024-10-08 14:56:35 +00:00
  • 3c70c04806 GH-3020 Make Kotlin dependency optional Oleg Zhurakousky 2024-10-08 14:53:02 +02:00
  • fa9a80d803 GH-3020 Make Kotlin dependency optional Oleg Zhurakousky 2024-10-08 14:53:02 +02:00
  • a81fb04286 Going back to snapshots buildmaster 2024-10-08 01:06:11 +00:00
  • 67d4d34a58 Update SNAPSHOT to 4.2.0-M2 buildmaster 2024-10-08 01:03:40 +00:00
  • 559d49381f Merge pull request #3017 from omercelikceng/codecleanupp Oleg Zhurakousky 2024-10-07 18:44:05 +02:00
  • eea905f692 Merge pull request #3015 from sobychacko/gh-2985 Oleg Zhurakousky 2024-10-07 18:43:26 +02:00
  • cbfd3aa995 Change "synchronized" to reentrant lock for virtual-threads Ömer Çelik 2024-10-04 23:03:56 +03:00
  • 4a2b67df38 Fix broken cross reference links Oleg Zhurakousky 2024-10-07 18:07:44 +02:00
  • 7a5e5d0541 Fix broken cross reference links Oleg Zhurakousky 2024-10-07 18:07:44 +02:00
  • 06040728cc Cleanup spring-kafka dependency version. Soby Chacko 2024-10-07 10:21:27 -04:00
  • e445a34f8d Code Cleanup - StringBuilder, Redundant Iteration, Record Ömer Çelik 2024-10-05 01:32:15 +03:00
  • f8d6caa429 GH-2985: Add Kafka Listener Container Customizer interfaces and documentation Soby Chacko 2024-10-04 17:50:14 -04:00
  • 6f1b5a4d93 Fix checkstyles before merge Oleg Zhurakousky 2024-10-02 12:24:52 +02:00
  • 94142aa80f change synchronized to reentrant lock in streambridge 김동근 2024-10-02 14:01:23 +09:00
  • 56d86c9807 GH-2974 Fix validation when only 'default' properties are used Oleg Zhurakousky 2024-10-02 12:14:00 +02:00
  • e642cadadd GH-2974 Fix validation when only 'default' properties are used Oleg Zhurakousky 2024-10-02 12:14:00 +02:00
  • 6f9809eba1 Fix depreactions Oleg Zhurakousky 2024-09-27 16:41:56 +02:00
  • 8148d55251 BindingServiceProperties.bindings property should be thread-safe. First, thanks for the excellent StreamBridge feature! I've found it very useful. However, I occasionally encounter the following exception during race conditions. `` java.lang.NullPointerException: null at java.base/java.util.TreeMap.rotateRight(TreeMap.java:2240) at java.base/java.util.TreeMap.fixAfterInsertion(TreeMap.java:2272) at java.base/java.util.TreeMap.put(TreeMap.java:580) at org.springframework.cloud.stream.config.BindingServiceProperties.bindToDefault(BindingServiceProperties.java:397) at org.springframework.cloud.stream.config.BindingServiceProperties.bindIfNecessary(BindingServiceProperties.java:381) at org.springframework.cloud.stream.config.BindingServiceProperties.getBindingProperties(BindingServiceProperties.java:301) at org.springframework.cloud.stream.function.StreamBridge.send(StreamBridge.java:149) `` BindingServiceProperties.bindings property should be thread-safe. kurt 2024-09-26 23:51:33 +09:00
  • 9aabfbe6ea Merge pull request #3011 from kurthong/BindingServiceProperties.bindings-property-should-be-thread-safe Oleg Zhurakousky 2024-09-27 11:00:21 +02:00
  • fd20513f86 BindingServiceProperties.bindings property should be thread-safe. First, thanks for the excellent StreamBridge feature! I've found it very useful. However, I occasionally encounter the following exception during race conditions. `` java.lang.NullPointerException: null at java.base/java.util.TreeMap.rotateRight(TreeMap.java:2240) at java.base/java.util.TreeMap.fixAfterInsertion(TreeMap.java:2272) at java.base/java.util.TreeMap.put(TreeMap.java:580) at org.springframework.cloud.stream.config.BindingServiceProperties.bindToDefault(BindingServiceProperties.java:397) at org.springframework.cloud.stream.config.BindingServiceProperties.bindIfNecessary(BindingServiceProperties.java:381) at org.springframework.cloud.stream.config.BindingServiceProperties.getBindingProperties(BindingServiceProperties.java:301) at org.springframework.cloud.stream.function.StreamBridge.send(StreamBridge.java:149) `` BindingServiceProperties.bindings property should be thread-safe. kurt 2024-09-26 23:51:33 +09:00
  • 2f4ae47276 GH-3009 Add post processing support for Supplier Oleg Zhurakousky 2024-09-26 14:08:27 +02:00
  • 0336ffd8ca GH-3009 Add post processing support for Supplier Oleg Zhurakousky 2024-09-26 14:08:27 +02:00
  • b7f2f1bb2d Support Spring Boot's KafkaConnectionDetails for Kafka connections Andy Wilkinson 2024-09-24 11:55:24 +01:00
  • 090ccfad14 Support Spring Boot's KafkaConnectionDetails for Kafka connections Andy Wilkinson 2024-09-24 11:55:24 +01:00
  • 417551365b Add 4.1.x branch to the CI PR builds Soby Chacko 2024-09-24 15:54:44 -04:00
  • eecec4198a Merge pull request #3005 from ferblaca/GH-3004 Oleg Zhurakousky 2024-09-24 18:25:57 +02:00
  • 56047ddb19 GH-2997 Fix support for producer's error-handler-definition Oleg Zhurakousky 2024-09-24 17:18:48 +02:00
  • 8fc89bc4c0 GH-2997 Fix support for producer's error-handler-definition Oleg Zhurakousky 2024-09-24 17:18:48 +02:00
  • 2f82f3cd02 Remove the use of synchronized in the getBinder method of DefaultBinderFactory class for virtual-threads Fernando Blanch 2024-09-24 16:09:27 +02:00
  • add6b0178e GH-2994, GH-2986 Add documentation explaining batch type conversion Oleg Zhurakousky 2024-09-23 16:47:36 +02:00
  • e81976f7b5 Make MessageConverterHelper bean names distinct in binders. Soby Chacko 2024-09-19 16:14:34 -04:00
  • dc38fd1199 Enhancements in Kafka binder FunctionBatchingConversionTests Soby Chacko 2024-09-18 13:30:03 -04:00
  • e4a06ee686 Customizing batch message conversion behavior for Kafka binder Soby Chacko 2024-09-17 14:39:30 -04:00
  • 2517760529 GH-2994, GH-2986 Add initial support for customizing Message Converter behavior Oleg Zhurakousky 2024-09-16 16:10:38 +02:00
  • 5d881b2adb GH-2994, GH-2986 Add documentation explaining batch type conversion Oleg Zhurakousky 2024-09-23 16:47:36 +02:00
  • 03dc940ea9 Merge pull request #3000 from MAX-66/fix-output-bindings-code Oleg Zhurakousky 2024-09-23 15:01:26 +02:00
  • 29a3558329 Make MessageConverterHelper bean names distinct in binders. Soby Chacko 2024-09-19 16:14:34 -04:00
  • 42d91e0ff3 GH-2650: Observability enhancements in reactive Kafka binder Soby Chacko 2024-09-19 12:48:19 -04:00
  • 058fc660ae Enhancements in Kafka binder FunctionBatchingConversionTests Soby Chacko 2024-09-18 13:30:03 -04:00
  • fac9eb1ebd Customizing batch message conversion behavior for Kafka binder Soby Chacko 2024-09-17 14:39:30 -04:00
  • 14c10462f8 GH-2994, GH-2986 Add initial support for customizing Message Converter behavior Oleg Zhurakousky 2024-09-16 16:10:38 +02:00
  • 4df2e760b9 Fixing failing tests Soby Chacko 2024-09-10 15:54:17 -04:00
  • 6c3fc4c350 Merge pull request #3001 from hightea/cherry-pick-avoid-duplicate-logs Oleg Zhurakousky 2024-09-08 04:16:13 -07:00
  • 110061b04e Avoid duplicate error logging when multiple destinations per binding Théophane Charbonnier 2024-09-02 18:06:00 +02:00
  • 0065a65d08 Simplify outputBindings logic in FunctionConfiguration lxq 2024-09-05 22:32:51 +08:00
  • f456405b02 Merge pull request #2998 from hightea/fix-duplicate-errors-logs Oleg Zhurakousky 2024-09-05 02:42:57 -07:00
  • a64a6e53e1 Avoid duplicate error logging when multiple destinations per binding Théophane Charbonnier 2024-09-02 18:06:00 +02:00
  • 08761487d8 Adds 4.1.x branch docs-build Spencer Gibb 2024-09-04 16:01:24 -04:00
  • 64dd18cc8e Use PulsarTopicBuilder in Pulsar binder (#2999) Chris Bono 2024-09-03 18:20:18 -05:00
  • 87ed345d1a KafkaBinderMetrics' metrics should be unregistered before it's thread Kurt Hong 2024-08-24 02:36:41 +09:00
  • fe1392efb0 KafkaBinderMetrics' metrics should be unregistered before it's thread Kurt Hong 2024-08-24 02:36:41 +09:00
  • 8e5f67a1a6 Code cleanup Ömer Çelik 2024-08-19 14:00:07 +03:00
  • 7fefaa38c0 Code cleanup Ömer Çelik 2024-08-16 13:05:38 +03:00
  • 1de0e1c690 Going back to snapshots buildmaster 2024-08-19 18:09:13 +00:00
  • b1507bdc01 Update SNAPSHOT to 4.2.0-M1 buildmaster 2024-08-19 18:06:14 +00:00
  • 26dddfe1c1 Going back to snapshots buildmaster 2024-08-19 17:29:31 +00:00
  • 15f5791281 Update SNAPSHOT to 4.2.0-M1 buildmaster 2024-08-19 17:26:43 +00:00
  • 268423327b GH-2989 - Make SpEL converter stringify primitive values Artem Bilan 2024-07-26 15:57:12 -04:00
  • f146ce3eac GH-2989 - Make SpEL converter stringify primitive values Artem Bilan 2024-07-26 15:57:12 -04:00
  • 6aa9062247 Merge pull request #2983 from omercelikceng/messageHeadersTest Oleg Zhurakousky 2024-08-08 11:00:30 +02:00
  • b898e396ed Re-enable SchemaRegistryServerAvroTests Soby Chacko 2024-08-07 17:49:24 -04:00
  • dffbe6d610 Merge pull request #2984 from andq/main Oleg Zhurakousky 2024-08-07 17:29:54 +02:00
  • 71e0c92e7c Bumping versions buildmaster 2024-08-06 18:45:33 +00:00
  • 9bfc242941 Disables tests spencergibb 2024-08-06 14:18:39 -04:00
  • 721b904ae2 Disables tests spencergibb 2024-08-06 13:50:18 -04:00
  • 8eda26210a Disables tests spencergibb 2024-08-05 16:06:14 -04:00
  • 42c42104ea Fixed compile errors with replacements for deprecations spencergibb 2024-08-05 15:53:43 -04:00
  • 1b4e3fbad8 Fix typo in docs andq 2024-08-03 19:41:18 +02:00
  • 3dd4a0747b Bumping versions buildmaster 2024-08-02 10:15:33 +00:00
  • 98501d7535 Missing Headers Problem Ömer Çelik 2024-08-02 01:06:04 +03:00
  • 1a0d6d3246 Missing Headers Problem Ömer Çelik 2024-08-02 00:56:02 +03:00
  • 3b5bb2e0d9 Remove redundant delaySubscription from FunctionConfiguration Artem Bilan 2024-07-26 15:57:12 -04:00
  • f356599503 GH-1163-function Oleg Zhurakousky 2024-07-17 17:20:32 +02:00
  • 07e7d81e2d GH-2971 Properly handle Kafka tombstone payload conversion Oleg Zhurakousky 2024-07-17 16:19:12 +02:00
  • a0ccd665ff Use docs profile in GH actions. Olga Maciaszek-Sharma 2024-07-15 15:28:47 +02:00