Advertisement
Guest User

Untitled

a guest
Aug 21st, 2019
89
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.32 KB | None | 0 0
  1. @KafkaListener(topics ="${slappy.consumer.topic}", groupId = "t1, t2, t3, t4, t5, t6, t7, t8, t9, t10")
  2. public void listenToGroup(@Payload WackyMessage message) {
  3.  
  4. log.info("Wacky Consumer with processItemId of received message: '{}'", message);
  5.  
  6. process(message, ProcessItemIdentifiers.omni_silo0_deleter);
  7. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement