home/spring-cloud-stream-samples
2
0
Fork 0
mirror of https://github.com/wahyd4/spring-cloud-stream-samples.git synced 2026-08-08 21:06:34 +10:00
Code Issues Packages Projects Releases Wiki Activity
220 Commits 7 Branches 0 Tags
master
Commit Graph
100 Commits
This Branch
This Branch
All Branches
Author SHA1 Message Date
Soby Chacko 61b88cf736 Hoxton version update in samples 2020-05-23 13:53:21 -04:00
Soby Chacko e98eb914f2 Update boot parent in samples 2020-05-05 18:25:21 -04:00
Soby Chacko 1bea974d4d Update boot parent in testing demo 2020-03-24 19:12:39 -04:00
Soby Chacko 52154cae9e Update boot parent in multi-binder sample 2020-03-24 19:03:14 -04:00
Soby Chacko dec7c4c5a7 Fixing issues with multi binder Kafka Streams sample 2020-03-06 18:40:16 -05:00
Soby Chacko 5c29947a5e Update versions in samples 2020-02-29 18:29:32 -05:00
Soby Chacko db739cdb53 Update versions in samples 2020-02-29 18:22:21 -05:00
Soby Chacko 9a14238a50 Further changes for the Kafka native serialization sample 2020-01-10 16:25:10 -05:00
Soby Chacko eb63558b79 Cleaning up the kafka native serialization sample 2020-01-09 18:34:55 -05:00
Soby Chacko 85551b3376 New sample for Kafka native serialization with functions 2020-01-09 17:32:28 -05:00
Soby Chacko 1ad568a0bd Fixing wrong binding names in schema registry confluent sample 2019-12-11 10:44:20 -05:00
Soby Chacko 2b263af24b Kafka Transaction sample - README cleanup 2019-11-20 18:40:14 -05:00
Soby Chacko d9b970da54 Fix typo 2019-11-12 17:12:03 -05:00
Soby Chacko db65408dcc Adding functions composition samples for both Kafka/Rabbit 2019-11-12 17:07:03 -05:00
Soby Chacko f70c029510 Update Kafka transaction sample to use functions 2019-11-11 20:00:21 -05:00
Soby Chacko 38a9d47dac Ignore tests where we have empty tests 
These tests properly neeed to use EmbeddedKafka or some other testing strategy
 2019-11-08 15:54:23 -05:00
Soby Chacko 3f3337d09f Removing the watermark property added earlier 2019-11-08 14:59:15 -05:00
Soby Chacko f29ce89a27 Add @DirtiesContext to the inventory test 2019-11-08 14:55:26 -05:00
Soby Chacko 0b95dc0533 Trying to address a CI build failure 
Related to replication-offset-checkpoint.tmp in inventory count kafka streams sample
 2019-11-08 14:40:11 -05:00
Soby Chacko 295a2cfb71 Fix binding names in schema registry samples 2019-11-08 12:25:39 -05:00
Soby Chacko 8cf8b2f10f Switching the inventory sample to the functional model 2019-11-01 19:54:11 -04:00
Soby Chacko bb0e21f677 Refactoring dynamic source destination samples 2019-10-31 16:30:02 -04:00
Soby Chacko a7875c7f74 Dynamic destination refactoring 2019-10-31 13:54:18 -04:00
Soby Chacko 22856c20db Polishing 2019-10-30 21:39:24 -04:00
Soby Chacko f9f3b10237 Removing source samples/jdbc-source from samples repo 
Removing source samples/jdbc-source from samples repo in favor of the JDBC app starters.
https://github.com/spring-cloud-stream-app-starters/jdbc
 2019-10-30 21:31:06 -04:00
Soby Chacko 5b464e829d Removing sink samples/jdbc-sink from samples repo 
Removing sink samples/jdbc-sink from samples repo in favor of the JDBC app starters.
https://github.com/spring-cloud-stream-app-starters/jdbc
 2019-10-30 21:11:10 -04:00
Soby Chacko 19335341ad Refactor test-embedded-kafka 2019-10-30 20:53:33 -04:00
Soby Chacko 664281b03f Remove samples-e2e-tests module from samples project 
Since We have platform specific e2e tests for Spring Cloud Stream apps,
removing the e2e tests module from sample apps project.
 2019-10-30 19:21:01 -04:00
