test

bak.log

@@ -1,9 +1,224 @@
-2022-02-20 13:01:33.604  INFO 19200 --- [main] c.n.e.l.LogTrackingApplication           : Starting LogTrackingApplication v0.1.0 using Java 1.8.0_261 on WIN-EQ1CCM5V0NR with PID 19200 (D:\SEEC\SEEC-LogTracking\seecoder-logTracking-server\target\app.jar started by Administrator in D:\SEEC\SEEC-LogTracking)
-2022-02-20 13:01:33.606  INFO 19200 --- [main] c.n.e.l.LogTrackingApplication           : No active profile set, falling back to default profiles: default
-2022-02-20 13:01:34.690  INFO 19200 --- [main] o.s.b.w.embedded.tomcat.TomcatWebServer  : Tomcat initialized with port(s): 8080 (http)
-2022-02-20 13:01:34.702  INFO 19200 --- [main] o.apache.catalina.core.StandardService   : Starting service [Tomcat]
-2022-02-20 13:01:34.703  INFO 19200 --- [main] org.apache.catalina.core.StandardEngine  : Starting Servlet engine: [Apache Tomcat/9.0.56]
-2022-02-20 13:01:34.754  INFO 19200 --- [main] o.a.c.c.C.[Tomcat].[localhost].[/]       : Initializing Spring embedded WebApplicationContext
-2022-02-20 13:01:34.755  INFO 19200 --- [main] w.s.c.ServletWebServerApplicationContext : Root WebApplicationContext: initialization completed in 1113 ms
-2022-02-20 13:01:35.034  INFO 19200 --- [main] o.s.b.w.embedded.tomcat.TomcatWebServer  : Tomcat started on port(s): 8080 (http) with context path ''
-2022-02-20 13:01:35.042  INFO 19200 --- [main] c.n.e.l.LogTrackingApplication           : Started LogTrackingApplication in 1.824 seconds (JVM running for 2.181)
+2022-02-21 15:36:37.358  INFO 22236 --- [main] c.n.e.l.LogTrackingApplication           : Starting LogTrackingApplication using Java 1.8.0_261 on WIN-EQ1CCM5V0NR with PID 22236 (D:\SEEC\SEEC-LogTracking\seecoder-logTracking-server\target\classes started by Administrator in D:\SEEC\SEEC-LogTracking)
+2022-02-21 15:36:37.368  INFO 22236 --- [main] c.n.e.l.LogTrackingApplication           : No active profile set, falling back to default profiles: default
+2022-02-21 15:36:38.280  INFO 22236 --- [main] o.s.b.w.embedded.tomcat.TomcatWebServer  : Tomcat initialized with port(s): 8080 (http)
+2022-02-21 15:36:38.289  INFO 22236 --- [main] o.apache.catalina.core.StandardService   : Starting service [Tomcat]
+2022-02-21 15:36:38.290  INFO 22236 --- [main] org.apache.catalina.core.StandardEngine  : Starting Servlet engine: [Apache Tomcat/9.0.56]
+2022-02-21 15:36:38.371  INFO 22236 --- [main] o.a.c.c.C.[Tomcat].[localhost].[/]       : Initializing Spring embedded WebApplicationContext
+2022-02-21 15:36:38.371  INFO 22236 --- [main] w.s.c.ServletWebServerApplicationContext : Root WebApplicationContext: initialization completed in 938 ms
+2022-02-21 15:36:38.799  INFO 22236 --- [main] o.s.b.w.embedded.tomcat.TomcatWebServer  : Tomcat started on port(s): 8080 (http) with context path ''
+2022-02-21 15:36:38.814  INFO 22236 --- [main] c.n.e.l.LogTrackingApplication           : Started LogTrackingApplication in 1.982 seconds (JVM running for 3.12)
+2022-02-21 15:38:56.556  INFO 7052 --- [main] c.n.e.l.LogTrackingApplication           : Starting LogTrackingApplication using Java 1.8.0_261 on WIN-EQ1CCM5V0NR with PID 7052 (D:\SEEC\SEEC-LogTracking\seecoder-logTracking-server\target\classes started by Administrator in D:\SEEC\SEEC-LogTracking)
+2022-02-21 15:38:56.559  INFO 7052 --- [main] c.n.e.l.LogTrackingApplication           : No active profile set, falling back to default profiles: default
+2022-02-21 15:38:57.169  INFO 7052 --- [main] o.s.b.w.embedded.tomcat.TomcatWebServer  : Tomcat initialized with port(s): 8080 (http)
+2022-02-21 15:38:57.176  INFO 7052 --- [main] o.apache.catalina.core.StandardService   : Starting service [Tomcat]
+2022-02-21 15:38:57.176  INFO 7052 --- [main] org.apache.catalina.core.StandardEngine  : Starting Servlet engine: [Apache Tomcat/9.0.56]
+2022-02-21 15:38:57.231  INFO 7052 --- [main] o.a.c.c.C.[Tomcat].[localhost].[/]       : Initializing Spring embedded WebApplicationContext
+2022-02-21 15:38:57.231  INFO 7052 --- [main] w.s.c.ServletWebServerApplicationContext : Root WebApplicationContext: initialization completed in 642 ms
+2022-02-21 15:38:57.473  INFO 7052 --- [main] o.s.b.w.embedded.tomcat.TomcatWebServer  : Tomcat started on port(s): 8080 (http) with context path ''
+2022-02-21 15:38:57.479  INFO 7052 --- [main] c.n.e.l.LogTrackingApplication           : Started LogTrackingApplication in 1.249 seconds (JVM running for 2.054)
+2022-02-21 15:40:16.219  INFO 15668 --- [main] c.n.e.l.LogTrackingApplication           : Starting LogTrackingApplication using Java 1.8.0_261 on WIN-EQ1CCM5V0NR with PID 15668 (D:\SEEC\SEEC-LogTracking\seecoder-logTracking-server\target\classes started by Administrator in D:\SEEC\SEEC-LogTracking)
+2022-02-21 15:40:16.221  INFO 15668 --- [main] c.n.e.l.LogTrackingApplication           : No active profile set, falling back to default profiles: default
+2022-02-21 15:40:16.887  INFO 15668 --- [main] o.s.b.w.embedded.tomcat.TomcatWebServer  : Tomcat initialized with port(s): 8080 (http)
+2022-02-21 15:40:16.900  INFO 15668 --- [main] o.apache.catalina.core.StandardService   : Starting service [Tomcat]
+2022-02-21 15:40:16.901  INFO 15668 --- [main] org.apache.catalina.core.StandardEngine  : Starting Servlet engine: [Apache Tomcat/9.0.56]
+2022-02-21 15:40:16.968  INFO 15668 --- [main] o.a.c.c.C.[Tomcat].[localhost].[/]       : Initializing Spring embedded WebApplicationContext
+2022-02-21 15:40:16.969  INFO 15668 --- [main] w.s.c.ServletWebServerApplicationContext : Root WebApplicationContext: initialization completed in 714 ms
+2022-02-21 15:40:17.278  INFO 15668 --- [main] o.s.b.w.embedded.tomcat.TomcatWebServer  : Tomcat started on port(s): 8080 (http) with context path ''
+2022-02-21 15:40:17.287  INFO 15668 --- [main] c.n.e.l.LogTrackingApplication           : Started LogTrackingApplication in 1.453 seconds (JVM running for 2.744)
+2022-02-21 15:41:14.594  INFO 18784 --- [main] c.n.e.l.LogTrackingApplication           : Starting LogTrackingApplication using Java 1.8.0_261 on WIN-EQ1CCM5V0NR with PID 18784 (D:\SEEC\SEEC-LogTracking\seecoder-logTracking-server\target\classes started by Administrator in D:\SEEC\SEEC-LogTracking)
+2022-02-21 15:41:14.596  INFO 18784 --- [main] c.n.e.l.LogTrackingApplication           : No active profile set, falling back to default profiles: default
+2022-02-21 15:41:15.222  INFO 18784 --- [main] o.s.b.w.embedded.tomcat.TomcatWebServer  : Tomcat initialized with port(s): 8080 (http)
+2022-02-21 15:41:15.228  INFO 18784 --- [main] o.apache.catalina.core.StandardService   : Starting service [Tomcat]
+2022-02-21 15:41:15.228  INFO 18784 --- [main] org.apache.catalina.core.StandardEngine  : Starting Servlet engine: [Apache Tomcat/9.0.56]
+2022-02-21 15:41:15.281  INFO 18784 --- [main] o.a.c.c.C.[Tomcat].[localhost].[/]       : Initializing Spring embedded WebApplicationContext
+2022-02-21 15:41:15.281  INFO 18784 --- [main] w.s.c.ServletWebServerApplicationContext : Root WebApplicationContext: initialization completed in 652 ms
+2022-02-21 15:41:15.533  INFO 18784 --- [main] o.s.b.w.embedded.tomcat.TomcatWebServer  : Tomcat started on port(s): 8080 (http) with context path ''
+2022-02-21 15:41:15.540  INFO 18784 --- [main] c.n.e.l.LogTrackingApplication           : Started LogTrackingApplication in 1.323 seconds (JVM running for 2.234)
+2022-02-21 15:41:18.856  INFO 18784 --- [http-nio-8080-exec-2] o.a.c.c.C.[Tomcat].[localhost].[/]       : Initializing Spring DispatcherServlet 'dispatcherServlet'
+2022-02-21 15:41:18.856  INFO 18784 --- [http-nio-8080-exec-2] o.s.web.servlet.DispatcherServlet        : Initializing Servlet 'dispatcherServlet'
+2022-02-21 15:41:18.857  INFO 18784 --- [http-nio-8080-exec-2] o.s.web.servlet.DispatcherServlet        : Completed initialization in 1 ms
+2022-02-21 15:41:18.937  INFO 18784 --- [http-nio-8080-exec-2] o.a.k.clients.producer.ProducerConfig    : ProducerConfig values: 
+	acks = -1
+	batch.size = 16384
+	bootstrap.servers = [localhost:9092]
+	buffer.memory = 33554432
+	client.dns.lookup = use_all_dns_ips
+	client.id = producer-1
+	compression.type = none
+	connections.max.idle.ms = 540000
+	delivery.timeout.ms = 120000
+	enable.idempotence = true
+	interceptor.classes = []
+	key.serializer = class org.apache.kafka.common.serialization.StringSerializer
+	linger.ms = 5
+	max.block.ms = 60000
+	max.in.flight.requests.per.connection = 5
+	max.request.size = 1048576
+	metadata.max.age.ms = 300000
+	metadata.max.idle.ms = 300000
+	metric.reporters = []
+	metrics.num.samples = 2
+	metrics.recording.level = INFO
+	metrics.sample.window.ms = 30000
+	partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner
+	receive.buffer.bytes = 32768
+	reconnect.backoff.max.ms = 1000
+	reconnect.backoff.ms = 50
+	request.timeout.ms = 5000
+	retries = 3
+	retry.backoff.ms = 100
+	sasl.client.callback.handler.class = null
+	sasl.jaas.config = null
+	sasl.kerberos.kinit.cmd = /usr/bin/kinit
+	sasl.kerberos.min.time.before.relogin = 60000
+	sasl.kerberos.service.name = null
+	sasl.kerberos.ticket.renew.jitter = 0.05
+	sasl.kerberos.ticket.renew.window.factor = 0.8
+	sasl.login.callback.handler.class = null
+	sasl.login.class = null
+	sasl.login.refresh.buffer.seconds = 300
+	sasl.login.refresh.min.period.seconds = 60
+	sasl.login.refresh.window.factor = 0.8
+	sasl.login.refresh.window.jitter = 0.05
+	sasl.mechanism = GSSAPI
+	security.protocol = PLAINTEXT
+	security.providers = null
+	send.buffer.bytes = 131072
+	socket.connection.setup.timeout.max.ms = 30000
+	socket.connection.setup.timeout.ms = 10000
+	ssl.cipher.suites = null
+	ssl.enabled.protocols = [TLSv1.2]
+	ssl.endpoint.identification.algorithm = https
+	ssl.engine.factory.class = null
+	ssl.key.password = null
+	ssl.keymanager.algorithm = SunX509
+	ssl.keystore.certificate.chain = null
+	ssl.keystore.key = null
+	ssl.keystore.location = null
+	ssl.keystore.password = null
+	ssl.keystore.type = JKS
+	ssl.protocol = TLSv1.2
+	ssl.provider = null
+	ssl.secure.random.implementation = null
+	ssl.trustmanager.algorithm = PKIX
+	ssl.truststore.certificates = null
+	ssl.truststore.location = null
+	ssl.truststore.password = null
+	ssl.truststore.type = JKS
+	transaction.timeout.ms = 60000
+	transactional.id = null
+	value.serializer = class org.apache.kafka.common.serialization.StringSerializer
+
+2022-02-21 15:41:18.979  INFO 18784 --- [http-nio-8080-exec-2] o.a.kafka.common.utils.AppInfoParser     : Kafka version: 3.0.0
+2022-02-21 15:41:18.980  INFO 18784 --- [http-nio-8080-exec-2] o.a.kafka.common.utils.AppInfoParser     : Kafka commitId: 8cb0a5e9d3441962
+2022-02-21 15:41:18.980  INFO 18784 --- [http-nio-8080-exec-2] o.a.kafka.common.utils.AppInfoParser     : Kafka startTimeMs: 1645429278977
+2022-02-21 15:41:19.248  INFO 18784 --- [kafka-producer-network-thread | producer-1] org.apache.kafka.clients.Metadata        : [Producer clientId=producer-1] Cluster ID: HsvqBxodQiORFIomGwKWDQ
+2022-02-21 15:41:19.258  INFO 18784 --- [http-nio-8080-exec-2] c.n.e.l.s.impl.LogTrackingServiceImpl    : aaa
+2022-02-21 15:42:15.185  INFO 20804 --- [main] c.n.e.l.LogTrackingApplication           : Starting LogTrackingApplication using Java 1.8.0_261 on WIN-EQ1CCM5V0NR with PID 20804 (D:\SEEC\SEEC-LogTracking\seecoder-logTracking-server\target\classes started by Administrator in D:\SEEC\SEEC-LogTracking)
+2022-02-21 15:42:15.187  INFO 20804 --- [main] c.n.e.l.LogTrackingApplication           : No active profile set, falling back to default profiles: default
+2022-02-21 15:42:15.763  INFO 20804 --- [main] o.s.b.w.embedded.tomcat.TomcatWebServer  : Tomcat initialized with port(s): 8080 (http)
+2022-02-21 15:42:15.769  INFO 20804 --- [main] o.apache.catalina.core.StandardService   : Starting service [Tomcat]
+2022-02-21 15:42:15.770  INFO 20804 --- [main] org.apache.catalina.core.StandardEngine  : Starting Servlet engine: [Apache Tomcat/9.0.56]
+2022-02-21 15:42:15.821  INFO 20804 --- [main] o.a.c.c.C.[Tomcat].[localhost].[/]       : Initializing Spring embedded WebApplicationContext
+2022-02-21 15:42:15.821  INFO 20804 --- [main] w.s.c.ServletWebServerApplicationContext : Root WebApplicationContext: initialization completed in 605 ms
+2022-02-21 15:42:16.047  INFO 20804 --- [main] o.s.b.w.embedded.tomcat.TomcatWebServer  : Tomcat started on port(s): 8080 (http) with context path ''
+2022-02-21 15:42:16.053  INFO 20804 --- [main] c.n.e.l.LogTrackingApplication           : Started LogTrackingApplication in 1.23 seconds (JVM running for 2.145)
+2022-02-21 15:44:28.674  INFO 18456 --- [main] c.n.e.l.LogTrackingApplication           : Starting LogTrackingApplication using Java 1.8.0_261 on WIN-EQ1CCM5V0NR with PID 18456 (D:\SEEC\SEEC-LogTracking\seecoder-logTracking-server\target\classes started by Administrator in D:\SEEC\SEEC-LogTracking)
+2022-02-21 15:44:28.676  INFO 18456 --- [main] c.n.e.l.LogTrackingApplication           : No active profile set, falling back to default profiles: default
+2022-02-21 15:44:29.330  INFO 18456 --- [main] o.s.b.w.embedded.tomcat.TomcatWebServer  : Tomcat initialized with port(s): 8080 (http)
+2022-02-21 15:44:29.336  INFO 18456 --- [main] o.apache.catalina.core.StandardService   : Starting service [Tomcat]
+2022-02-21 15:44:29.336  INFO 18456 --- [main] org.apache.catalina.core.StandardEngine  : Starting Servlet engine: [Apache Tomcat/9.0.56]
+2022-02-21 15:44:29.387  INFO 18456 --- [main] o.a.c.c.C.[Tomcat].[localhost].[/]       : Initializing Spring embedded WebApplicationContext
+2022-02-21 15:44:29.387  INFO 18456 --- [main] w.s.c.ServletWebServerApplicationContext : Root WebApplicationContext: initialization completed in 673 ms
+2022-02-21 15:44:29.607  INFO 18456 --- [main] o.s.b.w.embedded.tomcat.TomcatWebServer  : Tomcat started on port(s): 8080 (http) with context path ''
+2022-02-21 15:44:29.613  INFO 18456 --- [main] c.n.e.l.LogTrackingApplication           : Started LogTrackingApplication in 1.296 seconds (JVM running for 2.175)
+2022-02-21 15:44:32.335  INFO 18456 --- [http-nio-8080-exec-2] o.a.c.c.C.[Tomcat].[localhost].[/]       : Initializing Spring DispatcherServlet 'dispatcherServlet'
+2022-02-21 15:44:32.336  INFO 18456 --- [http-nio-8080-exec-2] o.s.web.servlet.DispatcherServlet        : Initializing Servlet 'dispatcherServlet'
+2022-02-21 15:44:32.336  INFO 18456 --- [http-nio-8080-exec-2] o.s.web.servlet.DispatcherServlet        : Completed initialization in 0 ms
+2022-02-21 15:44:32.410  INFO 18456 --- [http-nio-8080-exec-2] o.a.k.clients.producer.ProducerConfig    : ProducerConfig values: 
+	acks = -1
+	batch.size = 16384
+	bootstrap.servers = [localhost:9092]
+	buffer.memory = 33554432
+	client.dns.lookup = use_all_dns_ips
+	client.id = producer-1
+	compression.type = none
+	connections.max.idle.ms = 540000
+	delivery.timeout.ms = 120000
+	enable.idempotence = true
+	interceptor.classes = []
+	key.serializer = class org.apache.kafka.common.serialization.StringSerializer
+	linger.ms = 5
+	max.block.ms = 60000
+	max.in.flight.requests.per.connection = 5
+	max.request.size = 1048576
+	metadata.max.age.ms = 300000
+	metadata.max.idle.ms = 300000
+	metric.reporters = []
+	metrics.num.samples = 2
+	metrics.recording.level = INFO
+	metrics.sample.window.ms = 30000
+	partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner
+	receive.buffer.bytes = 32768
+	reconnect.backoff.max.ms = 1000
+	reconnect.backoff.ms = 50
+	request.timeout.ms = 5000
+	retries = 3
+	retry.backoff.ms = 100
+	sasl.client.callback.handler.class = null
+	sasl.jaas.config = null
+	sasl.kerberos.kinit.cmd = /usr/bin/kinit
+	sasl.kerberos.min.time.before.relogin = 60000
+	sasl.kerberos.service.name = null
+	sasl.kerberos.ticket.renew.jitter = 0.05
+	sasl.kerberos.ticket.renew.window.factor = 0.8
+	sasl.login.callback.handler.class = null
+	sasl.login.class = null
+	sasl.login.refresh.buffer.seconds = 300
+	sasl.login.refresh.min.period.seconds = 60
+	sasl.login.refresh.window.factor = 0.8
+	sasl.login.refresh.window.jitter = 0.05
+	sasl.mechanism = GSSAPI
+	security.protocol = PLAINTEXT
+	security.providers = null
+	send.buffer.bytes = 131072
+	socket.connection.setup.timeout.max.ms = 30000
+	socket.connection.setup.timeout.ms = 10000
+	ssl.cipher.suites = null
+	ssl.enabled.protocols = [TLSv1.2]
+	ssl.endpoint.identification.algorithm = https
+	ssl.engine.factory.class = null
+	ssl.key.password = null
+	ssl.keymanager.algorithm = SunX509
+	ssl.keystore.certificate.chain = null
+	ssl.keystore.key = null
+	ssl.keystore.location = null
+	ssl.keystore.password = null
+	ssl.keystore.type = JKS
+	ssl.protocol = TLSv1.2
+	ssl.provider = null
+	ssl.secure.random.implementation = null
+	ssl.trustmanager.algorithm = PKIX
+	ssl.truststore.certificates = null
+	ssl.truststore.location = null
+	ssl.truststore.password = null
+	ssl.truststore.type = JKS
+	transaction.timeout.ms = 60000
+	transactional.id = null
+	value.serializer = class org.apache.kafka.common.serialization.StringSerializer
+
+2022-02-21 15:44:32.448  INFO 18456 --- [http-nio-8080-exec-2] o.a.kafka.common.utils.AppInfoParser     : Kafka version: 3.0.0
+2022-02-21 15:44:32.449  INFO 18456 --- [http-nio-8080-exec-2] o.a.kafka.common.utils.AppInfoParser     : Kafka commitId: 8cb0a5e9d3441962
+2022-02-21 15:44:32.449  INFO 18456 --- [http-nio-8080-exec-2] o.a.kafka.common.utils.AppInfoParser     : Kafka startTimeMs: 1645429472446
+2022-02-21 15:44:32.717  INFO 18456 --- [kafka-producer-network-thread | producer-1] org.apache.kafka.clients.Metadata        : [Producer clientId=producer-1] Cluster ID: HsvqBxodQiORFIomGwKWDQ
+2022-02-21 15:44:32.726  INFO 18456 --- [http-nio-8080-exec-2] c.n.e.l.s.impl.LogTrackingServiceImpl    : aaa
+2022-02-21 15:46:50.652  INFO 18456 --- [http-nio-8080-exec-4] c.n.e.l.s.impl.LogTrackingServiceImpl    : {"target":"eval","source":"coder","op_type":1,"data":"This is an example","message":"be careful","created_time":1645429609397}
+2022-02-21 15:47:24.946  INFO 18456 --- [http-nio-8080-exec-6] c.n.e.l.s.impl.LogTrackingServiceImpl    : {"target":"eval","source":"coder","op_type":1,"data":"This is an example","message":"be careful","created_time":1645429643825}
+2022-02-21 15:47:34.638  INFO 18456 --- [http-nio-8080-exec-8] c.n.e.l.s.impl.LogTrackingServiceImpl    : {"target":"eval","source":"coder","op_type":1,"data":"This is an example","message":"be careful","created_time":1645429653592}
+2022-02-21 15:47:56.943  INFO 18456 --- [http-nio-8080-exec-10] c.n.e.l.s.impl.LogTrackingServiceImpl    : {"target":"eval","source":"coder","op_type":1,"data":"This is an example","message":"be careful","created_time":1645429675840}
+2022-02-21 15:48:18.516  INFO 18456 --- [http-nio-8080-exec-2] c.n.e.l.s.impl.LogTrackingServiceImpl    : aaa
+2022-02-21 15:48:34.814  INFO 18456 --- [http-nio-8080-exec-3] c.n.e.l.s.impl.LogTrackingServiceImpl    : aaa
+2022-02-21 15:48:45.837  INFO 18456 --- [http-nio-8080-exec-4] c.n.e.l.s.impl.LogTrackingServiceImpl    : what
+2022-02-21 15:48:53.893  INFO 18456 --- [http-nio-8080-exec-6] c.n.e.l.s.impl.LogTrackingServiceImpl    : {"target":"eval","source":"coder","op_type":1,"data":"This is an example","message":"be careful","created_time":1645429732832}
+2022-02-21 15:49:13.793  INFO 18456 --- [http-nio-8080-exec-7] c.n.e.l.s.impl.LogTrackingServiceImpl    : what's up
+2022-02-21 15:49:58.143  INFO 18456 --- [http-nio-8080-exec-9] c.n.e.l.s.impl.LogTrackingServiceImpl    : {"target":"eval","source":"coder","op_type":1,"data":"This is an example","message":"be careful","created_time":1645429797076}

