SpringCloud/spring-cloud-stream-samples
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity
286 Commits 9 Branches 0 Tags
a70904ef08ff61ee4a72eedb0a2e8ee26a27f3f4
Commit Graph

286 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
onobc
a70904ef08 Add docker-compose for kafka cluster 2022-03-15 10:08:20 -04:00
Soby Chacko
08692a96d5 New sample for sendto.destination header with multi binders 2022-01-20 16:52:59 -05:00
Oleg Zhurakousky
efaa4c69c2 Update kotlin/rabbit sample 2021-12-07 13:22:04 +01:00
Soby Chacko
26ce234c10 Remove recipe style docs from samples project 
Receipe docs have migrated to the Kafka binder docs as part of the 3.2.x release.
 2021-12-02 17:13:45 -05:00
Soby Chacko
794c8629a4 Polishing 2021-10-01 16:28:54 -04:00
Soby Chacko
1998a60a5f Transaction sample changes 
Add @Transactional on the runtime code in the lambda expression,
not on the functional bean. If it is set on the function bean, then
that will only be invoked at application initialization, thus losing
the transactional semantics on the actual runtme code.

Resolves https://github.com/spring-cloud/spring-cloud-stream-samples/issues/212
 2021-10-01 16:21:27 -04:00
Soby Chacko
becc034169 Fix Kakfa Stream multiple input sample. 
Add new recipe for multiple instances of pollable consumers.
 2021-10-01 14:08:51 -04:00
Soby Chacko
0f579a8c95 New Kafka Streams sample for multiple input topics 2021-09-10 10:26:46 -04:00
Diego Toharia
fa8d4a3d2f GH-214: Fix kinesis-produce-consume does not run 
Fixes https://github.com/spring-cloud/spring-cloud-stream-samples/issues/214

* Use H2 as embedded DB
* Bump `spring-cloud-stream-binder-kinesis` to `2.2.0`
 2021-09-07 11:12:22 -04:00