Soby Chacko add0cbfb15 Refactoring/Updating partitioning samples 2019-10-30 19:14:45 -04:00
Soby Chacko c8bea78d01 Refactor kafka jaas (multi binder) sample application 2019-10-30 16:48:53 -04:00
Soby Chacko 3eed560762 Refactor multibinder Kafka Streams application 2019-10-30 13:53:10 -04:00
Soby Chacko dad51e3d40 Refactoring mult-binder-two-kafka-clusters sample 2019-10-30 11:27:55 -04:00
Soby Chacko 8849f78cc0 Refactoring multi binder samples 2019-10-29 17:50:24 -04:00
Soby Chacko 8cf071251d Refactoring multi-io samples as functions 2019-10-29 17:28:27 -04:00
Soby Chacko de7f31d87d Update StreamListener sample 2019-10-29 12:32:02 -04:00
Soby Chacko 05e704f448 Updates to uppercase transformer 2019-10-29 12:22:07 -04:00
Soby Chacko 288c98a1a8 Temporaily disable kinesis-to-webflux sample from the build 2019-10-29 11:38:10 -04:00
Soby Chacko c37a483386 Polishing 2019-10-29 11:25:12 -04:00
Soby Chacko 175018af5e Processor samples refactoring 2019-10-29 11:24:23 -04:00
Soby Chacko 7b105a1495 Polishing 2019-10-29 10:25:18 -04:00
Soby Chacko 5cc9d346cf Refactor reactive processor sample application 2019-10-29 10:24:01 -04:00
Soby Chacko 56ffe4b99d Update kafka streams product tracker sample 2019-10-28 21:55:05 -04:00
Soby Chacko 2ca8568b55 Update interactive query sample 2019-10-28 21:47:05 -04:00
Soby Chacko ca18443d8d Update globalktable binding sample 2019-10-28 21:33:24 -04:00
Soby Chacko 3b0537c450 Update kafka-streams-table-join sample 2019-10-28 21:15:03 -04:00
Soby Chacko 3d6303e637 Update kafka-streams-to-rabbitmq-message-channel sample 2019-10-28 19:58:53 -04:00
Soby Chacko 2703ab2c8d Update kafka-streams-message-channel sample 2019-10-28 19:43:16 -04:00
Soby Chacko d3fff3b71e Update Kafka Streams DLQ sample 2019-10-28 17:03:15 -04:00
Soby Chacko 9be4ca0e56 Update Kafka Streams branching sample 2019-10-28 16:20:36 -04:00
Soby Chacko f2b3aacaab Refactoring kafka-streams-aggregate sample to use functions 2019-10-25 15:23:11 -04:00
Soby Chacko 594779ee77 Cleaning up samples 
Kotlin e2e sample with Boot 2.2.0.RELEASE
Kafka Streams word count functional updates
 2019-10-24 18:12:54 -04:00
Soby Chacko 4ec74168d6 Update Kotlin e2e sample 2019-10-01 17:30:34 -04:00
Soby Chacko 47990a694f Porting kafka streams interactive sample to functional model 2019-09-30 13:11:39 -04:00
Soby Chacko 9fbabeba56 Unignore test 2019-09-28 18:29:40 -04:00
Soby Chacko f7d966525f Ignoring test temporarily 2019-09-23 12:22:18 -04:00
Soby Chacko 2e4b9b7597 polishing 2019-09-23 12:15:44 -04:00
Soby Chacko a93ac7d702 Schema registry samples update - Iteration #3 
Update the samples that use Confluent Schema Registry and Confluent avro serializer/deserializer.
 2019-09-23 12:07:42 -04:00
Soby Chacko a123a621ec Schema registry samples update - Iteration #3 
Update the samples those are using Confluent Schema Registry and the spring Avro message converters
 2019-09-19 11:28:25 -04:00
Soby Chacko 74803ec017 cleanup 2019-09-18 17:36:52 -04:00
Soby Chacko b1025b0c6c Schema registry samples update - interation 2 
Updating kafka-streams-schema-evolution with Confluent Scheam registry samples
 2019-09-18 16:30:25 -04:00
Soby Chacko ff136d56c2 Schema registry sample upgrade - Iteration 1 
Convert the vanilla applications that uses the Spring provided Scheam registry and Avro message converters.
Provide 2 sets of the same applications - one for the Kafka binder and another for the Rabbit binder.
The top level folder of each of these sets are named appropriately so that anyone who is interested in a
particular binder can easilty cd to that directory and run the samples
 2019-09-17 20:17:27 -04:00
Soby Chacko c80523e257 Ignore reactive samples tests 2019-08-07 09:44:16 -04:00
Soby Chacko 2054e59fc1 Ignore jdbc sink e2e tests temporarily 2019-08-02 15:51:37 -04:00
Soby Chacko 2a7dbae247 Ignoring schema registry tests temporarily 2019-08-02 15:33:09 -04:00
Soby Chacko 5fd4b3e7e2 docs polishing 2019-06-20 17:50:20 -04:00
Soby Chacko 85aa628e8c polishing 2019-06-20 16:26:12 -04:00
Soby Chacko 59c7d710f6 Polishing 2019-06-20 16:15:34 -04:00
Soby Chacko f97d71f85f New sample for schema registry 
This sample demonstrates how to use Confluent Avro serializers with Confluent schema registry
in Spring Cloud Stream applications. Please see the README for details.
 2019-06-20 16:13:18 -04:00
