home/spring-cloud-stream-samples
2
0
Fork 0
mirror of https://github.com/wahyd4/spring-cloud-stream-samples.git synced 2026-08-09 05:16:18 +10:00
Code Issues Packages Projects Releases Wiki Activity
142 Commits 7 Branches 0 Tags
426c97b284028d3d37505cc053f91652a32e6f67
Commit Graph
142 Commits
This Branch
This Branch
All Branches
Author SHA1 Message Date
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
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
Jose Antonio Iñigo GarridoandSoby Chacko 14f3f5c600 kafka-e2e-sample 
fixed readme

updated e2e Kotlin sample and version upgrade to Horsham

updgraded Kotlin to 1.3.31
 2019-06-11 18:43:33 -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
Jukka KarvanenandSoby Chacko 1afdac7eb6 Kafka Streams unit test demonstration in Spring Cloud Stream 
kafka-streams-test-utils added TopologyTestDriver, Note now kafka.version need to be kept in sync manually

Reduce unnecessary logging

Extract contants to be used in test class
Changed non used key type from Object to Bytes to use BytesSerde
Added default contructor to support JsonSerde
Added toString for better test output

KafkaStreamsWordCountApplication.WordCountProcessorApplication using TopologyTestDriver

Unified intentation

Bytes as key type

Polishing
 2019-04-25 22:17:49 -04:00
MircoandSoby Chacko ce0e8e1e18 Fixed typo 2019-03-21 15:22:03 -04:00
Spring OperatorandSoby Chacko de71d4bffd URL Cleanup 
This commit updates URLs to prefer the https protocol. Redirects are not followed to avoid accidentally expanding intentionally shortened URLs (i.e. if using a URL shortener).

# Fixed URLs

## Fixed But Review Recommended
These URLs were fixed, but the https status was not OK. However, the https status was the same as the http request or http redirected to an https URL, so they were migrated. Your review is recommended.

* http://packages.confluent.io/maven/ (404) migrated to:
  https://packages.confluent.io/maven/ ([https](https://packages.confluent.io/maven/) result 404).

## Fixed Success
These URLs were switched to an https URL with a 2xx status. While the status was successful, your review is still recommended.

* http://www.apache.org/licenses/LICENSE-2.0 migrated to:
  https://www.apache.org/licenses/LICENSE-2.0 ([https](https://www.apache.org/licenses/LICENSE-2.0) result 200).
* http://repo.spring.io/libs-milestone-local migrated to:
  https://repo.spring.io/libs-milestone-local ([https](https://repo.spring.io/libs-milestone-local) result 302).
* http://repo.spring.io/libs-release-local migrated to:
  https://repo.spring.io/libs-release-local ([https](https://repo.spring.io/libs-release-local) result 302).
* http://repo.spring.io/libs-snapshot-local migrated to:
  https://repo.spring.io/libs-snapshot-local ([https](https://repo.spring.io/libs-snapshot-local) result 302).
* http://repo.spring.io/release migrated to:
  https://repo.spring.io/release ([https](https://repo.spring.io/release) result 302).

# Ignored
These URLs were intentionally ignored.

* http://maven.apache.org/POM/4.0.0
* http://maven.apache.org/xsd/maven-4.0.0.xsd
* http://www.w3.org/2001/XMLSchema-instance
 2019-03-21 15:21:19 -04:00
Spring OperatorandSoby Chacko f8c5cf942c URL Cleanup 
This commit updates URLs to prefer the https protocol. Redirects are not followed to avoid accidentally expanding intentionally shortened URLs (i.e. if using a URL shortener).

# Fixed URLs

## Fixed But Review Recommended
These URLs were fixed, but the https status was not OK. However, the https status was the same as the http request or http redirected to an https URL, so they were migrated. Your review is recommended.

* http://packages.confluent.io/maven/ (404) with 7 occurrences migrated to:
  https://packages.confluent.io/maven/ ([https](https://packages.confluent.io/maven/) result 404).

## Fixed Success
These URLs were switched to an https URL with a 2xx status. While the status was successful, your review is still recommended.

* http://maven.apache.org/xsd/assembly-1.1.2.xsd with 6 occurrences migrated to:
  https://maven.apache.org/xsd/assembly-1.1.2.xsd ([https](https://maven.apache.org/xsd/assembly-1.1.2.xsd) result 200).
* http://maven.apache.org/xsd/maven-4.0.0.xsd with 61 occurrences migrated to:
  https://maven.apache.org/xsd/maven-4.0.0.xsd ([https](https://maven.apache.org/xsd/maven-4.0.0.xsd) result 200).
* http://repo.spring.io/libs-milestone-local with 4 occurrences migrated to:
  https://repo.spring.io/libs-milestone-local ([https](https://repo.spring.io/libs-milestone-local) result 302).
* http://repo.spring.io/libs-release-local with 1 occurrences migrated to:
  https://repo.spring.io/libs-release-local ([https](https://repo.spring.io/libs-release-local) result 302).
* http://repo.spring.io/libs-snapshot-local with 4 occurrences migrated to:
  https://repo.spring.io/libs-snapshot-local ([https](https://repo.spring.io/libs-snapshot-local) result 302).
* http://repo.spring.io/release with 2 occurrences migrated to:
  https://repo.spring.io/release ([https](https://repo.spring.io/release) result 302).

