| | |
|---|
| | | package com.moral.api.kafka.consumer; |
|---|
| | | |
|---|
| | | import com.moral.api.constant.TopicConstants; |
|---|
| | | import lombok.extern.slf4j.Slf4j; |
|---|
| | | import org.apache.kafka.clients.consumer.ConsumerRecord; |
|---|
| | | import org.springframework.kafka.annotation.KafkaListener; |
|---|
| | | import org.springframework.kafka.support.Acknowledgment; |
|---|
| | | import org.springframework.stereotype.Component; |
|---|
| | | |
|---|
| | | import java.util.Random; |
|---|
| | | |
|---|
| | | @Component |
|---|
| | | @Slf4j |
|---|
| | |
|---|
| | | log.info(String.format("kafka 消费消息成功---------------- listen1 topic = %s, offset = %d, value = %s ", record.topic(), record.offset(), record.value())); |
|---|
| | | ack.acknowledge(); |
|---|
| | | } |
|---|
| | | |
|---|
| | | }*/ |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | } |
|---|
