Ecosyste.ms: Repos

An open API service providing repository metadata for many open source software ecosystems.

GitHub / spring-cloud / spring-cloud-stream-samples

Samples for Spring Cloud Stream

JSON API: https://repos.ecosyste.ms/api/v1/hosts/GitHub/repositories/spring-cloud%2Fspring-cloud-stream-samples

Stars: 910
Forks: 663
Open Issues: 37

License: apache-2.0
Language: Java
Repo Size: 3.48 MB
Dependencies: 491

Created: about 8 years ago
Updated: 6 months ago
Last pushed: 6 months ago
Last synced: 6 months ago

Files

Loading...

Readme

Loading...

Dependencies

function-based-stream-app-samples/image-thumbnail-samples/image-thumbnail-stream-sample/docker-compose-apps.yml docker

demo/image-thumbnail-sink latest
springcloudstream/file-source-kafka 3.0.0-SNAPSHOT
springcloudstream/http-request-processor-kafka 3.0.0-SNAPSHOT

function-based-stream-app-samples/image-thumbnail-samples/image-thumbnail-stream-sample/docker-compose-kafka.yml docker

confluentinc/cp-kafka 5.3.1
confluentinc/cp-zookeeper 5.3.1

kafka-batch-sample/docker-compose.yml docker

wurstmeister/kafka latest
wurstmeister/zookeeper latest

kafka-streams-samples/kafka-streams-aggregate/docker-compose.yml docker

wurstmeister/kafka latest
wurstmeister/zookeeper latest

kafka-streams-samples/kafka-streams-branching/docker-compose.yml docker

wurstmeister/kafka latest
wurstmeister/zookeeper latest

kafka-streams-samples/kafka-streams-dlq-sample/docker-compose.yml docker

wurstmeister/kafka latest
wurstmeister/zookeeper latest

kafka-streams-samples/kafka-streams-global-table-join/docker-compose.yml docker

wurstmeister/kafka latest
wurstmeister/zookeeper latest

kafka-streams-samples/kafka-streams-jaas-security/docker-compose.yml docker

wurstmeister/kafka latest
wurstmeister/zookeeper latest

kafka-streams-samples/kafka-streams-message-channel/docker-compose.yml docker

wurstmeister/kafka latest
wurstmeister/zookeeper latest

kafka-streams-samples/kafka-streams-product-tracker/docker-compose.yml docker

wurstmeister/kafka latest
wurstmeister/zookeeper latest

kafka-streams-samples/kafka-streams-table-join/docker-compose.yml docker

wurstmeister/kafka latest
wurstmeister/zookeeper latest

kafka-streams-samples/kafka-streams-to-rabbitmq-message-channel/docker-compose.yml docker

rabbitmq management
wurstmeister/kafka latest
wurstmeister/zookeeper latest

kafka-streams-samples/kafka-streams-word-count/docker-compose.yml docker

wurstmeister/kafka latest
wurstmeister/zookeeper latest

multi-binder-samples/multi-binder-kafka-rabbit/docker-compose.yml docker

rabbitmq management
wurstmeister/kafka latest
wurstmeister/zookeeper latest

multi-binder-samples/multi-binder-kafka-streams/docker-compose.yml docker

wurstmeister/kafka latest
wurstmeister/zookeeper latest

multi-binder-samples/multi-binder-sendto-dest-header/docker-compose.yml docker

wurstmeister/kafka latest
wurstmeister/zookeeper latest

multi-binder-samples/multi-binder-two-kafka-clusters/docker-compose.yml docker

wurstmeister/kafka latest
wurstmeister/zookeeper latest

multi-functions-samples/function-composition-kafka/docker-compose.yml docker

wurstmeister/kafka latest
wurstmeister/zookeeper latest

multi-functions-samples/function-composition-rabbit/docker-compose.yml docker

rabbitmq management

multi-functions-samples/multi-functions-kafka/docker-compose.yml docker

wurstmeister/kafka latest
wurstmeister/zookeeper latest

multi-functions-samples/multi-functions-rabbit/docker-compose.yml docker

rabbitmq management

partitioning-samples/kafka-partitioning/docker-compose.yml docker

wurstmeister/kafka latest
wurstmeister/zookeeper latest

partitioning-samples/rabbit-partitioning/docker-compose.yml docker

rabbitmq management

transaction-kafka-samples/docker-compose.yml docker

