|
@ -16,7 +16,7 @@ public class ConsumerListener {
|
|
|
@KafkaListener(topics = "sep-hbase-data")
|
|
|
public void loadData(ConsumerRecord<?, ?> record) {
|
|
|
if(record.value() != null){
|
|
|
System.out.println("消息:" + record.value().toString());
|
|
|
// System.out.println("消息:" + record.value().toString());
|
|
|
elasticSearchDataProcessService.saveData(record.value().toString());
|
|
|
}
|
|
|
}
|