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

73 Commits

Author SHA1 Message Date
Du, Zhi Guo
0d55d4e3c5 Update to spring boot 3.0.x (#256) 2024-06-10 15:30:05 -04:00
Steven Gantz
13bc86a240 RecordRecoverableProcessor and DltAwareProcessor example (#254) 
* example implementation with tests

update tests and README
Add implementation of junit

* Added fixes for comments

Made the test much more deterministic

* Fixed compilation error from IDE vs CLI invocation

* Removed unnecessary annotation

Handled by spring boot, not needed for Kafka autoconfiguration.
 2024-01-23 11:06:38 -05:00
dependabot[bot]
893f48fc27 Bump org.apache.avro:avro in /kafka-streams-samples/kafka-streams-avro 
Bumps org.apache.avro:avro from 1.8.2 to 1.11.3.

---
updated-dependencies:
- dependency-name: org.apache.avro:avro
  dependency-type: direct:production
...

Signed-off-by: dependabot[bot] <support@github.com>
 2023-11-13 14:25:37 -05:00
Soby Chacko
1bba62ddf5 README cleanup 2023-09-07 16:29:44 -04:00
Soby Chacko
8ee48dcb96 Samples cleanup 2023-08-28 18:02:55 -04:00
Soby Chacko
ddfe12228d Temporarily disabling the migrated samples 2023-08-28 17:45:22 -04:00
Soby Chacko
21b1afae51 Migrating samples from core SCSt repository 2023-08-28 17:20:41 -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
Jay Ehsaniara
2447b7c167 Update KafkaStreamsInteractiveQuerySample.java 
Avro generates primitive long in the later versions
 2021-07-06 14:00:35 -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
1e4a4f3239 Fixing build issues 2021-04-29 19:59:58 -04: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
6141f0059f New sample for Kafka Streams + Avro 2021-02-09 14:52:51 -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
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
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
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
ldicarlo
db24d1d68d Fixing Dead Link 
I think this link should point here, since Confluent removed kafka examples from confluentinc/examples, and put them in confluentinc/kafka-streams-examples.
 2019-11-08 16:24:08 -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
8cf8b2f10f Switching the inventory sample to the functional model 2019-11-01 19:54:11 -04:00
David Turanski
1c83e0ea54 Add inventory count sample 
Clean up

Change name in pom.xml
 2019-11-01 19:51:03 -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
47990a694f Porting kafka streams interactive sample to functional model 2019-09-30 13:11:39 -04:00
Soby Chacko
68b0614638 Update kafka streams samples 
Address Serde changes from upstream
Polishing
 2019-06-18 14:06:15 -04:00
Jose Antonio Iñigo Garrido
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
Jukka Karvanen
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
Mirco
ce0e8e1e18 Fixed typo 2019-03-21 15:22:03 -04:00
Spring Operator
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 Operator
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 Operator
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 Operator
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