Commit b8847239 authored by Sarika Sama's avatar Sarika Sama

initial commits

parents e70dd459 394fa93b
...@@ -21,10 +21,7 @@ public class UserService { ...@@ -21,10 +21,7 @@ public class UserService {
@Autowired @Autowired
private UserRepository userRepository; private UserRepository userRepository;
// public Flux<User> getUsers(){
//
// return userRepository.findAll();
// }
@Autowired @Autowired
private KafkaProducer kafkaProducer; private KafkaProducer kafkaProducer;
...@@ -32,6 +29,12 @@ private KafkaProducer kafkaProducer; ...@@ -32,6 +29,12 @@ private KafkaProducer kafkaProducer;
@Value("${order_topic}") @Value("${order_topic}")
private String topicName; private String topicName;
// public Flux<User> getUsers(){
//
// return userRepository.findAll();
// }
public Flux<User> fetchUsersAndPublish(){ public Flux<User> fetchUsersAndPublish(){
Flux<User> users = userRepository.findAll(); Flux<User> users = userRepository.findAll();
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment