Incorporated review comments on the pull request.

This commit is contained in:
CHANDRAKANT Kumar
2020-08-14 12:46:33 +05:30
parent 99ddab1f5e
commit bad4b717d7
3 changed files with 5 additions and 9 deletions

View File

@@ -7,7 +7,7 @@
<version>1.0.0-SNAPSHOT</version>
<name>spring-webflux-threads</name>
<packaging>jar</packaging>
<description>Spring WebFlux AMQP Sample</description>
<description>Spring WebFlux Threads Sample</description>
<parent>
<groupId>com.baeldung</groupId>
@@ -20,6 +20,7 @@
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-webflux</artifactId>
<!-- Uncomment the following to switch from Netty to Tomcat/Jetty -->
<!--
<exclusions>
<exclusion>
@@ -29,12 +30,14 @@
</exclusions>
-->
</dependency>
<!-- Uncomment the following to switch from Netty to Tomcat -->
<!--
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-tomcat</artifactId>
</dependency>
-->
<!-- Uncomment the following to switch from Netty to Jetty -->
<!--
<dependency>
<groupId>org.springframework.boot</groupId>

View File

@@ -81,7 +81,7 @@ public class Controller {
return Flux.fromIterable(getThreads());
}
@GetMapping("/thareds/reactor-kafka")
@GetMapping("/threads/reactor-kafka")
public Flux<String> getIndexKafka() {
Map<String, Object> producerProps = new HashMap<>();
producerProps.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");