# Ignored
These URLs were intentionally ignored.

* http://maven.apache.org/POM/4.0.0 with 122 occurrences
* http://maven.apache.org/plugins/maven-assembly-plugin/assembly/1.1.2 with 12 occurrences
* http://www.w3.org/2001/XMLSchema-instance with 67 occurrences
 2019-03-21 15:19:50 -04:00
Spring OperatorandSoby Chacko 6a2fb044ab URL Cleanup 
This commit updates URLs to prefer the https protocol. Redirects are not followed to avoid accidentally expanding intentionally shortened URLs (i.e. if using a URL shortener).

# Fixed URLs

## Fixed But Review Recommended
These URLs were fixed, but the https status was not OK. However, the https status was the same as the http request or http redirected to an https URL, so they were migrated. Your review is recommended.

* [ ] http://%s:%d/%s (UnknownHostException) with 2 occurrences migrated to:
  https://%s:%d/%s ([https](https://%s:%d/%s) result UnknownHostException).

## Fixed Success
These URLs were switched to an https URL with a 2xx status. While the status was successful, your review is still recommended.

* [ ] http://docs.spring.io/spring-kafka/reference/htmlsingle/ with 2 occurrences migrated to:
  https://docs.spring.io/spring-kafka/reference/htmlsingle/ ([https](https://docs.spring.io/spring-kafka/reference/htmlsingle/) result 301).

# Ignored
These URLs were intentionally ignored.

* http://127.0.0.1:8081/config with 2 occurrences
* http://localhost with 2 occurrences
* http://localhost:15672 with 1 occurrences
* http://localhost:64398/ with 1 occurrences
* http://localhost:64399/orders with 1 occurrences
* http://localhost:8080 with 8 occurrences
* http://localhost:8080/ with 1 occurrences
* http://localhost:8080/charts/top-five?genre=Punk with 1 occurrences
* http://localhost:8080/events with 2 occurrences
* http://localhost:8081 with 14 occurrences
* http://localhost:8082/charts/top-five?genre=Punk with 1 occurrences
* http://localhost:8990 with 4 occurrences
* http://localhost:9009/messages with 9 occurrences
* http://localhost:9009/messagesX with 1 occurrences
* http://localhost:9010/messages with 6 occurrences
* http://localhost:9010/messagesX with 1 occurrences
 2019-03-21 15:19:36 -04:00
Spring OperatorandSoby Chacko 0469a003ee URL Cleanup 
This commit updates URLs to prefer the https protocol. Redirects are not followed to avoid accidentally expanding intentionally shortened URLs (i.e. if using a URL shortener).

# Fixed URLs

## Fixed Success
These URLs were switched to an https URL with a 2xx status. While the status was successful, your review is still recommended.

* [ ] http://www.apache.org/licenses/ with 1 occurrences migrated to:
  https://www.apache.org/licenses/ ([https](https://www.apache.org/licenses/) result 200).
* [ ] http://www.apache.org/licenses/LICENSE-2.0 with 93 occurrences migrated to:
  https://www.apache.org/licenses/LICENSE-2.0 ([https](https://www.apache.org/licenses/LICENSE-2.0) result 200).
 2019-03-21 15:17:00 -04:00
todaynoworkandSoby Chacko dd06860b57 GlobalKTable binding sample 
Sample demonstrating joins between KStream and GlobalKTable.
Polishing.

Resolves #93
 2019-03-01 18:26:00 -05: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
krzysztof.goniaandSoby Chacko 80723fc491 Update README.adoc 2018-12-06 11:05:54 -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
Artem Bilan 697e5fd64a GH-99: Add Rule to ignore Kinesis test 
Fixes spring-cloud/spring-cloud-stream-samples#99

Add `LocalKinesisResource` which is going to be used as a `@ClassRule`
to ensure in the unit test that local service is available for
performing the test.
For that reason add `spring-cloud-stream-test-support-internal`
dependency since `LocalKinesisResource` is based on the
`AbstractExternalResourceTestSupport`
 2018-11-21 14:53:35 -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
Artem BilanandSoby Chacko 52c4c876a1 GH-87: Add Kinesis to WebFlux sample 
Fixes spring-cloud/spring-cloud-stream-samples#87
 2018-11-14 15:02:00 -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
Bjarte Stien KarlsenandSoby Chacko 451eef29b8 Add Kafka Streams consumer application to the native 
Spring Cloud Stream schema registry sample.

Resolves #98
 2018-10-30 19:19:20 -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
Soby Chacko e2111652fd More structural changes to samples repo 
Remove CF Acceptance tests
Convert local sample tests as e2e tests for the various sample apps
Polishing
 2018-08-17 21:02:30 -04:00
Soby Chacko 1dabe82fc9 Refactoring artifact names 
Rerfactoring artfiact names for partitioning samples to uniquely identy them as samples
Add docker plugin (fabric8) sections for uppercase transformer and partitioning samples
 2018-08-17 15:40:54 -04:00
Soby Chacko f34fd120e9 Uber jar naming changes 
Separate artifacts for kafka and rabbit binders with different classifiers
 2018-08-16 11:58:43 -04:00
Soby Chacko 49428f2bb6 Add distribution management to schema registry samples 2018-08-16 08:39:11 -04:00
Soby Chacko 1b3807888c Add missing distribution management to various samples 2018-08-16 08:27:39 -04:00