added custom response

.gitignore

+target/
+!.mvn/wrapper/maven-wrapper.jar
+!**/src/main/**/target/
+!**/src/test/**/target/
+
+### IntelliJ IDEA ###
+.idea/modules.xml
+.idea/jarRepositories.xml
+.idea/compiler.xml
+.idea/libraries/
+*.iws
+*.iml
+*.ipr
+
+### Eclipse ###
+.apt_generated
+.classpath
+.factorypath
+.project
+.settings
+.springBeans
+.sts4-cache
+
+### NetBeans ###
+/nbproject/private/
+/nbbuild/
+/dist/
+/nbdist/
+/.nb-gradle/
+build/
+!**/src/main/**/build/
+!**/src/test/**/build/
+
+### VS Code ###
+.vscode/
+
+### Mac OS ###
+.DS_Store
\ No newline at end of file

src/main/java/com/example/kafka/controller/DepartmentController.java

@@ -70,15 +70,25 @@ public class DepartmentController {
     }
 
     @GetMapping("/fetchAll/{departmentId}")
-    public Mono<UserResponse> getDepartmentAndUsersById(@PathVariable String departmentId){
+    public Mono<UserResponse> getMonoDepartmentAndUsersById(@PathVariable String departmentId){
         Mono<Department> department = departmentService.findById(departmentId);
-        return department.flatMap(d-> userService.fetchUserByDepartmentName("d.getName()").collectList().map(users->{
+        return department.flatMap(d-> userService.fetchUserByDepartmentName(d.getName()).collectList().map(users->{
             UserResponse userResponse = new UserResponse();
             userResponse.setUserList(users);
             return userResponse;
         }));
     }
 
+    @GetMapping("/fetchAll")
+    public Flux<UserResponse> getFluxDepartmentAndUsersById(@RequestParam(value = "departmentId") String departmentId){
+        Mono<Department> department = departmentService.findById(departmentId);
+        return department.flatMapMany(d-> userService.fetchUserByDepartmentName(d.getName()).map(user -> {
+            UserResponse userResponse = new UserResponse();
+            userResponse.setUser(user);
+            return userResponse;
+        }));
+    }
+
 }
 
 

src/main/java/com/example/kafka/entity/UserResponse.java

 package com.example.kafka.entity;
 
+import com.fasterxml.jackson.annotation.JsonInclude;
 import lombok.AllArgsConstructor;
 import lombok.Data;
 import lombok.NoArgsConstructor;
@@ -11,15 +12,8 @@ import java.util.List;
 @AllArgsConstructor
 @NoArgsConstructor
 @ToString
+@JsonInclude(JsonInclude.Include.NON_NULL)
 public class UserResponse {
-
-    /**
-     * User id
-     */
-    private String id;
-
-    /**
-     * User name
-     */
     private List<User> userList;
+    private User user;
 }