| File was renamed from screen-api/src/main/java/com/moral/api/kafka/consumer/SecondsDataConsumer.java |
| | |
|---|
| | | * @Version TODO |
|---|
| | | **/ |
|---|
| | | //@Component |
|---|
| | | public class SecondsDataConsumer implements ConsumerSeekAware { |
|---|
| | | public class SecondDataConsumer implements ConsumerSeekAware { |
|---|
| | | |
|---|
| | | @KafkaListener(topics = "test",groupId = "SecondsDataGroup3") |
|---|
| | | @KafkaListener(topics = "second_data",groupId = "SecondsDataGroup3") |
|---|
| | | public void listen(ConsumerRecord<String, String> record , Consumer consumer) throws Exception { |
|---|
| | | String messageStr = record.value(); |
|---|
| | | Map<String,String> message = (Map<String,String>)JSON.parse(messageStr); |
|---|
