Commit Graph
188 Commits
Author SHA1 Message Date
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
Artem Bilan 78514bb36c Ignore Kinesis tests when no local Kinesis 2019-10-29 16:12:59 -04:00
Artem BilanandSoby Chacko dee9053bd0 GH-161: Make Kinesis samples Function-based (#162)
* GH-161: Make Kinesis samples Function-based

Fixes https://github.com/spring-cloud/spring-cloud-stream-samples/issues/161

* * Fix READMEs to avoid `@EnableBinding` and brothers
2019-10-29 15:48:36 -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
Jose Antonio Iñigo GarridoandSoby Chacko ff95320be1 removed unnecessary props - native serialization/deserialization 2019-07-01 14:45:11 -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
Marcos Paulo dos Santos fca77bb1da #150 - Removed deprecated class org.springframework.kafka.test.rule.KafkaEmbedded 2019-06-18 18:36:44 -03:00