diff --git a/kafka-streams-samples/kafka-streams-interactive-query-advanced/src/main/java/kafka/streams/interactive/query/KafkaStreamsInteractiveQuerySample.java b/kafka-streams-samples/kafka-streams-interactive-query-advanced/src/main/java/kafka/streams/interactive/query/KafkaStreamsInteractiveQuerySample.java index 91885b5..0eefe17 100644 --- a/kafka-streams-samples/kafka-streams-interactive-query-advanced/src/main/java/kafka/streams/interactive/query/KafkaStreamsInteractiveQuerySample.java +++ b/kafka-streams-samples/kafka-streams-interactive-query-advanced/src/main/java/kafka/streams/interactive/query/KafkaStreamsInteractiveQuerySample.java @@ -200,7 +200,7 @@ public class KafkaStreamsInteractiveQuerySample { logger.info("Top Five songs request served from different host: " + hostInfo); RestTemplate restTemplate = new RestTemplate(); return restTemplate.postForObject( - String.format("http://%s:%d/%s", hostInfo.host(), + String.format("https://%s:%d/%s", hostInfo.host(), hostInfo.port(), "charts/top-five?genre=Punk"), "punk", List.class); } } @@ -235,7 +235,7 @@ public class KafkaStreamsInteractiveQuerySample { logger.info("Song info request served from different host: " + hostInfo); RestTemplate restTemplate = new RestTemplate(); SongBean song = restTemplate.postForObject( - String.format("http://%s:%d/%s", hostInfo.host(), + String.format("https://%s:%d/%s", hostInfo.host(), hostInfo.port(), "song/idx?id=" + songPlayCount.getSongId()), "id", SongBean.class); results.add(new SongPlayCountBean(song.getArtist(),song.getAlbum(), song.getName(), songPlayCount.getPlays())); diff --git a/processor-samples/polled-consumer/README.md b/processor-samples/polled-consumer/README.md index d987fd3..c15f5b6 100644 --- a/processor-samples/polled-consumer/README.md +++ b/processor-samples/polled-consumer/README.md @@ -18,7 +18,7 @@ It uses a Polled Consumer (rather than a message-driven `@StreamListener`). * PolledConsumerApplicationTests - the test case The `spring-kafka-test` dependency added to the `pom.xml` puts the `KafkaEmbedded` JUnit `@Rule` on the class path. -Refer to the [Spring for Apache Kafka Reference Manual](http://docs.spring.io/spring-kafka/reference/htmlsingle/#testing) for more information about this. +Refer to the [Spring for Apache Kafka Reference Manual](https://docs.spring.io/spring-kafka/reference/htmlsingle/#testing) for more information about this. Notice how the `@BeforeClass` method sets up the Boot and binder properties to locate the servers. See the test method for the details on interacting with Embedded Kafka. diff --git a/testing-samples/test-embedded-kafka/README.adoc b/testing-samples/test-embedded-kafka/README.adoc index a49727d..62b9b29 100644 --- a/testing-samples/test-embedded-kafka/README.adoc +++ b/testing-samples/test-embedded-kafka/README.adoc @@ -17,7 +17,7 @@ This sample is a Spring Boot application that uses Spring Cloud Stream to receiv * EmbeddedKafkaApplicationTests - the test case The `spring-kafka-test` dependency added to the `pom.xml` puts the `KafkaEmbedded` JUnit `@Rule` on the class path. -Refer to the [Spring for Apache Kafka Reference Manual](http://docs.spring.io/spring-kafka/reference/htmlsingle/#testing) for more information about this. +Refer to the [Spring for Apache Kafka Reference Manual](https://docs.spring.io/spring-kafka/reference/htmlsingle/#testing) for more information about this. Notice how the `@BeforeClass` method sets up the Boot and binder properties to locate the servers. See the test method for the details on interacting with Embedded Kafka.