File tree Expand file tree Collapse file tree 2 files changed +3
-6
lines changed
chat_server/src/main/java/com/jootalkpia/chat_server/service
state_server/src/main/java/com/jootalkpia/state_server/service Expand file tree Collapse file tree 2 files changed +3
-6
lines changed Original file line number Diff line number Diff line change @@ -40,8 +40,7 @@ public void processMinutePrice(String kafkaMessage) {
4040
4141 @ KafkaListener (
4242 topics = "${topic.chat}" ,
43- groupId = "${group.chat}" ,
44- concurrency = "3"
43+ groupId = "${group.chat}"
4544 )
4645 public void processChatMessage (@ Header (KafkaHeaders .RECEIVED_KEY ) String channelId , String kafkaMessage ) {
4746 try {
@@ -56,8 +55,7 @@ public void processChatMessage(@Header(KafkaHeaders.RECEIVED_KEY) String channel
5655
5756 @ KafkaListener (
5857 topics = "${topic.push}" ,
59- groupId = "${group.push}" ,
60- concurrency = "8"
58+ groupId = "${group.push}"
6159 )
6260 public void processPushMessage (String kafkaMessage ) {
6361 try {
Original file line number Diff line number Diff line change @@ -21,8 +21,7 @@ public class KafkaConsumer {
2121
2222 @ KafkaListener (
2323 topics = "${topic.chat}" ,
24- groupId = "${group.status}" ,
25- concurrency = "3"
24+ groupId = "${group.status}"
2625 )
2726 public void processState (String kafkaMessage ) {
2827 ObjectMapper mapper = new ObjectMapper ();
You can’t perform that action at this time.
0 commit comments