Soby Chacko
13399dcd5f
Binder instantiation changes
...
- When default binder is provided, consider it while instantiating the binder.
This is needed for AOT/Native applications that provide a default binder.
Resolves https://github.com/spring-cloud/spring-cloud-stream/issues/2569
Resolves #2579
2022-12-07 14:53:26 -08:00
Oleg Zhurakousky
474ee07086
GH-2566 Make test binder an auto-configuration
...
Resolves #2566
2022-12-07 14:15:28 -08:00
유병준[Plasma1]
764a90720a
fix a broken link for kafka transaction reference
2022-12-07 10:47:12 -05:00
sai
3c7c5230c6
Fix typo in ListenerContainerWithDlqAndRetryCustomizer example of kafka binder
2022-12-05 17:27:27 -05:00
Soby Chacko
62e6a28d6d
Test deps cleanup in Kafka Streams binder
...
Remove superfluous Kafka test dependencies in Kafka Streams binder
Resolves https://github.com/spring-cloud/spring-cloud-stream/issues/2573
2022-12-05 11:39:14 -05:00
Christian Tzolov
d261074eb5
Multirecord schema support test fix
...
- fix the schema property settings for test.
- fix test schema fixture.
- add support (and check) for both avro converter types.
Resolves #2562
2022-12-04 13:40:16 +01:00
Soby Chacko
f54a370eed
Remove AWS Kinesis binder from core SCSt
2022-12-02 14:03:00 -05:00
buildmaster
67eed25d22
Going back to snapshots
2022-12-01 17:32:53 +00:00
buildmaster
9d4fdbbb03
Update SNAPSHOT to 4.0.0-RC3
2022-12-01 17:29:34 +00:00
Soby Chacko
8f04c6e9aa
Disconnect Kinesis binder docs from ref docs
2022-11-30 22:22:38 -05:00
Soby Chacko
d9b5a0972f
Cleanup TestChannelBinderConfiguration comments
...
Remove EnableBinding reference
2022-11-30 16:37:47 -05:00
Soby Chacko
02b3b8e02e
Disconnect Kinesis binder from the build
...
- Kinesis binder depends on spring-cloud-aws library which only becomes available
after the spring-cloud (2022) release that includes Spring Cloud Stream release.
This creates a cycle and thus we cannot include Kinesis binder release as part
of the Spring Cloud Stream release train.
See this issue for more details: https://github.com/spring-cloud/spring-cloud-stream/issues/2572
- Subsequently, we will remove the source code for Kinesis binder from core SCSt repostiroy and move
it into it's own space (as it was before).
2022-11-30 15:19:48 -05:00
Soby Chacko
d6fee8a258
Remove unused test support class
2022-11-29 17:40:10 -05:00
Soby Chacko
7248ac6c09
Test support dependency cleanup
2022-11-29 17:35:12 -05:00
Soby Chacko
f0f88e5de0
Rename spring-cloud-stream-binder-test
...
- Rename to spring-cloud-stream-test-support
- Make downstream binder dependency changes
2022-11-29 16:26:17 -05:00
Oleg Zhurakousky
c9778d88c9
Fixing checkstyle from previous commit
...
Resolves #2567
2022-11-29 11:30:50 -08:00
Kim Escobar
c1ce3cec75
Fix ClassCastException when using batch mode
...
Fix ClassCastException when handling error while using batch mode that prevents the republish of the message into the DLQ. The issue happened whenever the republish to dlq was enabled or if republish was disabled and max attempts were > 1 while the batch mode was enabled, because the handler was not expecting the the sourceData for the ErrorMessage could be a list of amqp message.
2022-11-29 10:40:17 -08:00
Oleg Zhurakousky
d99be4cf87
Remove test-jar from 'spring-cloud-stream-binder-test'
...
Resolves #2568
2022-11-29 10:35:00 -08:00
Soby Chacko
bc094e0ec4
Split test-binder from core spring-cloud-stream
...
* Remove all SI test-binder based components from core spring-cloud-stream-module
* Create a new module - spring-cloud-stream-test-binder that contains the test-binder
and all it's related components
* Migrate tests from core module that use the test-binder into a separate module
called spring-cloud-stream-integration-tests
* Remove the test-jar dependency using the classifier approach
* Update Spring Cloud Stream BOM with the new test-binder dependency
* Update Schema-Registry tests that use the old approach (using the test-jar with the classifier)
with the new test-binder dependency
Resolves https://github.com/spring-cloud/spring-cloud-stream/issues/2565
2022-11-29 10:06:07 -08:00
Oleg Zhurakousky
58ef5b0479
GH-2570 Ensure consistency in error handling
...
Rework error handling documentation
Remove dependence and usage of global errorChannel
Resolves #2570
2022-11-29 10:04:03 -08:00
buildmaster
622ba0a52c
Bumping versions
2022-11-29 17:32:43 +00:00
buildmaster
5b25dff5f9
Bumping versions
2022-11-21 17:35:03 +00:00
Soby Chacko
cfcb74252a
Update the cache prefix in schema registry client
2022-11-17 19:25:36 -05:00
Soby Chacko
20f844e094
Update AVRO version used in Schema Registry
...
AVRO 1.9.2 --> 1.11.1
Temporarily disabling AvroSchemaLocationsTest
2022-11-17 16:58:38 -05:00
buildmaster
75f16e336b
Going back to snapshots
2022-11-17 17:10:08 +00:00
buildmaster
c05e4b82c1
Update SNAPSHOT to 4.0.0-RC2
2022-11-17 17:06:33 +00:00
buildmaster
e7394d6a65
Bumping versions
2022-11-15 17:33:21 +00:00
Oleg Zhurakousky
c70f7d4949
Remove dead test
2022-11-09 09:43:13 +01:00
PINGUET Julien
2f37e98924
fix: set "spring-kafka-test" scope to "test"
...
Fixes gh-2387
2022-11-08 13:37:13 -05:00
Soby Chacko
330610fde9
Address compile issues in Kafka binder tests
2022-11-03 14:46:33 -04:00
Oleg Zhurakousky
81ddec3ce3
Fix byte[] conversion handling
2022-11-03 18:39:09 +01:00
Soby Chacko
9fb252c535
Schema Registry samples README enhancements
...
Adding instructions for how to use Confluent Schema Registry
with Spring Cloud Stream Scheam Registry AVRO converter clients.
2022-11-01 16:02:29 -04:00
buildmaster
523b77f58b
Bumping versions
2022-10-31 17:43:44 +00:00
Soby Chacko
fad684c2d7
Schema Registry cleanup
...
* AutoConfiguration.imports in-lieu of spring.factories and related changes.
* Build script cleanup.
2022-10-31 11:52:25 -04:00
Atsushi Yoshikawa
ecddd62fad
Fix producer Binding#companion bean not set
2022-10-31 10:34:04 +01:00
buildmaster
9a82f726b0
Going back to snapshots
2022-10-27 21:44:40 +00:00
buildmaster
14e58050ef
Update SNAPSHOT to 4.0.0-RC1
2022-10-27 21:41:15 +00:00
spencergibb
31fdea641d
Removes more snapshot versions
2022-10-27 13:19:14 -04:00
spencergibb
bd9dd3a553
Removes version for spring-rabbit-stream
2022-10-27 13:16:32 -04:00
Soby Chacko
4ebeadc0f6
Dependency cleanup - Kafka binder
...
Revmoe unnecessary explicit depdency of kafka-clients in the binder
2022-10-27 12:57:14 -04:00
Soby Chacko
b088879083
Dependency cleanup in Kafka binder
...
Remove unnecessary test dependencies added as
compile scope in Kafka binder.
Resolves https://github.com/spring-cloud/spring-cloud-stream/issues/2546
2022-10-26 14:56:25 -04:00
buildmaster
d83a02c603
Bumping versions
2022-10-26 17:33:09 +00:00
Oleg Zhurakousky
b86e713a58
Fix general Observablity support as well as Rabbit Observability support
2022-10-24 17:42:43 +02:00
Soby Chacko
0357d7f67f
Schema Registry Docs Cleanup
2022-10-20 15:35:01 -04:00
Soby Chacko
aebd885204
Minor cleanup in samples and tools
...
- Cleanup in schema-registry samples (final variable).
- Add instructions in tools/kafka/docker-compose to run
a quick test using Kafka console scripts.
2022-10-20 15:04:28 -04:00
Soby Chacko
9fa26da9ca
Add RetryTemplate to reactive kafka binder tests
...
This is needed because of a recent commit: cc04b0b13b
2022-10-20 11:40:59 -04:00
Soby Chacko
8e5f2d546e
checkstyle fixes
2022-10-20 11:03:45 -04:00
omercelikceng
cc04b0b13b
KafkaTopidProvisioner retry refactoring
...
Use a retry template for topic description method call through admin client
when provisioning consumer destinations. We are retrying because in the event
this operation gets failed, it is retried with the default retry settings in the provisioner.
Resolves https://github.com/spring-cloud/spring-cloud-stream/issues/2520
2022-10-20 10:56:19 -04:00
dependabot[bot]
0e5754f24f
Bump jackson-databind from 2.13.4 to 2.13.4.1
...
Bumps [jackson-databind](https://github.com/FasterXML/jackson ) from 2.13.4 to 2.13.4.1.
- [Release notes](https://github.com/FasterXML/jackson/releases )
- [Commits](https://github.com/FasterXML/jackson/commits )
---
updated-dependencies:
- dependency-name: com.fasterxml.jackson.core:jackson-databind
dependency-type: direct:production
...
Signed-off-by: dependabot[bot] <support@github.com >
2022-10-19 09:38:11 +02:00
Gary Russell
d93a4a0c4a
GH-2510: RabbitMQ Super Streams Concurrency
...
Add support for concurrency.
Use try with resources in stream tests.
Fix Test with Latest Boot
Resolves #2524
2022-10-19 09:36:30 +02:00
