Commit 42acd470 authored by 技术部-任文超's avatar 技术部-任文超

删除测试代码

parent 24fde647
...@@ -4,7 +4,6 @@ import java.util.Objects; ...@@ -4,7 +4,6 @@ import java.util.Objects;
import javax.annotation.Resource; import javax.annotation.Resource;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.ApplicationListener; import org.springframework.context.ApplicationListener;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
...@@ -20,20 +19,6 @@ import cn.quantgroup.acolyte.buddhistscriptures.ingester.UserIngest; ...@@ -20,20 +19,6 @@ import cn.quantgroup.acolyte.buddhistscriptures.ingester.UserIngest;
public class KafkaUserEventListener implements ApplicationListener<StatisticsEvent> { public class KafkaUserEventListener implements ApplicationListener<StatisticsEvent> {
@Resource @Resource
private UserIngest userIngest; private UserIngest userIngest;
@Value("${kafka.connect}")
private String kafka_connect;
@Value("${batch.size}")
private int batch_size;
@Value("${linger.ms}")
private int linger_ms;
@Value("${reconnect.backoff.ms}")
private int reconnect_backoff_ms;
@Value("${retry.backoff.ms}")
private int retry_backoff_ms;
@Value("${buffer.memory}")
private int buffer_memory;
@Value("${max.block.ms}")
private int max_block_ms;
@Override @Override
public void onApplicationEvent(StatisticsEvent event) { public void onApplicationEvent(StatisticsEvent event) {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment