|
@@ -1,7 +1,9 @@
|
|
|
package kafkademo.kafka.listener;
|
|
|
|
|
|
import org.springframework.kafka.annotation.KafkaListener;
|
|
|
+import org.springframework.stereotype.Component;
|
|
|
|
|
|
+@Component
|
|
|
public class SingleListener {
|
|
|
|
|
|
@KafkaListener(topics = "one-exchange", groupId = "group-id")
|