function-based-stream-app-samples/couchbase-stream-applications/couchbase-consumer/pom.xml maven

function-based-stream-app-samples/couchbase-stream-applications/couchbase-sink/pom.xml maven

function-based-stream-app-samples/couchbase-stream-applications/pom.xml maven

org.springframework.cloud:spring-cloud-dependencies 2020.0.2 import
org.testcontainers:testcontainers-bom 1.15.1 import
com.couchbase.client:java-client 3.0.10

function-based-stream-app-samples/image-thumbnail-samples/image-thumbnail-processor/pom.xml maven

org.assertj:assertj-core 3.16.1
org.junit.jupiter:junit-jupiter 5.6.2 test
org.springframework:spring-core 5.2.8.RELEASE test

function-based-stream-app-samples/image-thumbnail-samples/image-thumbnail-stream-sample/image-thumbnail-sink/pom.xml maven

org.springframework.cloud:spring-cloud-dependencies 2020.0.2 import
io.projectreactor:reactor-test
io.spring.cloud.stream.sample:image-thumbnail-processor 0.0.1-SNAPSHOT
org.springframework.cloud.fn:file-consumer 1.0.0-SNAPSHOT
org.springframework.cloud.stream.app:stream-applications-composite-function-support 3.0.0-SNAPSHOT
org.springframework.cloud:spring-cloud-stream
org.springframework.cloud:spring-cloud-stream-binder-kafka
org.awaitility:awaitility test
org.springframework.boot:spring-boot-starter-test test
org.springframework.cloud:spring-cloud-stream test

function-based-stream-app-samples/image-thumbnail-samples/image-thumbnail-web/pom.xml maven

io.spring.cloud.stream.sample:image-thumbnail-processor 0.0.1-SNAPSHOT
org.springframework.boot:spring-boot-devtools
org.springframework.boot:spring-boot-starter-thymeleaf
org.springframework.cloud.fn:http-request-function 1.0.0-SNAPSHOT
org.springframework.boot:spring-boot-starter-test test

kafka-batch-sample/pom.xml maven

kafka-e2e-kotlin-sample/customer-service/pom.xml maven

kafka-e2e-kotlin-sample/order-service/pom.xml maven

org.springframework.cloud:spring-cloud-dependencies 2020.0.2 import
com.fasterxml.jackson.module:jackson-module-kotlin
io.confluent:kafka-avro-serializer 5.2.1
io.confluent:kafka-schema-registry-client 5.2.1
io.confluent:kafka-streams-avro-serde 5.2.1
org.apache.avro:avro 1.8.2
org.jetbrains.kotlin:kotlin-reflect
org.jetbrains.kotlin:kotlin-stdlib-jdk8
org.springframework.boot:spring-boot-starter-webflux
org.springframework.cloud:spring-cloud-starter-stream-kafka
org.springframework.cloud:spring-cloud-stream
org.springframework.cloud:spring-cloud-stream-schema 3.0.0.BUILD-SNAPSHOT
io.projectreactor:reactor-test test
org.springframework.boot:spring-boot-starter-test test
org.springframework.cloud:spring-cloud-stream-test-support test

kafka-e2e-kotlin-sample/shipping-service/pom.xml maven

kafka-native-serialization/pom.xml maven

kafka-security-samples/kafka-ssl-demo/pom.xml maven

kafka-streams-samples/kafka-streams-aggregate/pom.xml maven

kafka-streams-samples/kafka-streams-avro/pom.xml maven

org.springframework.cloud:spring-cloud-dependencies 2020.0.2 import
io.confluent:kafka-avro-serializer 5.2.0
io.confluent:kafka-streams-avro-serde 5.2.0
org.apache.avro:avro 1.8.2
org.apache.kafka:kafka-streams
org.springframework.cloud:spring-cloud-stream
org.springframework.cloud:spring-cloud-stream-binder-kafka
org.springframework.cloud:spring-cloud-stream-binder-kafka-streams 3.1.3-SNAPSHOT
org.springframework.boot:spring-boot-starter-test test
org.springframework.cloud:spring-cloud-stream test

kafka-streams-samples/kafka-streams-branching/pom.xml maven

kafka-streams-samples/kafka-streams-destination-pattern/pom.xml maven

org.springframework.cloud:spring-cloud-dependencies 2020.0.2 import
org.apache.kafka:kafka-streams
org.springframework.cloud:spring-cloud-stream
org.springframework.cloud:spring-cloud-stream-binder-kafka-streams 3.1.3-SNAPSHOT
org.springframework.boot:spring-boot-starter-test test
org.springframework.cloud:spring-cloud-stream-test-support test

