f8c5cf942c
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
== What is this app? This is an example of a Spring Cloud Stream processor using Kafka Streams support. The example is based on the word count application from the https://github.com/confluentinc/examples/blob/3.2.x/kafka-streams/src/main/java/io/confluent/examples/streams/WordCountLambdaExample.java[reference documentation]. The application has two inputs one as a KStream and another one with the binding for a message channel. === Running the app: Go to the root of the repository and do: `docker-compose up -d` `./mvnw clean package` `java -jar target/kafka-streams-message-channel-0.0.1-SNAPSHOT.jar --spring.cloud.stream.kafka.streams.timeWindow.length=60000` Issue the following commands: `docker exec -it kafka-mc /opt/kafka/bin/kafka-console-producer.sh --broker-list 127.0.0.1:9092 --topic words` On another terminal: `docker exec -it kafka-mc /opt/kafka/bin/kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092 --topic counts` Enter some text in the console producer and watch the output in the console consumer. Also watch the console for logging statements from the regular sink StreamListener method. The default time window is configured for 5 seconds and you can change that using the following property. `spring.cloud.stream.kafka.streams.timeWindow.length` (value is expressed in milliseconds) In order to switch to a hopping window, you can use the `spring.cloud.stream.kafka.streams.timeWindow.advanceBy` (value in milliseconds). This will create an overlapped hopping windows depending on the value you provide. Here is an example with 2 overlapping windows (window length of 10 seconds and a hop (advance) by 5 seconds: `java -jar target/kafka-streams-message-channel-0.0.1-SNAPSHOT.jar --spring.cloud.stream.kafka.streams.timeWindow.length=10000 --spring.cloud.stream.kafka.streams.timeWindow.advanceBy=5000`