Incorporated review comments on the pull request.

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

View File

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

View File

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