moral.git - Gitblit

summary
reflog
commits
tree
tickets
docs
forks
compare

jinpengyong

2023-08-17 433b18fddbdb38f0c2a0a2358bc74fe46e10c9ba

 screen-api/src/main/java/com/moral/api/exception/consumer/CruiserDataConsumer.java

@@ -31,9 +31,9 @@
 * 走航车数据消费者
 * */

//@Component
@Component
@Slf4j
public class CruiserDataConsumer implements ConsumerSeekAware {
public class CruiserDataConsumer  implements ConsumerSeekAware {

    @KafkaListener(topics = KafkaConstants.CRUISER_TOPIC_SECOND, containerFactory = "cruiserDataListenerFactory")
    public void listenSecondSpecial(ConsumerRecord<String, String> record) throws Exception {

			@@ -31,9 +31,9 @@
			* 走航车数据消费者
			* */

			//@Component
			@Component
			@Slf4j
			public class CruiserDataConsumer implements ConsumerSeekAware {
			public class CruiserDataConsumer implements ConsumerSeekAware {

			@KafkaListener(topics = KafkaConstants.CRUISER_TOPIC_SECOND, containerFactory = "cruiserDataListenerFactory")
			public void listenSecondSpecial(ConsumerRecord<String, String> record) throws Exception {