seecoder-logTracking-client/src/main/java/client/LogTrackingClient.java

@@ -60,6 +60,7 @@ public class LogTrackingClient implements logTrackingApi {
     public void publish() {
         threadPoolExecutor.execute(() -> {
             try {
+                System.out.println(Config.SERVER + "/api/publish");
                 PostHelper.post(Config.SERVER + "/api/publish", logConfigDto);
             } catch (IOException e) {
                 log.error(e.getMessage());

seecoder-logTracking-common/src/main/java/com/nju/edu/logTracking/kafka/Config.java

@@ -4,14 +4,15 @@ import java.util.Arrays;
 import java.util.List;
 
 public class Config {
-    public static List<String> KAFKA_SERVERS = Arrays.asList("environment-40-126.seec.svc.cluster.local:9092");
+    public static List<String> KAFKA_SERVERS = Arrays.asList("environment-40-136.seec.svc.cluster.local:9092");
     public static String SERVER = "http://environment-40-127.seec.svc.cluster.local:8080";
 
-    public enum Topic{
+    public enum Topic {
         LOG_TRACKING_TOPIC("log-tracking");
 
         String topic;
-        Topic(String topic){
+
+        Topic(String topic) {
             this.topic = topic;
         }
 

seecoder-logTracking-common/src/main/java/com/nju/edu/logTracking/kafka/KafkaUtils.java

@@ -2,13 +2,14 @@ package com.nju.edu.logTracking.kafka;
 
 import org.apache.kafka.clients.consumer.KafkaConsumer;
 import org.apache.kafka.clients.producer.KafkaProducer;
-import org.apache.kafka.clients.producer.ProducerRecord;
 
 import java.util.List;
 import java.util.Properties;
 
 
 public class KafkaUtils {
+    private volatile static KafkaProducer<String, String> kafkaProducer;
+
     public static KafkaConsumer<String, String> createConsumer(List<String> topic) {
         Properties properties = new Properties();
         properties.put("bootstrap.servers", Config.KAFKA_SERVERS);
@@ -19,25 +20,27 @@ public class KafkaUtils {
         properties.put("session.timeout.ms", "30000");
         properties.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
         properties.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
-
         KafkaConsumer<String, String> kafkaConsumer = new KafkaConsumer<>(properties);
         kafkaConsumer.subscribe(topic);
         return kafkaConsumer;
     }
 
-    public static KafkaProducer<String, String> createProducer(int retries) {
-        Properties properties = new Properties();
-        properties.put("bootstrap.servers", Config.KAFKA_SERVERS);
-        properties.put("acks", "all");
-        properties.put("linger.ms", 5);
-        properties.put("retries", retries);
-        properties.put("request.timeout.ms", 5000);
-        properties.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
-        properties.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");
-        return new KafkaProducer<>(properties);
-    }
-
-    public static void send(KafkaProducer<String, String> producer, String topic, String message) {
-        producer.send(new ProducerRecord<>(topic, message));
+    public static KafkaProducer<String, String> getProducer() {
+        if(kafkaProducer == null){
+            synchronized (KafkaUtils.class){
+                if(kafkaProducer==null){
+                    Properties properties = new Properties();
+                    properties.put("bootstrap.servers", Config.KAFKA_SERVERS);
+                    properties.put("acks", "all");
+                    properties.put("linger.ms", 5);
+                    properties.put("retries", 3);
+                    properties.put("request.timeout.ms", 5000);
+                    properties.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
+                    properties.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");
+                    kafkaProducer = new KafkaProducer<>(properties);
+                }
+            }
+        }
+        return kafkaProducer;
     }
 }

seecoder-logTracking-server/src/main/java/com/nju/edu/logTracking/producer/level/HighLevel.java

@@ -3,11 +3,12 @@ package com.nju.edu.logTracking.producer.level;
 import com.nju.edu.logTracking.kafka.Config;
 import com.nju.edu.logTracking.kafka.KafkaUtils;
 import org.apache.kafka.clients.producer.KafkaProducer;
+import org.apache.kafka.clients.producer.ProducerRecord;
 
 public class HighLevel implements Level{
     @Override
     public void sendMessage(String message) {
-        KafkaProducer<String,String> kafkaProducer = KafkaUtils.createProducer(10);
-        KafkaUtils.send(kafkaProducer, Config.Topic.LOG_TRACKING_TOPIC.getTopic(), message);
+        KafkaProducer<String,String> kafkaProducer = KafkaUtils.getProducer();
+        kafkaProducer.send(new ProducerRecord<>(Config.Topic.LOG_TRACKING_TOPIC.getTopic(), message));
     }
 }

seecoder-logTracking-server/src/main/java/com/nju/edu/logTracking/producer/level/LowLevel.java

@@ -3,11 +3,12 @@ package com.nju.edu.logTracking.producer.level;
 import com.nju.edu.logTracking.kafka.Config;
 import com.nju.edu.logTracking.kafka.KafkaUtils;
 import org.apache.kafka.clients.producer.KafkaProducer;
+import org.apache.kafka.clients.producer.ProducerRecord;
 
 public class LowLevel implements Level{
     @Override
     public void sendMessage(String message) {
-        KafkaProducer<String,String> kafkaProducer = KafkaUtils.createProducer(0);
-        KafkaUtils.send(kafkaProducer, Config.Topic.LOG_TRACKING_TOPIC.getTopic(), message);
+        KafkaProducer<String,String> kafkaProducer = KafkaUtils.getProducer();
+        kafkaProducer.send(new ProducerRecord<>(Config.Topic.LOG_TRACKING_TOPIC.getTopic(), message));
     }
 }

seecoder-logTracking-server/src/main/java/com/nju/edu/logTracking/producer/level/MediumLevel.java

@@ -3,11 +3,12 @@ package com.nju.edu.logTracking.producer.level;
 import com.nju.edu.logTracking.kafka.Config;
 import com.nju.edu.logTracking.kafka.KafkaUtils;
 import org.apache.kafka.clients.producer.KafkaProducer;
+import org.apache.kafka.clients.producer.ProducerRecord;
 
 public class MediumLevel implements Level{
     @Override
     public void sendMessage(String message) {
-        KafkaProducer<String,String> kafkaProducer = KafkaUtils.createProducer(3);
-        KafkaUtils.send(kafkaProducer, Config.Topic.LOG_TRACKING_TOPIC.getTopic(), message);
+        KafkaProducer<String,String> kafkaProducer = KafkaUtils.getProducer();
+        kafkaProducer.send(new ProducerRecord<>(Config.Topic.LOG_TRACKING_TOPIC.getTopic(), message));
     }
 }

seecoder-logTracking-server/src/main/java/com/nju/edu/logTracking/service/impl/LogTrackingServiceImpl.java

@@ -48,7 +48,6 @@ public class LogTrackingServiceImpl implements LogTrackingService {
         String data = dto.getLog();
         //发送数据
         logTracking.publish(data);
-        System.out.println("===================");
         log.info(data);
     }
 }