Soby Chacko
3387cd75d9 Recipe for transactions and multiple topics. 2021-09-03 19:02:54 -04:00
Gary Russell
44dfb314c1 GH-210: Upgrade test-embedded-kafka to JUnit5 (#211) 
* GH-210: Upgrade test-embedded-kafka to JUnit5

Resolves https://github.com/spring-cloud/spring-cloud-stream-samples/issues/210

* Avoid a rebalance by using a different group in the test; use `assign()` instead of `subscribe()`.
 2021-08-26 15:29:13 -04:00
Gary Russell
99d44e08d2 Fix README. 2021-08-23 16:10:30 -04:00
Soby Chacko
1aeaba8e9a New sample for message routing callback 2021-07-26 16:30:56 -04:00
Soby Chacko
786bb72248 New recipe for Kafka custom header mapper 2021-07-16 18:51:51 -04:00
Soby Chacko
35c32db661 New recipe for how to keep track of successful publishing to Kafka. 2021-07-12 16:12:55 -04:00
Soby Chacko
8d11589518 Update kafka-multi-binder-jaas 
Update kafka-multi-binder-jaas to demonstrate how to use two Kafka clusters
with different jaas configs within a single application
 2021-07-07 15:16:32 -04:00
Jay Ehsaniara
2447b7c167 Update KafkaStreamsInteractiveQuerySample.java 
Avro generates primitive long in the later versions
 2021-07-06 14:00:35 -04:00
Soby Chacko
ee0ee47dc7 Adding new recipe for Kafka Streams binder 
How to change the default startOffset from earliest to latest?
 2021-06-24 19:34:08 -04:00
Soby Chacko
a1d17eccda Kafka Streams binder Jaas security sample 
Adding new sample for showcasing kafka streams binder
jaas security with SASL_PLAINTEXT.
 2021-06-22 20:52:16 -04:00
Soby Chacko
98f68c112a Adding some recipe like instructions for popular use cases. (#205) 
* Adding some recipe like instructions for popular use cases.

* Address PR review comments
 2021-06-15 16:46:53 -04:00
Jacson Ferreira
29e7db06dc Simple update Readme file 2021-06-08 20:11:26 -04:00
Soby Chacko
1e4a4f3239 Fixing build issues 2021-04-29 19:59:58 -04:00
Oleg Zhurakousky
556ca3d7b4 Add Kotlin/Stream sample 2021-04-06 16:44:01 +02:00
Soby Chacko
24997117d4 Spring Boot and Cloud updates 
Update samples to use Boot 2.4.4
Spring Cloud is updated to 2020.0.2

Remove empty integration tests
 2021-03-24 22:47:17 -04:00
Soby Chacko
03998b9bdc Cleanup in sample for spring-schema-registry-kafka-standalone 2021-02-09 20:53:28 -05:00
Soby Chacko
778550f1fd New sample: Spring's schema registry + Kafka + Avro 2021-02-09 20:45:30 -05:00
Soby Chacko
6141f0059f New sample for Kafka Streams + Avro 2021-02-09 14:52:51 -05:00
David Turanski
8f67cb8ac2 Disable tests by default and fix Testcontainers version 2021-01-25 12:08:34 -05:00
David Turanski
bcc920d532 More polish 2020-12-11 12:38:43 -05:00
David Turanski
400776aefd Remove Java 11 APIs 2020-12-11 12:09:27 -05:00
David Turanski
7349be38e5 Fix build and add integration profile 2020-12-11 10:06:23 -05:00
David Turanski
4516e7cae2 More cleanup 2020-12-09 16:45:07 -05:00
David Turanski
82d9d75c5e Polishing... 2020-12-09 10:24:14 -05:00
David Turanski
5f28d19327 Polishing... 2020-12-09 10:23:47 -05:00
David Turanski
15cf920c13 Add CouchBase sample 2020-12-07 09:25:02 -05:00
Soby Chacko
9d9804c365 Further cleanup in kafka ssl demo 
Use Horsham.SR10 directly instead of spring-cloud Hoxton
 2020-11-23 20:04:36 -05:00
Soby Chacko
89eddfe3c6 kafka ssl demo: Add spring-cloud-stream-binder-kafka-core 3.0.10.RELEASE dependency 2020-11-23 19:59:00 -05:00
mothaj
89b347f630 GH-195: updated test to use TestInputTopic and TestOutputTopic instead of depricated classes and methods 2020-11-23 15:37:09 -05:00
Soby Chacko
e749b8de7f Update ssl demo app 2020-11-23 10:54:07 -05:00
Soby Chacko
e20a22452d Reintroduce avro wildcard types in schema registry sample 
See this issue in Spring Cloud Function: https://github.com/spring-cloud/spring-cloud-function/issues/611
 2020-11-20 16:55:29 -05:00
Soby Chacko
22ade85c68 Update dependencies in scheam registry kafka vanilla samples. 2020-11-20 15:28:39 -05:00
Soby Chacko
1c262ef9b7 Update README.adoc 2020-11-06 11:19:32 -05:00
Soby Chacko
9a934c95ab Fix typo in README. 2020-11-06 11:16:31 -05:00
Soby Chacko
1b6d42d883 Fix tests 2020-10-22 10:42:33 -04:00
Soby Chacko
5ff96b4174 Adding new sample for Kafka Streams destination pattern 
See this issue for more context: https://github.com/spring-cloud/spring-cloud-stream-binder-kafka/issues/961
 2020-10-21 20:30:44 -04:00
Christian Tzolov
128cff6e27 Enable Kafka Producer/Consumer/Stream metrics 
- Change bindings input output to allows execution in SCDF.
 - Update to Boot 2.3.4 to ensure micrometer 1.5.5.
 2020-10-20 11:07:46 +02:00
Soby Chacko
a92fab7e3b Upgrade Spring Boot in samples to 2.3.4.RELEASE 2020-10-16 19:52:27 -04:00
Soby Chacko
2125c22f6d Update promethus-rsocket-spring version 
Update promethus-rsocket-spring version to 1.1.0
in Kafka Streams metrics demo
 2020-09-24 14:41:28 -04:00
Soby Chacko
9031d8922e New sample for Kafka Streams metrics 2020-09-21 20:07:25 -04:00
Soby Chacko
70e5307fc4 docs cleanup 2020-09-14 19:54:04 -04:00