Soby Chacko 426c97b284 Revert "Ignore failing test on CI" 
This reverts commit 45f7cdf17b.
 2019-06-19 19:54:22 -04:00
Soby Chacko 45f7cdf17b Ignore failing test on CI 2019-06-19 19:28:13 -04:00
Soby Chacko aaa5b44ac7 Fix broken tests 2019-06-19 17:24:14 -04:00
Soby Chacko 68b0614638 Update kafka streams samples 
Address Serde changes from upstream
Polishing
 2019-06-18 14:06:15 -04:00
Soby Chacko aeb05a7515 Use https for accessing Confluent maven repository 2019-06-11 20:15:13 -04:00
Soby Chacko a1809285b4 Convert reactive processor to functional model 2019-06-11 12:05:26 -04:00
Soby Chacko 465a983baf update dependencies for kafka binder in certain projects 2019-06-11 10:37:58 -04:00
Soby ChackoandGitHub 0b1a5c3be1 Update versions 2019-06-10 11:48:32 -04:00
Soby Chacko dd41ea5bac Update versions 
parent to Boot 2.1.4 snapshot
ScSt to Germantown snapshot
 2019-03-01 15:17:21 -05:00
Soby Chacko 18a7b2453e Cleanup kafka streams sample yaml files 2019-01-18 17:38:49 -05:00
Soby Chacko 5eebba3e9d polishing 2019-01-17 17:42:04 -05:00
Soby Chacko e6cf1085a6 Add integration test for kafka-streams wordcount sample 2019-01-17 17:38:09 -05:00
Soby ChackoandGitHub 03976c7c22 Update README.adoc 2019-01-08 10:32:36 -05:00
Soby Chacko c518e38aef Cleanup kafka streams samples yaml configuration 2019-01-07 16:55:37 -05:00
Soby Chacko 92803928ab Update confluent schema registry consumer sample with application ID 
Resolves #107
 2019-01-07 16:17:01 -05:00
Soby Chacko 5a21f2b687 Cleanup application.yml for kafka streams wordcount 2018-12-10 18:52:58 -05:00
Soby Chacko d73bddc095 Sample kafka streams config cleanup 2018-12-03 18:35:25 -05:00
Soby Chacko 50b855243a Fix stream-table sample issues 2018-12-03 16:44:42 -05:00
Soby Chacko 1ce7d3d51b polishing 2018-11-27 16:01:05 -05:00
Soby Chacko 417abb9acd Adding new sample for multibinder kafka streams 2018-11-27 15:58:37 -05:00
Soby Chacko d0b9cf52aa Temporarily ignore CloudStreamKinesisToWebfluxApplicationTests 2018-11-17 12:21:40 -05:00
Soby Chacko 1a67f1af23 Use kinesis binder instead of starter artifact 2018-11-14 15:11:46 -05:00
Soby Chacko 9beb9b7352 Add new sample for multiple binders 
Demonstrate how a Kafka Streams processor can be used to
produce data and then publish that into Rabbitmq.
 2018-11-02 09:50:48 -04:00
Soby Chacko 0ee844bcd9 Update stale maven coordinates for artifacts. 
Polishing docs
 2018-10-30 19:41:52 -04:00
Soby Chacko 57c980cfa2 Update boot parent to 2.1.0.BUILD-SNAPSHOT 2018-10-11 08:57:06 -04:00
Soby Chacko 12649abfeb Fixing kafka streams sample tests 2018-10-11 08:08:38 -04:00
Soby Chacko ab59cb73c6 Temporarily setting spring boot parent to 2.1.0.M3 2018-09-19 09:52:23 -04:00
Soby Chacko c8ccdfc9f6 polishing docs 2018-08-23 17:20:57 -04:00
Soby Chacko 765ada3559 Renaming kafka streams schema registry sample components 2018-08-23 17:14:52 -04:00
Soby Chacko 2adec97cd0 Kafka Streams schema evolution sample 
Sample for demonstrating schema evolution using kafka and kafka streams
binders and Confluent Schema Registry server.

Resolves #85
 2018-08-23 17:02:42 -04:00
Soby Chacko 1c38e8b553 Adding new sample for Kafka with security 
Demonstrate how to set up 2 kafka clusters with JAAS (plain text) enabled
and then run a processor application against them.

Resolves #86
 2018-08-23 15:21:56 -04:00
Soby Chacko b10a329fe1 Sample e2e tests pom changes 
Sample e2e tests module now inherit from the same parent pom as the other sample projects.

Resolves #88
 2018-08-22 19:19:59 -04:00