kafka-streams-samples/kafka-streams-dlq-sample/pom.xml maven

kafka-streams-samples/kafka-streams-global-table-join/pom.xml maven

org.springframework.cloud:spring-cloud-dependencies 2020.0.2 import
org.springframework.boot:spring-boot-starter
org.springframework.boot:spring-boot-starter-actuator
org.springframework.boot:spring-boot-starter-web
org.springframework.cloud:spring-cloud-stream-binder-kafka-streams 3.1.3-SNAPSHOT
org.apache.kafka:kafka-streams-test-utils ${kafka.version} test
org.springframework.boot:spring-boot-starter-test test
org.springframework.kafka:spring-kafka-test test

kafka-streams-samples/kafka-streams-inventory-count/pom.xml maven

org.springframework.cloud:spring-cloud-dependencies 2020.0.2 import
org.springframework.cloud:spring-cloud-stream 3.1.3-SNAPSHOT
org.springframework.cloud:spring-cloud-stream-binder-kafka-streams 3.1.3-SNAPSHOT
org.apache.kafka:kafka-streams-test-utils 2.6.0 test
org.springframework.boot:spring-boot-starter-test test
org.springframework.kafka:spring-kafka-test test

kafka-streams-samples/kafka-streams-jaas-security/pom.xml maven

kafka-streams-samples/kafka-streams-message-channel/pom.xml maven

org.springframework.cloud:spring-cloud-dependencies 2020.0.2 import
org.springframework.boot:spring-boot-starter
org.springframework.boot:spring-boot-starter-actuator
org.springframework.boot:spring-boot-starter-web
org.springframework.cloud:spring-cloud-stream-binder-kafka
org.springframework.cloud:spring-cloud-stream-binder-kafka-streams 3.1.3-SNAPSHOT
org.apache.kafka:kafka-streams-test-utils ${kafka.version} test
org.springframework.boot:spring-boot-starter-test test
org.springframework.kafka:spring-kafka-test test

kafka-streams-samples/kafka-streams-metrics-demo/pom.xml maven

org.springframework.cloud:spring-cloud-dependencies 2020.0.2 import
io.micrometer.prometheus:prometheus-rsocket-spring 1.1.0
io.micrometer:micrometer-registry-prometheus
org.apache.kafka:kafka-streams
org.springframework.boot:spring-boot-starter-actuator
org.springframework.boot:spring-boot-starter-web
org.springframework.cloud:spring-cloud-stream 3.1.3-SNAPSHOT
org.springframework.cloud:spring-cloud-stream-binder-kafka-streams 3.1.3-SNAPSHOT
org.springframework.boot:spring-boot-starter-test test
org.springframework.cloud:spring-cloud-stream-test-support test

kafka-streams-samples/kafka-streams-multiple-input-topics/pom.xml maven

kafka-streams-samples/kafka-streams-product-tracker/pom.xml maven

org.springframework.cloud:spring-cloud-dependencies 2020.0.2 import
org.springframework.boot:spring-boot-starter
org.springframework.boot:spring-boot-starter-actuator
org.springframework.boot:spring-boot-starter-web
org.springframework.cloud:spring-cloud-stream-binder-kafka-streams 3.1.3-SNAPSHOT
org.apache.kafka:kafka-streams-test-utils ${kafka.version} test
org.springframework.boot:spring-boot-starter-test test
org.springframework.kafka:spring-kafka-test test

kafka-streams-samples/kafka-streams-table-join/pom.xml maven

org.springframework.cloud:spring-cloud-dependencies 2020.0.2 import
org.springframework.boot:spring-boot-starter
org.springframework.boot:spring-boot-starter-actuator
org.springframework.boot:spring-boot-starter-web
org.springframework.cloud:spring-cloud-stream-binder-kafka-streams 3.1.3-SNAPSHOT
org.apache.kafka:kafka-streams-test-utils ${kafka.version} test
org.springframework.boot:spring-boot-starter-test test
org.springframework.kafka:spring-kafka-test test

kafka-streams-samples/kafka-streams-to-rabbitmq-message-channel/pom.xml maven

kafka-streams-samples/kafka-streams-word-count/pom.xml maven

kinesis-samples/kinesis-produce-consume/pom.xml maven

