spring-cloud-stream-samples

Files

Spring Operator 0f8c257ed7 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 91 occurrences migrated to:
  https://www.apache.org/licenses/LICENSE-2.0 ([https](https://www.apache.org/licenses/LICENSE-2.0) result 200).

2019-04-24 12:53:07 -04:00

.mvn/wrapper

Refactoring samples

2018-03-09 10:47:22 -05:00

src

URL Cleanup

2019-04-24 12:53:07 -04:00

.gitignore

Refactoring samples

2018-03-09 10:47:22 -05:00

docker-compose.yml

Refactoring samples

2018-03-09 10:47:22 -05:00

mvnw

Refactoring samples

2018-03-09 10:47:22 -05:00

mvnw.cmd

Refactoring samples

2018-03-09 10:47:22 -05:00

pom.xml

URL Cleanup

2019-04-24 12:51:53 -04:00

README.adoc

Refactoring samples

2018-03-09 10:47:22 -05:00

README.adoc

== What is this app?

This is an example of a Spring Cloud Stream processor using Kafka Streams support.

This example is a Spring Cloud Stream adaptation of this Kafka Streams sample: https://github.com/confluentinc/kafka-streams-examples/blob/4.0.0-post/src/test/java/io/confluent/examples/streams/StreamToTableJoinIntegrationTest.java

The application uses two inputs - one KStream for user-clicks and a KTable for user-regions.
Then it joins the information from stream to table to find out total clicks per region.

=== Running the app:

Go to the root of the repository.

`docker-compose up -d`

`./mvnw clean package`

`java -jar target/kafka-streams-table-join-0.0.1-SNAPSHOT.jar`

`docker exec -it kafka-join /opt/kafka/bin/kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092 --topic output-topic --key-deserializer org.apache.kafka.common.serialization.StringDeserializer --value-deserializer org.apache.kafka.common.serialization.LongDeserializer --property print.key=true --property key.separator="-"`

Run the stand-alone `Producers` application to generate some data and watch the output on the console consumer above.