|
@ -32,6 +32,7 @@ public class LabelDataListener {
|
|
|
private static String mongoDb_Operator_TableName = "WLYY_OPERATOR_LOG";
|
|
|
|
|
|
//@Scheduled(cron = "0 0/1 * * * ?") //每分钟执行一次
|
|
|
//正式库的 topic名字是flumeLog
|
|
|
@KafkaListener(topics = "flumeLog1")
|
|
|
@Transactional
|
|
|
public void labelData(ConsumerRecord<?, ?> record) {
|