kinesis-samples/kinesis-to-webflux/pom.xml maven

org.springframework.cloud:spring-cloud-dependencies 2020.0.2 import
org.springframework.boot:spring-boot-starter-webflux
org.springframework.cloud:spring-cloud-stream-binder-kinesis 2.0.2.BUILD-SNAPSHOT
io.projectreactor:reactor-test test
org.junit.vintage:junit-vintage-engine test
org.springframework.boot:spring-boot-starter-test test

kotlin-rabbit-functions/pom.xml maven

multi-binder-samples/kafka-multi-binder-jaas/pom.xml maven

multi-binder-samples/multi-binder-dynamic-destinations/pom.xml maven

multi-binder-samples/multi-binder-kafka-rabbit/pom.xml maven

multi-binder-samples/multi-binder-kafka-streams/pom.xml maven

multi-binder-samples/multi-binder-sendto-dest-header/pom.xml maven

multi-binder-samples/multi-binder-two-kafka-clusters/pom.xml maven

multi-functions-samples/function-composition-kafka/pom.xml maven

multi-functions-samples/function-composition-rabbit/pom.xml maven

multi-functions-samples/multi-functions-kafka/pom.xml maven

multi-functions-samples/multi-functions-rabbit/pom.xml maven

partitioning-samples/kafka-partitioning/partitioning-consumer-sample-kafka/pom.xml maven

partitioning-samples/kafka-partitioning/partitioning-producer-sample-kafka/pom.xml maven

partitioning-samples/rabbit-partitioning/partitioning-consumer-sample-rabbit/pom.xml maven

partitioning-samples/rabbit-partitioning/partitioning-producer-sample-rabbit/pom.xml maven

pom.xml maven

routing-samples/message-routing-callback/pom.xml maven

testing-samples/test-embedded-kafka/pom.xml maven

testing-samples/testing-demo/pom.xml maven

transaction-kafka-samples/transaction-http-source/pom.xml maven

transaction-kafka-samples/transaction-logger-sink/pom.xml maven

transaction-kafka-samples/transaction-spring-data-processor/pom.xml maven

batch-producer-consumer/pom.xml maven

confluent-schema-registry-integration/confluent-schema-registry-integration-consumer/pom.xml maven

confluent-schema-registry-integration/confluent-schema-registry-integration-producer1/pom.xml maven

confluent-schema-registry-integration/confluent-schema-registry-integration-producer2/pom.xml maven

confluent-schema-registry-integration/pom.xml maven

io.confluent:kafka-avro-serializer ${confluent.version}
io.confluent:kafka-schema-registry-client ${confluent.version}
org.apache.avro:avro ${avro.version}
org.springframework.boot:spring-boot-starter-web
org.springframework.cloud:spring-cloud-stream-binder-kafka

function-based-stream-app-samples/image-thumbnail-samples/pom.xml maven

function-based-stream-app-samples/pom.xml maven

kafka-binder-native-app/pom.xml maven

org.springframework.cloud:spring-cloud-stream 4.1.0-SNAPSHOT
org.springframework.cloud:spring-cloud-stream-binder-kafka 4.1.0-SNAPSHOT
org.springframework.kafka:spring-kafka
org.springframework.boot:spring-boot-starter-test test
org.springframework.cloud:spring-cloud-stream-test-binder 4.1.0-SNAPSHOT test
org.springframework.kafka:spring-kafka-test test

kafka-e2e-kotlin-sample/pom.xml maven

kafka-security-samples/pom.xml maven

kafka-streams-samples/kafka-streams-interactive-query/pom.xml maven

kafka-streams-samples/pom.xml maven

kinesis-samples/pom.xml maven

multi-binder-samples/pom.xml maven

multi-functions-samples/pom.xml maven

partitioning-samples/kafka-partitioning/pom.xml maven

partitioning-samples/pom.xml maven

partitioning-samples/rabbit-partitioning/pom.xml maven

routing-samples/pom.xml maven

spring-cloud-stream-schema-registry-integration/pom.xml maven

spring-cloud-stream-schema-registry-integration/schema-registry-consumer-kafka/pom.xml maven

spring-cloud-stream-schema-registry-integration/schema-registry-producer1-kafka/pom.xml maven

spring-cloud-stream-schema-registry-integration/schema-registry-producer2-kafka/pom.xml maven

testing-samples/pom.xml maven

transaction-kafka-samples/pom.xml maven