diff --git a/application.pid b/application.pid new file mode 100644 index 0000000..945ea2e --- /dev/null +++ b/application.pid @@ -0,0 +1 @@ +22952 \ No newline at end of file diff --git a/lib/ipworks/local/1.0.0/ipworks-local-1.0.0.jar b/lib/ipworks-local-1.0.0.jar similarity index 100% rename from lib/ipworks/local/1.0.0/ipworks-local-1.0.0.jar rename to lib/ipworks-local-1.0.0.jar diff --git a/lib/state-spring-boot-starter-1.0.3.jar b/lib/state-spring-boot-starter-1.0.3.jar deleted file mode 100644 index 4f5a7df..0000000 Binary files a/lib/state-spring-boot-starter-1.0.3.jar and /dev/null differ diff --git a/lib/state-spring-boot-starter-1.0.5.jar b/lib/state-spring-boot-starter-1.0.5.jar new file mode 100644 index 0000000..ce29499 Binary files /dev/null and b/lib/state-spring-boot-starter-1.0.5.jar differ diff --git a/logs/trace.log b/logs/trace.log new file mode 100644 index 0000000..688c81f --- /dev/null +++ b/logs/trace.log @@ -0,0 +1,1040 @@ +[2024-04-17 00:47:29.132][I][StartupInfoLogger.logStarting ] Starting AsdeRecvApplication using Java 1.8.0_322 on DESKTOP-32A4E6F with PID 8460 (D:\Workspace\Odroid_repository\EyeGW_AsdeRecv\target\classes started by GMT in D:\Workspace\Odroid_repository\EyeGW_AsdeRecv\target\classes) +[2024-04-17 00:47:29.139][I][SpringApplication.logStartupProfileInfo ] The following 2 profiles are active: "default", "winTest" +[2024-04-17 00:47:31.207][I][TomcatWebServer.initialize ] Tomcat initialized with port(s): 18080 (http) +[2024-04-17 00:47:31.223][I][DirectJDKLog.log ] Initializing ProtocolHandler ["http-nio-18080"] +[2024-04-17 00:47:31.225][I][DirectJDKLog.log ] Starting service [Tomcat] +[2024-04-17 00:47:31.227][I][DirectJDKLog.log ] Starting Servlet engine: [Apache Tomcat/9.0.71] +[2024-04-17 00:47:31.442][I][DirectJDKLog.log ] Initializing Spring embedded WebApplicationContext +[2024-04-17 00:47:31.444][I][tionContext.prepareWebApplicationContext] Root WebApplicationContext: initialization completed in 2195 ms +[2024-04-17 00:47:33.675][I][MulticastIpworks.Initialize ] Multicast Server is running... +[2024-04-17 00:47:34.696][I][EndpointLinksResolver. ] Exposing 1 endpoint(s) beneath base path '/actuator' +[2024-04-17 00:47:34.759][I][DirectJDKLog.log ] Starting ProtocolHandler ["http-nio-18080"] +[2024-04-17 00:47:34.801][I][TomcatWebServer.start ] Tomcat started on port(s): 18080 (http) with context path '' +[2024-04-17 00:47:34.834][I][StartupInfoLogger.logStarted ] Started AsdeRecvApplication in 6.474 seconds (JVM running for 7.688) +[2024-04-17 00:47:34.855][I][UDPManager.initializeUDPFromXML ] [UDPManager] Load file .. : D:\Workspace\Odroid_repository\EyeGW_AsdeRecv\cfg\udpsocket.xml +[2024-04-17 00:47:34.961][I][UDPManager.initializeUDPFromXML ] [UDP Socket] ID : 1 IP : 127.0.0.1 PORT : 52114 +[2024-04-17 00:47:35.924][I][DirectJDKLog.log ] Initializing Spring DispatcherServlet 'dispatcherServlet' +[2024-04-17 00:47:35.925][I][FrameworkServlet.initServletBean ] Initializing Servlet 'dispatcherServlet' +[2024-04-17 00:47:35.928][I][FrameworkServlet.initServletBean ] Completed initialization in 2 ms +[2024-04-17 00:47:36.848][I][UDPSocket.activeSocket ] [UDP Socket] MultiCalstGroup : +239.11.12.5 port:52114 +[2024-04-17 00:47:36.849][I][UDPSocket.activeSocket ] [UDP Socket] recv : 127.0.0.1:52114 +[2024-04-17 00:47:36.850][I][UDPManager.startClient ] [UDP Manager][CONNECTED - PRIMARY][127.0.0.1][52114] +[2024-04-17 00:47:36.851][I][CustomThread.run ] [CustomThread] Started. +[2024-04-17 00:47:36.855][I][AsterixSpecLoader.initCategory ] Initializing.. +[2024-04-17 00:47:37.076][I][AsterixSpecLoader.initCategory ] Category-10 Spec 로드 성공 (파일:spec/alterixCat010Indra.yml) +[2024-04-17 00:47:37.152][I][AsterixSpecLoader.initCategory ] Category-11 Spec 로드 성공 (파일:spec/alterixCat011.yml) +[2024-04-17 00:47:37.152][I][AsterixSpecLoader.initCategory ] initialized. .. +[2024-04-17 00:47:37.248][I][AbstractConfig.logAll ] ProducerConfig values: + acks = -1 + batch.size = 16384 + bootstrap.servers = [10.200.31.6:9091, 10.200.31.8:9091, 10.200.31.142:9091] + 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 = 0 + 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 = 30000 + retries = 2147483647 + 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.connect.timeout.ms = null + sasl.login.read.timeout.ms = 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.login.retry.backoff.max.ms = 10000 + sasl.login.retry.backoff.ms = 100 + sasl.mechanism = GSSAPI + sasl.oauthbearer.clock.skew.seconds = 30 + sasl.oauthbearer.expected.audience = null + sasl.oauthbearer.expected.issuer = null + sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 + sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 + sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 + sasl.oauthbearer.jwks.endpoint.url = null + sasl.oauthbearer.scope.claim.name = scope + sasl.oauthbearer.sub.claim.name = sub + sasl.oauthbearer.token.endpoint.url = null + 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 + +[2024-04-17 00:47:37.305][I][KafkaProducer.configureTransactionState ] [Producer clientId=producer-1] Instantiated an idempotent producer. +[2024-04-17 00:47:37.432][I][AppInfoParser$AppInfo. ] Kafka version: 3.1.2 +[2024-04-17 00:47:37.435][I][AppInfoParser$AppInfo. ] Kafka commitId: f8c67dc3ae0a3265 +[2024-04-17 00:47:37.436][I][AppInfoParser$AppInfo. ] Kafka startTimeMs: 1713314857429 +[2024-04-17 00:47:37.879][I][Metadata.updateLatestMetadata ] [Producer clientId=producer-1] Resetting the last seen epoch of partition ic.recv.asde_test-0 to 0 since the associated topicId changed from null to uwaPXRTMTaSckOZuHg_tTw +[2024-04-17 00:47:37.884][I][Metadata.update ] [Producer clientId=producer-1] Cluster ID: kItbTcR-TnKq97Lzu_1hFA +[2024-04-17 00:47:37.889][I][TransactionManager.setProducerIdAndEpoch] [Producer clientId=producer-1] ProducerId set to 7058 with epoch 0 +[2024-04-17 00:47:37.918][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:37.158 | 2024-04-17 00:47:37.158) +[2024-04-17 00:47:37.961][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:37.919 | 2024-04-17 00:47:37.919) +[2024-04-17 00:47:37.976][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:37.962 | 2024-04-17 00:47:37.962) +[2024-04-17 00:47:37.988][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:37.978 | 2024-04-17 00:47:37.978) +[2024-04-17 00:47:38.000][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:37.989 | 2024-04-17 00:47:37.989) +[2024-04-17 00:47:38.009][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:38.001 | 2024-04-17 00:47:38.001) +[2024-04-17 00:47:38.021][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:38.012 | 2024-04-17 00:47:38.012) +[2024-04-17 00:47:38.029][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:38.022 | 2024-04-17 00:47:38.022) +[2024-04-17 00:47:38.888][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:38.882 | 2024-04-17 00:47:38.882) +[2024-04-17 00:47:38.898][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:38.889 | 2024-04-17 00:47:38.889) +[2024-04-17 00:47:38.904][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:38.899 | 2024-04-17 00:47:38.899) +[2024-04-17 00:47:38.909][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:38.905 | 2024-04-17 00:47:38.905) +[2024-04-17 00:47:39.846][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:39.840 | 2024-04-17 00:47:39.840) +[2024-04-17 00:47:39.853][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:39.848 | 2024-04-17 00:47:39.848) +[2024-04-17 00:47:39.862][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:39.854 | 2024-04-17 00:47:39.854) +[2024-04-17 00:47:39.871][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:39.864 | 2024-04-17 00:47:39.864) +[2024-04-17 00:47:40.803][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:40.798 | 2024-04-17 00:47:40.798) +[2024-04-17 00:47:40.809][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:40.804 | 2024-04-17 00:47:40.804) +[2024-04-17 00:47:40.815][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:40.810 | 2024-04-17 00:47:40.810) +[2024-04-17 00:47:40.819][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:40.816 | 2024-04-17 00:47:40.816) +[2024-04-17 00:47:41.760][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:41.757 | 2024-04-17 00:47:41.757) +[2024-04-17 00:47:41.779][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:41.761 | 2024-04-17 00:47:41.761) +[2024-04-17 00:47:41.784][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:41.780 | 2024-04-17 00:47:41.780) +[2024-04-17 00:47:41.789][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:41.785 | 2024-04-17 00:47:41.785) +[2024-04-17 00:47:42.717][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:42.714 | 2024-04-17 00:47:42.714) +[2024-04-17 00:47:42.722][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:42.718 | 2024-04-17 00:47:42.718) +[2024-04-17 00:47:42.727][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:42.723 | 2024-04-17 00:47:42.723) +[2024-04-17 00:47:42.734][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:42.728 | 2024-04-17 00:47:42.728) +[2024-04-17 00:47:43.675][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:43.673 | 2024-04-17 00:47:43.673) +[2024-04-17 00:47:43.678][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:43.676 | 2024-04-17 00:47:43.676) +[2024-04-17 00:47:43.681][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:43.679 | 2024-04-17 00:47:43.679) +[2024-04-17 00:47:43.684][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:43.682 | 2024-04-17 00:47:43.682) +[2024-04-17 00:47:44.633][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:44.631 | 2024-04-17 00:47:44.631) +[2024-04-17 00:47:44.636][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:44.634 | 2024-04-17 00:47:44.634) +[2024-04-17 00:47:44.640][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:44.637 | 2024-04-17 00:47:44.637) +[2024-04-17 00:47:44.645][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:44.641 | 2024-04-17 00:47:44.641) +[2024-04-17 00:47:45.592][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:45.590 | 2024-04-17 00:47:45.590) +[2024-04-17 00:47:45.596][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:45.593 | 2024-04-17 00:47:45.593) +[2024-04-17 00:47:45.599][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:45.597 | 2024-04-17 00:47:45.597) +[2024-04-17 00:47:45.602][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:45.599 | 2024-04-17 00:47:45.599) +[2024-04-17 00:47:46.552][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:46.550 | 2024-04-17 00:47:46.550) +[2024-04-17 00:47:46.555][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:46.553 | 2024-04-17 00:47:46.553) +[2024-04-17 00:47:46.558][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:46.555 | 2024-04-17 00:47:46.555) +[2024-04-17 00:47:46.561][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:46.558 | 2024-04-17 00:47:46.558) +[2024-04-17 00:47:47.513][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:47.511 | 2024-04-17 00:47:47.511) +[2024-04-17 00:47:47.517][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:47.514 | 2024-04-17 00:47:47.514) +[2024-04-17 00:47:47.521][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:47.518 | 2024-04-17 00:47:47.518) +[2024-04-17 00:47:47.524][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:47.522 | 2024-04-17 00:47:47.522) +[2024-04-17 00:47:48.475][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:48.473 | 2024-04-17 00:47:48.473) +[2024-04-17 00:47:48.478][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:48.476 | 2024-04-17 00:47:48.476) +[2024-04-17 00:47:48.481][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:48.479 | 2024-04-17 00:47:48.479) +[2024-04-17 00:47:48.485][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:48.482 | 2024-04-17 00:47:48.482) +[2024-04-17 00:47:49.438][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:49.434 | 2024-04-17 00:47:49.434) +[2024-04-17 00:47:49.442][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:49.440 | 2024-04-17 00:47:49.440) +[2024-04-17 00:47:49.445][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:49.443 | 2024-04-17 00:47:49.443) +[2024-04-17 00:47:49.449][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:49.446 | 2024-04-17 00:47:49.446) +[2024-04-17 00:47:50.391][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:50.389 | 2024-04-17 00:47:50.389) +[2024-04-17 00:47:50.393][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:50.391 | 2024-04-17 00:47:50.391) +[2024-04-17 00:47:50.396][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:50.394 | 2024-04-17 00:47:50.394) +[2024-04-17 00:47:50.399][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:50.397 | 2024-04-17 00:47:50.397) +[2024-04-17 00:47:51.351][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:51.348 | 2024-04-17 00:47:51.348) +[2024-04-17 00:47:51.353][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:51.351 | 2024-04-17 00:47:51.351) +[2024-04-17 00:47:51.356][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:51.354 | 2024-04-17 00:47:51.354) +[2024-04-17 00:47:51.359][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:51.357 | 2024-04-17 00:47:51.357) +[2024-04-17 00:47:52.310][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:52.307 | 2024-04-17 00:47:52.307) +[2024-04-17 00:47:52.312][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:52.311 | 2024-04-17 00:47:52.311) +[2024-04-17 00:47:52.315][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:52.314 | 2024-04-17 00:47:52.314) +[2024-04-17 00:47:52.318][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:52.316 | 2024-04-17 00:47:52.316) +[2024-04-17 00:47:53.269][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:53.267 | 2024-04-17 00:47:53.267) +[2024-04-17 00:47:53.271][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:53.269 | 2024-04-17 00:47:53.269) +[2024-04-17 00:47:53.274][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:53.272 | 2024-04-17 00:47:53.272) +[2024-04-17 00:47:53.277][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:53.275 | 2024-04-17 00:47:53.275) +[2024-04-17 00:47:54.228][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:54.225 | 2024-04-17 00:47:54.225) +[2024-04-17 00:47:54.231][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:54.229 | 2024-04-17 00:47:54.229) +[2024-04-17 00:47:54.234][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:54.232 | 2024-04-17 00:47:54.232) +[2024-04-17 00:47:54.238][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:54.235 | 2024-04-17 00:47:54.235) +[2024-04-17 00:47:55.188][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:55.185 | 2024-04-17 00:47:55.185) +[2024-04-17 00:47:55.191][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:55.189 | 2024-04-17 00:47:55.189) +[2024-04-17 00:47:55.195][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:55.192 | 2024-04-17 00:47:55.192) +[2024-04-17 00:47:55.199][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(40건 | 2024-04-17 00:47:55.196 | 2024-04-17 00:47:55.196) +[2024-04-17 00:48:19.145][I][StartupInfoLogger.logStarting ] Starting AsdeRecvApplication using Java 1.8.0_322 on DESKTOP-32A4E6F with PID 7660 (D:\Workspace\Odroid_repository\EyeGW_AsdeRecv\target\classes started by GMT in D:\Workspace\Odroid_repository\EyeGW_AsdeRecv\target\classes) +[2024-04-17 00:48:19.151][I][SpringApplication.logStartupProfileInfo ] The following 2 profiles are active: "default", "winTest" +[2024-04-17 00:48:21.158][I][TomcatWebServer.initialize ] Tomcat initialized with port(s): 18080 (http) +[2024-04-17 00:48:21.174][I][DirectJDKLog.log ] Initializing ProtocolHandler ["http-nio-18080"] +[2024-04-17 00:48:21.175][I][DirectJDKLog.log ] Starting service [Tomcat] +[2024-04-17 00:48:21.176][I][DirectJDKLog.log ] Starting Servlet engine: [Apache Tomcat/9.0.71] +[2024-04-17 00:48:21.267][I][DirectJDKLog.log ] Initializing Spring embedded WebApplicationContext +[2024-04-17 00:48:21.268][I][tionContext.prepareWebApplicationContext] Root WebApplicationContext: initialization completed in 2014 ms +[2024-04-17 00:48:23.546][I][MulticastIpworks.Initialize ] Multicast Server is running... +[2024-04-17 00:48:24.550][I][EndpointLinksResolver. ] Exposing 1 endpoint(s) beneath base path '/actuator' +[2024-04-17 00:48:24.615][I][DirectJDKLog.log ] Starting ProtocolHandler ["http-nio-18080"] +[2024-04-17 00:48:24.656][I][TomcatWebServer.start ] Tomcat started on port(s): 18080 (http) with context path '' +[2024-04-17 00:48:24.687][I][StartupInfoLogger.logStarted ] Started AsdeRecvApplication in 6.255 seconds (JVM running for 7.044) +[2024-04-17 00:48:24.700][I][UDPManager.initializeUDPFromXML ] [UDPManager] Load file .. : D:\Workspace\Odroid_repository\EyeGW_AsdeRecv\cfg\udpsocket.xml +[2024-04-17 00:48:24.728][I][UDPManager.initializeUDPFromXML ] [UDP Socket] ID : 1 IP : 127.0.0.1 PORT : 52114 +[2024-04-17 00:48:25.663][I][DirectJDKLog.log ] Initializing Spring DispatcherServlet 'dispatcherServlet' +[2024-04-17 00:48:25.664][I][FrameworkServlet.initServletBean ] Initializing Servlet 'dispatcherServlet' +[2024-04-17 00:48:25.666][I][FrameworkServlet.initServletBean ] Completed initialization in 2 ms +[2024-04-17 00:48:26.579][I][UDPSocket.activeSocket ] [UDP Socket] MultiCalstGroup : +239.11.12.5 port:52114 +[2024-04-17 00:48:26.580][I][UDPSocket.activeSocket ] [UDP Socket] recv : 127.0.0.1:52114 +[2024-04-17 00:48:26.580][I][UDPManager.startClient ] [UDP Manager][CONNECTED - PRIMARY][127.0.0.1][52114] +[2024-04-17 00:48:26.581][I][CustomThread.run ] [CustomThread] Started. +[2024-04-17 00:48:26.584][I][AsterixSpecLoader.initCategory ] Initializing.. +[2024-04-17 00:48:26.711][I][AsterixSpecLoader.initCategory ] Category-10 Spec 로드 성공 (파일:spec/alterixCat010Indra.yml) +[2024-04-17 00:48:26.779][I][AsterixSpecLoader.initCategory ] Category-11 Spec 로드 성공 (파일:spec/alterixCat011.yml) +[2024-04-17 00:48:26.780][I][AsterixSpecLoader.initCategory ] initialized. .. +[2024-04-17 00:48:26.989][I][AbstractConfig.logAll ] ProducerConfig values: + acks = -1 + batch.size = 16384 + bootstrap.servers = [10.200.31.6:9091, 10.200.31.8:9091, 10.200.31.142:9091] + 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 = 0 + 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 = 30000 + retries = 2147483647 + 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.connect.timeout.ms = null + sasl.login.read.timeout.ms = 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.login.retry.backoff.max.ms = 10000 + sasl.login.retry.backoff.ms = 100 + sasl.mechanism = GSSAPI + sasl.oauthbearer.clock.skew.seconds = 30 + sasl.oauthbearer.expected.audience = null + sasl.oauthbearer.expected.issuer = null + sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 + sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 + sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 + sasl.oauthbearer.jwks.endpoint.url = null + sasl.oauthbearer.scope.claim.name = scope + sasl.oauthbearer.sub.claim.name = sub + sasl.oauthbearer.token.endpoint.url = null + 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 + +[2024-04-17 00:48:27.040][I][KafkaProducer.configureTransactionState ] [Producer clientId=producer-1] Instantiated an idempotent producer. +[2024-04-17 00:48:27.102][I][AppInfoParser$AppInfo. ] Kafka version: 3.1.2 +[2024-04-17 00:48:27.104][I][AppInfoParser$AppInfo. ] Kafka commitId: f8c67dc3ae0a3265 +[2024-04-17 00:48:27.104][I][AppInfoParser$AppInfo. ] Kafka startTimeMs: 1713314907097 +[2024-04-17 00:48:27.451][I][Metadata.updateLatestMetadata ] [Producer clientId=producer-1] Resetting the last seen epoch of partition ic.recv.asde_test-0 to 0 since the associated topicId changed from null to uwaPXRTMTaSckOZuHg_tTw +[2024-04-17 00:48:27.454][I][Metadata.update ] [Producer clientId=producer-1] Cluster ID: kItbTcR-TnKq97Lzu_1hFA +[2024-04-17 00:48:27.457][I][TransactionManager.setProducerIdAndEpoch] [Producer clientId=producer-1] ProducerId set to 7059 with epoch 0 +[2024-04-17 00:48:27.473][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(28건 | 2024-04-17 00:48:26.831 | 2024-04-17 00:48:26.831) +[2024-04-17 00:48:27.504][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(29건 | 2024-04-17 00:48:26.853 | 2024-04-17 00:48:26.853) +[2024-04-17 00:48:27.521][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:48:26.867 | 2024-04-17 00:48:26.867) +[2024-04-17 00:48:27.524][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(7건 | 2024-04-17 00:48:26.875 | 2024-04-17 00:48:26.875) +[2024-04-17 00:48:27.810][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(28건 | 2024-04-17 00:48:27.789 | 2024-04-17 00:48:27.789) +[2024-04-17 00:48:27.826][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(29건 | 2024-04-17 00:48:27.794 | 2024-04-17 00:48:27.794) +[2024-04-17 00:48:27.835][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:48:27.800 | 2024-04-17 00:48:27.800) +[2024-04-17 00:48:27.839][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(7건 | 2024-04-17 00:48:27.805 | 2024-04-17 00:48:27.805) +[2024-04-17 00:48:28.754][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(28건 | 2024-04-17 00:48:28.745 | 2024-04-17 00:48:28.745) +[2024-04-17 00:48:28.761][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(29건 | 2024-04-17 00:48:28.748 | 2024-04-17 00:48:28.748) +[2024-04-17 00:48:28.769][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:48:28.752 | 2024-04-17 00:48:28.752) +[2024-04-17 00:48:28.772][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(7건 | 2024-04-17 00:48:28.755 | 2024-04-17 00:48:28.755) +[2024-04-17 00:48:29.710][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(28건 | 2024-04-17 00:48:29.704 | 2024-04-17 00:48:29.704) +[2024-04-17 00:48:29.715][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(29건 | 2024-04-17 00:48:29.705 | 2024-04-17 00:48:29.705) +[2024-04-17 00:48:29.720][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:48:29.708 | 2024-04-17 00:48:29.708) +[2024-04-17 00:48:29.724][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(8건 | 2024-04-17 00:48:29.709 | 2024-04-17 00:48:29.709) +[2024-04-17 00:48:30.674][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(28건 | 2024-04-17 00:48:30.666 | 2024-04-17 00:48:30.666) +[2024-04-17 00:48:30.678][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(29건 | 2024-04-17 00:48:30.667 | 2024-04-17 00:48:30.667) +[2024-04-17 00:48:30.681][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:48:30.670 | 2024-04-17 00:48:30.670) +[2024-04-17 00:48:30.684][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(8건 | 2024-04-17 00:48:30.672 | 2024-04-17 00:48:30.672) +[2024-04-17 00:48:31.629][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(28건 | 2024-04-17 00:48:31.625 | 2024-04-17 00:48:31.625) +[2024-04-17 00:48:31.633][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(29건 | 2024-04-17 00:48:31.627 | 2024-04-17 00:48:31.627) +[2024-04-17 00:48:31.637][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:48:31.628 | 2024-04-17 00:48:31.628) +[2024-04-17 00:48:31.639][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(8건 | 2024-04-17 00:48:31.631 | 2024-04-17 00:48:31.631) +[2024-04-17 00:48:32.600][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(28건 | 2024-04-17 00:48:32.584 | 2024-04-17 00:48:32.584) +[2024-04-17 00:48:32.603][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(29건 | 2024-04-17 00:48:32.585 | 2024-04-17 00:48:32.585) +[2024-04-17 00:48:32.606][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:48:32.599 | 2024-04-17 00:48:32.599) +[2024-04-17 00:48:32.608][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(7건 | 2024-04-17 00:48:32.602 | 2024-04-17 00:48:32.602) +[2024-04-17 00:48:33.549][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(28건 | 2024-04-17 00:48:33.547 | 2024-04-17 00:48:33.547) +[2024-04-17 00:48:33.551][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(29건 | 2024-04-17 00:48:33.547 | 2024-04-17 00:48:33.547) +[2024-04-17 00:48:33.554][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:48:33.548 | 2024-04-17 00:48:33.548) +[2024-04-17 00:48:33.556][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(7건 | 2024-04-17 00:48:33.550 | 2024-04-17 00:48:33.550) +[2024-04-17 00:48:34.508][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(28건 | 2024-04-17 00:48:34.504 | 2024-04-17 00:48:34.504) +[2024-04-17 00:48:34.510][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(29건 | 2024-04-17 00:48:34.506 | 2024-04-17 00:48:34.506) +[2024-04-17 00:48:34.514][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:48:34.508 | 2024-04-17 00:48:34.508) +[2024-04-17 00:48:34.516][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(7건 | 2024-04-17 00:48:34.509 | 2024-04-17 00:48:34.509) +[2024-04-17 00:48:35.471][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(28건 | 2024-04-17 00:48:35.466 | 2024-04-17 00:48:35.466) +[2024-04-17 00:48:35.476][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(29건 | 2024-04-17 00:48:35.469 | 2024-04-17 00:48:35.469) +[2024-04-17 00:48:35.480][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:48:35.471 | 2024-04-17 00:48:35.471) +[2024-04-17 00:48:35.483][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(9건 | 2024-04-17 00:48:35.473 | 2024-04-17 00:48:35.473) +[2024-04-17 00:48:36.430][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(28건 | 2024-04-17 00:48:36.426 | 2024-04-17 00:48:36.426) +[2024-04-17 00:48:36.438][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(29건 | 2024-04-17 00:48:36.428 | 2024-04-17 00:48:36.428) +[2024-04-17 00:48:36.444][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:48:36.431 | 2024-04-17 00:48:36.431) +[2024-04-17 00:48:36.447][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(10건 | 2024-04-17 00:48:36.434 | 2024-04-17 00:48:36.434) +[2024-04-17 00:48:37.389][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(28건 | 2024-04-17 00:48:37.386 | 2024-04-17 00:48:37.386) +[2024-04-17 00:48:37.392][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(29건 | 2024-04-17 00:48:37.388 | 2024-04-17 00:48:37.388) +[2024-04-17 00:48:37.394][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:48:37.389 | 2024-04-17 00:48:37.389) +[2024-04-17 00:48:37.396][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(8건 | 2024-04-17 00:48:37.391 | 2024-04-17 00:48:37.391) +[2024-04-17 00:50:17.168][I][StartupInfoLogger.logStarting ] Starting AsdeRecvApplication using Java 1.8.0_322 on DESKTOP-32A4E6F with PID 18680 (D:\Workspace\Odroid_repository\EyeGW_AsdeRecv\target\classes started by GMT in D:\Workspace\Odroid_repository\EyeGW_AsdeRecv\target\classes) +[2024-04-17 00:50:17.172][I][SpringApplication.logStartupProfileInfo ] The following 2 profiles are active: "default", "winTest" +[2024-04-17 00:50:19.055][I][TomcatWebServer.initialize ] Tomcat initialized with port(s): 18080 (http) +[2024-04-17 00:50:19.069][I][DirectJDKLog.log ] Initializing ProtocolHandler ["http-nio-18080"] +[2024-04-17 00:50:19.070][I][DirectJDKLog.log ] Starting service [Tomcat] +[2024-04-17 00:50:19.072][I][DirectJDKLog.log ] Starting Servlet engine: [Apache Tomcat/9.0.71] +[2024-04-17 00:50:19.156][I][DirectJDKLog.log ] Initializing Spring embedded WebApplicationContext +[2024-04-17 00:50:19.157][I][tionContext.prepareWebApplicationContext] Root WebApplicationContext: initialization completed in 1871 ms +[2024-04-17 00:50:20.904][I][MulticastIpworks.Initialize ] Multicast Server is running... +[2024-04-17 00:50:21.748][I][EndpointLinksResolver. ] Exposing 1 endpoint(s) beneath base path '/actuator' +[2024-04-17 00:50:21.800][I][DirectJDKLog.log ] Starting ProtocolHandler ["http-nio-18080"] +[2024-04-17 00:50:21.837][I][TomcatWebServer.start ] Tomcat started on port(s): 18080 (http) with context path '' +[2024-04-17 00:50:21.869][I][StartupInfoLogger.logStarted ] Started AsdeRecvApplication in 5.597 seconds (JVM running for 6.227) +[2024-04-17 00:50:21.884][I][UDPManager.initializeUDPFromXML ] [UDPManager] Load file .. : D:\Workspace\Odroid_repository\EyeGW_AsdeRecv\cfg\udpsocket.xml +[2024-04-17 00:50:21.912][I][UDPManager.initializeUDPFromXML ] [UDP Socket] ID : 1 IP : 127.0.0.1 PORT : 52114 +[2024-04-17 00:50:23.444][I][UDPSocket.activeSocket ] [UDP Socket] MultiCalstGroup : +239.11.12.5 port:52114 +[2024-04-17 00:50:23.446][I][UDPSocket.activeSocket ] [UDP Socket] recv : 127.0.0.1:52114 +[2024-04-17 00:50:23.446][I][UDPManager.startClient ] [UDP Manager][CONNECTED - PRIMARY][127.0.0.1][52114] +[2024-04-17 00:50:23.448][I][CustomThread.run ] [CustomThread] Started. +[2024-04-17 00:50:23.451][I][AsterixSpecLoader.initCategory ] Initializing.. +[2024-04-17 00:50:23.616][I][AsterixSpecLoader.initCategory ] Category-10 Spec 로드 성공 (파일:spec/alterixCat010Indra.yml) +[2024-04-17 00:50:23.701][I][AsterixSpecLoader.initCategory ] Category-11 Spec 로드 성공 (파일:spec/alterixCat011.yml) +[2024-04-17 00:50:23.702][I][AsterixSpecLoader.initCategory ] initialized. .. +[2024-04-17 00:50:23.755][I][DirectJDKLog.log ] Initializing Spring DispatcherServlet 'dispatcherServlet' +[2024-04-17 00:50:23.756][I][FrameworkServlet.initServletBean ] Initializing Servlet 'dispatcherServlet' +[2024-04-17 00:50:23.760][I][FrameworkServlet.initServletBean ] Completed initialization in 4 ms +[2024-04-17 00:50:23.957][I][AbstractConfig.logAll ] ProducerConfig values: + acks = -1 + batch.size = 16384 + bootstrap.servers = [10.200.31.6:9091, 10.200.31.8:9091, 10.200.31.142:9091] + 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 = 0 + 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 = 30000 + retries = 2147483647 + 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.connect.timeout.ms = null + sasl.login.read.timeout.ms = 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.login.retry.backoff.max.ms = 10000 + sasl.login.retry.backoff.ms = 100 + sasl.mechanism = GSSAPI + sasl.oauthbearer.clock.skew.seconds = 30 + sasl.oauthbearer.expected.audience = null + sasl.oauthbearer.expected.issuer = null + sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 + sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 + sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 + sasl.oauthbearer.jwks.endpoint.url = null + sasl.oauthbearer.scope.claim.name = scope + sasl.oauthbearer.sub.claim.name = sub + sasl.oauthbearer.token.endpoint.url = null + 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 + +[2024-04-17 00:50:24.015][I][KafkaProducer.configureTransactionState ] [Producer clientId=producer-1] Instantiated an idempotent producer. +[2024-04-17 00:50:24.100][I][AppInfoParser$AppInfo. ] Kafka version: 3.1.2 +[2024-04-17 00:50:24.101][I][AppInfoParser$AppInfo. ] Kafka commitId: f8c67dc3ae0a3265 +[2024-04-17 00:50:24.102][I][AppInfoParser$AppInfo. ] Kafka startTimeMs: 1713315024097 +[2024-04-17 00:50:24.455][I][Metadata.updateLatestMetadata ] [Producer clientId=producer-1] Resetting the last seen epoch of partition ai.analyze.video-0 to 0 since the associated topicId changed from null to ZHI-a535TFWndLCWIZVkMA +[2024-04-17 00:50:24.457][I][Metadata.update ] [Producer clientId=producer-1] Cluster ID: kItbTcR-TnKq97Lzu_1hFA +[2024-04-17 00:50:24.459][I][TransactionManager.setProducerIdAndEpoch] [Producer clientId=producer-1] ProducerId set to 7060 with epoch 0 +[2024-04-17 00:50:24.475][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(29건 | 2024-04-17 00:50:23.799 | 2024-04-17 00:50:23.799) +[2024-04-17 00:50:24.496][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(29건 | 2024-04-17 00:50:23.826 | 2024-04-17 00:50:23.826) +[2024-04-17 00:50:24.517][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:50:23.848 | 2024-04-17 00:50:23.848) +[2024-04-17 00:50:24.522][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(7건 | 2024-04-17 00:50:23.860 | 2024-04-17 00:50:23.860) +[2024-04-17 00:50:24.768][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(29건 | 2024-04-17 00:50:24.756 | 2024-04-17 00:50:24.756) +[2024-04-17 00:50:24.777][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(29건 | 2024-04-17 00:50:24.758 | 2024-04-17 00:50:24.758) +[2024-04-17 00:50:24.784][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:50:24.762 | 2024-04-17 00:50:24.762) +[2024-04-17 00:50:24.787][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(7건 | 2024-04-17 00:50:24.764 | 2024-04-17 00:50:24.764) +[2024-04-17 00:50:25.734][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(29건 | 2024-04-17 00:50:25.714 | 2024-04-17 00:50:25.714) +[2024-04-17 00:50:25.741][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(29건 | 2024-04-17 00:50:25.718 | 2024-04-17 00:50:25.718) +[2024-04-17 00:50:25.750][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:50:25.722 | 2024-04-17 00:50:25.722) +[2024-04-17 00:50:25.755][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(7건 | 2024-04-17 00:50:25.725 | 2024-04-17 00:50:25.725) +[2024-04-17 00:50:26.682][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(29건 | 2024-04-17 00:50:26.673 | 2024-04-17 00:50:26.673) +[2024-04-17 00:50:26.699][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(29건 | 2024-04-17 00:50:26.675 | 2024-04-17 00:50:26.675) +[2024-04-17 00:50:26.717][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:50:26.678 | 2024-04-17 00:50:26.678) +[2024-04-17 00:50:26.721][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(8건 | 2024-04-17 00:50:26.681 | 2024-04-17 00:50:26.681) +[2024-04-17 00:50:27.640][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(29건 | 2024-04-17 00:50:27.633 | 2024-04-17 00:50:27.633) +[2024-04-17 00:50:27.644][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(28건 | 2024-04-17 00:50:27.635 | 2024-04-17 00:50:27.635) +[2024-04-17 00:50:27.650][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(28건 | 2024-04-17 00:50:27.637 | 2024-04-17 00:50:27.637) +[2024-04-17 00:50:27.651][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(5건 | 2024-04-17 00:50:27.638 | 2024-04-17 00:50:27.638) +[2024-04-17 00:50:28.597][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(29건 | 2024-04-17 00:50:28.590 | 2024-04-17 00:50:28.590) +[2024-04-17 00:50:28.604][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(29건 | 2024-04-17 00:50:28.592 | 2024-04-17 00:50:28.592) +[2024-04-17 00:50:28.611][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:50:28.594 | 2024-04-17 00:50:28.594) +[2024-04-17 00:50:28.641][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(6건 | 2024-04-17 00:50:28.597 | 2024-04-17 00:50:28.597) +[2024-04-17 00:50:29.554][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(29건 | 2024-04-17 00:50:29.549 | 2024-04-17 00:50:29.549) +[2024-04-17 00:50:29.558][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(29건 | 2024-04-17 00:50:29.552 | 2024-04-17 00:50:29.552) +[2024-04-17 00:50:29.562][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:50:29.554 | 2024-04-17 00:50:29.554) +[2024-04-17 00:50:29.565][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(6건 | 2024-04-17 00:50:29.556 | 2024-04-17 00:50:29.556) +[2024-04-17 00:50:30.510][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(29건 | 2024-04-17 00:50:30.506 | 2024-04-17 00:50:30.506) +[2024-04-17 00:50:30.512][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(28건 | 2024-04-17 00:50:30.508 | 2024-04-17 00:50:30.508) +[2024-04-17 00:50:30.516][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(28건 | 2024-04-17 00:50:30.510 | 2024-04-17 00:50:30.510) +[2024-04-17 00:50:30.518][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(5건 | 2024-04-17 00:50:30.512 | 2024-04-17 00:50:30.512) +[2024-04-17 00:53:04.881][I][StartupInfoLogger.logStarting ] Starting AsdeRecvApplication using Java 1.8.0_322 on DESKTOP-32A4E6F with PID 10036 (D:\Workspace\Odroid_repository\EyeGW_AsdeRecv\target\classes started by GMT in D:\Workspace\Odroid_repository\EyeGW_AsdeRecv\target\classes) +[2024-04-17 00:53:04.887][I][SpringApplication.logStartupProfileInfo ] The following 2 profiles are active: "default", "winTest" +[2024-04-17 00:53:06.914][I][TomcatWebServer.initialize ] Tomcat initialized with port(s): 18080 (http) +[2024-04-17 00:53:06.934][I][DirectJDKLog.log ] Initializing ProtocolHandler ["http-nio-18080"] +[2024-04-17 00:53:06.936][I][DirectJDKLog.log ] Starting service [Tomcat] +[2024-04-17 00:53:06.937][I][DirectJDKLog.log ] Starting Servlet engine: [Apache Tomcat/9.0.71] +[2024-04-17 00:53:07.147][I][DirectJDKLog.log ] Initializing Spring embedded WebApplicationContext +[2024-04-17 00:53:07.148][I][tionContext.prepareWebApplicationContext] Root WebApplicationContext: initialization completed in 2123 ms +[2024-04-17 00:53:09.163][I][MulticastIpworks.Initialize ] Multicast Server is running... +[2024-04-17 00:53:10.073][I][EndpointLinksResolver. ] Exposing 1 endpoint(s) beneath base path '/actuator' +[2024-04-17 00:53:10.113][I][DirectJDKLog.log ] Starting ProtocolHandler ["http-nio-18080"] +[2024-04-17 00:53:10.146][I][TomcatWebServer.start ] Tomcat started on port(s): 18080 (http) with context path '' +[2024-04-17 00:53:10.174][I][StartupInfoLogger.logStarted ] Started AsdeRecvApplication in 6.07 seconds (JVM running for 6.671) +[2024-04-17 00:53:10.190][I][UDPManager.initializeUDPFromXML ] [UDPManager] Load file .. : D:\Workspace\Odroid_repository\EyeGW_AsdeRecv\cfg\udpsocket.xml +[2024-04-17 00:53:10.214][I][UDPManager.initializeUDPFromXML ] [UDP Socket] ID : 1 IP : 127.0.0.1 PORT : 52114 +[2024-04-17 00:53:11.580][I][DirectJDKLog.log ] Initializing Spring DispatcherServlet 'dispatcherServlet' +[2024-04-17 00:53:11.582][I][FrameworkServlet.initServletBean ] Initializing Servlet 'dispatcherServlet' +[2024-04-17 00:53:11.586][I][FrameworkServlet.initServletBean ] Completed initialization in 3 ms +[2024-04-17 00:53:12.024][I][UDPSocket.activeSocket ] [UDP Socket] MultiCalstGroup : +239.11.12.5 port:52114 +[2024-04-17 00:53:12.025][I][UDPSocket.activeSocket ] [UDP Socket] recv : 127.0.0.1:52114 +[2024-04-17 00:53:12.026][I][UDPManager.startClient ] [UDP Manager][CONNECTED - PRIMARY][127.0.0.1][52114] +[2024-04-17 00:53:12.028][I][CustomThread.run ] [CustomThread] Started. +[2024-04-17 00:53:12.032][I][AsterixSpecLoader.initCategory ] Initializing.. +[2024-04-17 00:53:12.245][I][AsterixSpecLoader.initCategory ] Category-10 Spec 로드 성공 (파일:spec/alterixCat010Indra.yml) +[2024-04-17 00:53:12.341][I][AsterixSpecLoader.initCategory ] Category-11 Spec 로드 성공 (파일:spec/alterixCat011.yml) +[2024-04-17 00:53:12.344][I][AsterixSpecLoader.initCategory ] initialized. .. +[2024-04-17 00:53:12.656][I][AbstractConfig.logAll ] ProducerConfig values: + acks = -1 + batch.size = 16384 + bootstrap.servers = [10.200.31.6:9091, 10.200.31.8:9091, 10.200.31.142:9091] + 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 = 0 + 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 = 30000 + retries = 2147483647 + 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.connect.timeout.ms = null + sasl.login.read.timeout.ms = 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.login.retry.backoff.max.ms = 10000 + sasl.login.retry.backoff.ms = 100 + sasl.mechanism = GSSAPI + sasl.oauthbearer.clock.skew.seconds = 30 + sasl.oauthbearer.expected.audience = null + sasl.oauthbearer.expected.issuer = null + sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 + sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 + sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 + sasl.oauthbearer.jwks.endpoint.url = null + sasl.oauthbearer.scope.claim.name = scope + sasl.oauthbearer.sub.claim.name = sub + sasl.oauthbearer.token.endpoint.url = null + 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 + +[2024-04-17 00:53:12.702][I][KafkaProducer.configureTransactionState ] [Producer clientId=producer-1] Instantiated an idempotent producer. +[2024-04-17 00:53:12.783][I][AppInfoParser$AppInfo. ] Kafka version: 3.1.2 +[2024-04-17 00:53:12.785][I][AppInfoParser$AppInfo. ] Kafka commitId: f8c67dc3ae0a3265 +[2024-04-17 00:53:12.785][I][AppInfoParser$AppInfo. ] Kafka startTimeMs: 1713315192781 +[2024-04-17 00:53:13.190][I][TransactionManager.setProducerIdAndEpoch] [Producer clientId=producer-1] ProducerId set to 7061 with epoch 0 +[2024-04-17 00:53:13.200][W][MetadataUpdater.handleSuccessfulResponse] [Producer clientId=producer-1] Error while fetching metadata with correlation id 2 : {ic.recv.asde_test=LEADER_NOT_AVAILABLE} +[2024-04-17 00:53:13.202][I][Metadata.update ] [Producer clientId=producer-1] Cluster ID: kItbTcR-TnKq97Lzu_1hFA +[2024-04-17 00:53:13.302][I][Metadata.updateLatestMetadata ] [Producer clientId=producer-1] Resetting the last seen epoch of partition ic.recv.asde_test-0 to 0 since the associated topicId changed from null to j-dTKltrQSWQMoC3Q_gtOA +[2024-04-17 00:53:13.335][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(26건 | 2024-04-17 00:53:12.558 | 2024-04-17 00:53:12.558) +[2024-04-17 00:53:13.365][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:53:12.582 | 2024-04-17 00:53:12.582) +[2024-04-17 00:53:13.379][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(28건 | 2024-04-17 00:53:12.597 | 2024-04-17 00:53:12.597) +[2024-04-17 00:53:13.382][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(5건 | 2024-04-17 00:53:12.602 | 2024-04-17 00:53:12.602) +[2024-04-17 00:53:13.526][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(26건 | 2024-04-17 00:53:13.516 | 2024-04-17 00:53:13.516) +[2024-04-17 00:53:13.532][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:53:13.518 | 2024-04-17 00:53:13.518) +[2024-04-17 00:53:13.539][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(28건 | 2024-04-17 00:53:13.523 | 2024-04-17 00:53:13.523) +[2024-04-17 00:53:13.542][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(7건 | 2024-04-17 00:53:13.527 | 2024-04-17 00:53:13.527) +[2024-04-17 00:53:14.487][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(26건 | 2024-04-17 00:53:14.478 | 2024-04-17 00:53:14.478) +[2024-04-17 00:53:14.491][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:53:14.480 | 2024-04-17 00:53:14.480) +[2024-04-17 00:53:14.497][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(28건 | 2024-04-17 00:53:14.483 | 2024-04-17 00:53:14.483) +[2024-04-17 00:53:14.500][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(6건 | 2024-04-17 00:53:14.485 | 2024-04-17 00:53:14.485) +[2024-04-17 00:53:15.442][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:53:15.438 | 2024-04-17 00:53:15.438) +[2024-04-17 00:53:15.447][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(26건 | 2024-04-17 00:53:15.439 | 2024-04-17 00:53:15.439) +[2024-04-17 00:53:15.452][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(28건 | 2024-04-17 00:53:15.441 | 2024-04-17 00:53:15.441) +[2024-04-17 00:53:15.456][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(7건 | 2024-04-17 00:53:15.443 | 2024-04-17 00:53:15.443) +[2024-04-17 00:53:16.418][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:53:16.411 | 2024-04-17 00:53:16.411) +[2024-04-17 00:53:16.429][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(26건 | 2024-04-17 00:53:16.414 | 2024-04-17 00:53:16.414) +[2024-04-17 00:53:16.434][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(28건 | 2024-04-17 00:53:16.416 | 2024-04-17 00:53:16.416) +[2024-04-17 00:53:16.436][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(6건 | 2024-04-17 00:53:16.418 | 2024-04-17 00:53:16.418) +[2024-04-17 00:53:17.388][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:53:17.354 | 2024-04-17 00:53:17.354) +[2024-04-17 00:53:17.396][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(26건 | 2024-04-17 00:53:17.357 | 2024-04-17 00:53:17.357) +[2024-04-17 00:53:17.405][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(28건 | 2024-04-17 00:53:17.362 | 2024-04-17 00:53:17.362) +[2024-04-17 00:53:17.413][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(6건 | 2024-04-17 00:53:17.364 | 2024-04-17 00:53:17.364) +[2024-04-17 00:53:18.374][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:53:18.312 | 2024-04-17 00:53:18.312) +[2024-04-17 00:53:18.379][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(26건 | 2024-04-17 00:53:18.316 | 2024-04-17 00:53:18.316) +[2024-04-17 00:53:18.384][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(28건 | 2024-04-17 00:53:18.320 | 2024-04-17 00:53:18.320) +[2024-04-17 00:53:18.414][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(6건 | 2024-04-17 00:53:18.322 | 2024-04-17 00:53:18.322) +[2024-04-17 00:53:19.279][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:53:19.271 | 2024-04-17 00:53:19.271) +[2024-04-17 00:53:19.285][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(26건 | 2024-04-17 00:53:19.275 | 2024-04-17 00:53:19.275) +[2024-04-17 00:53:19.290][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(28건 | 2024-04-17 00:53:19.278 | 2024-04-17 00:53:19.278) +[2024-04-17 00:53:19.291][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(5건 | 2024-04-17 00:53:19.282 | 2024-04-17 00:53:19.282) +[2024-04-17 00:53:48.599][I][StartupInfoLogger.logStarting ] Starting AsdeRecvApplication using Java 1.8.0_322 on DESKTOP-32A4E6F with PID 20168 (D:\Workspace\Odroid_repository\EyeGW_AsdeRecv\target\classes started by GMT in D:\Workspace\Odroid_repository\EyeGW_AsdeRecv\target\classes) +[2024-04-17 00:53:48.607][I][SpringApplication.logStartupProfileInfo ] The following 2 profiles are active: "default", "winTest" +[2024-04-17 00:53:50.712][I][TomcatWebServer.initialize ] Tomcat initialized with port(s): 18080 (http) +[2024-04-17 00:53:50.739][I][DirectJDKLog.log ] Initializing ProtocolHandler ["http-nio-18080"] +[2024-04-17 00:53:50.740][I][DirectJDKLog.log ] Starting service [Tomcat] +[2024-04-17 00:53:50.741][I][DirectJDKLog.log ] Starting Servlet engine: [Apache Tomcat/9.0.71] +[2024-04-17 00:53:50.883][I][DirectJDKLog.log ] Initializing Spring embedded WebApplicationContext +[2024-04-17 00:53:50.883][I][tionContext.prepareWebApplicationContext] Root WebApplicationContext: initialization completed in 2106 ms +[2024-04-17 00:53:52.765][I][MulticastIpworks.Initialize ] Multicast Server is running... +[2024-04-17 00:53:53.757][I][EndpointLinksResolver. ] Exposing 1 endpoint(s) beneath base path '/actuator' +[2024-04-17 00:53:53.817][I][DirectJDKLog.log ] Starting ProtocolHandler ["http-nio-18080"] +[2024-04-17 00:53:53.853][I][TomcatWebServer.start ] Tomcat started on port(s): 18080 (http) with context path '' +[2024-04-17 00:53:53.888][I][StartupInfoLogger.logStarted ] Started AsdeRecvApplication in 6.11 seconds (JVM running for 7.014) +[2024-04-17 00:53:53.905][I][UDPManager.initializeUDPFromXML ] [UDPManager] Load file .. : D:\Workspace\Odroid_repository\EyeGW_AsdeRecv\cfg\udpsocket.xml +[2024-04-17 00:53:53.951][I][UDPManager.initializeUDPFromXML ] [UDP Socket] ID : 1 IP : 127.0.0.1 PORT : 52114 +[2024-04-17 00:53:55.080][I][DirectJDKLog.log ] Initializing Spring DispatcherServlet 'dispatcherServlet' +[2024-04-17 00:53:55.081][I][FrameworkServlet.initServletBean ] Initializing Servlet 'dispatcherServlet' +[2024-04-17 00:53:55.083][I][FrameworkServlet.initServletBean ] Completed initialization in 2 ms +[2024-04-17 00:53:55.723][I][UDPSocket.activeSocket ] [UDP Socket] MultiCalstGroup : +239.11.12.5 port:52114 +[2024-04-17 00:53:55.726][I][UDPSocket.activeSocket ] [UDP Socket] recv : 127.0.0.1:52114 +[2024-04-17 00:53:55.726][I][UDPManager.startClient ] [UDP Manager][CONNECTED - PRIMARY][127.0.0.1][52114] +[2024-04-17 00:53:55.727][I][CustomThread.run ] [CustomThread] Started. +[2024-04-17 00:53:55.730][I][AsterixSpecLoader.initCategory ] Initializing.. +[2024-04-17 00:53:55.845][I][AsterixSpecLoader.initCategory ] Category-10 Spec 로드 성공 (파일:spec/alterixCat010Indra.yml) +[2024-04-17 00:53:55.912][I][AsterixSpecLoader.initCategory ] Category-11 Spec 로드 성공 (파일:spec/alterixCat011.yml) +[2024-04-17 00:53:55.913][I][AsterixSpecLoader.initCategory ] initialized. .. +[2024-04-17 00:53:56.741][I][AbstractConfig.logAll ] ProducerConfig values: + acks = -1 + batch.size = 16384 + bootstrap.servers = [10.200.31.6:9091, 10.200.31.8:9091, 10.200.31.142:9091] + 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 = 0 + 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 = 30000 + retries = 2147483647 + 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.connect.timeout.ms = null + sasl.login.read.timeout.ms = 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.login.retry.backoff.max.ms = 10000 + sasl.login.retry.backoff.ms = 100 + sasl.mechanism = GSSAPI + sasl.oauthbearer.clock.skew.seconds = 30 + sasl.oauthbearer.expected.audience = null + sasl.oauthbearer.expected.issuer = null + sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 + sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 + sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 + sasl.oauthbearer.jwks.endpoint.url = null + sasl.oauthbearer.scope.claim.name = scope + sasl.oauthbearer.sub.claim.name = sub + sasl.oauthbearer.token.endpoint.url = null + 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 + +[2024-04-17 00:53:56.794][I][KafkaProducer.configureTransactionState ] [Producer clientId=producer-1] Instantiated an idempotent producer. +[2024-04-17 00:53:56.856][I][AppInfoParser$AppInfo. ] Kafka version: 3.1.2 +[2024-04-17 00:53:56.858][I][AppInfoParser$AppInfo. ] Kafka commitId: f8c67dc3ae0a3265 +[2024-04-17 00:53:56.859][I][AppInfoParser$AppInfo. ] Kafka startTimeMs: 1713315236854 +[2024-04-17 00:53:57.373][I][Metadata.updateLatestMetadata ] [Producer clientId=producer-1] Resetting the last seen epoch of partition ic.recv.asde_test-0 to 0 since the associated topicId changed from null to j-dTKltrQSWQMoC3Q_gtOA +[2024-04-17 00:53:57.376][I][Metadata.update ] [Producer clientId=producer-1] Cluster ID: kItbTcR-TnKq97Lzu_1hFA +[2024-04-17 00:53:57.378][I][TransactionManager.setProducerIdAndEpoch] [Producer clientId=producer-1] ProducerId set to 7062 with epoch 0 +[2024-04-17 00:53:57.401][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(26건 | 2024-04-17 00:53:56.660 | 2024-04-17 00:53:56.660) +[2024-04-17 00:53:57.430][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(25건 | 2024-04-17 00:53:56.675 | 2024-04-17 00:53:56.675) +[2024-04-17 00:53:57.442][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:53:56.686 | 2024-04-17 00:53:56.686) +[2024-04-17 00:53:57.447][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(10건 | 2024-04-17 00:53:56.694 | 2024-04-17 00:53:56.694) +[2024-04-17 00:53:57.632][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(26건 | 2024-04-17 00:53:57.619 | 2024-04-17 00:53:57.619) +[2024-04-17 00:53:57.638][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(26건 | 2024-04-17 00:53:57.623 | 2024-04-17 00:53:57.623) +[2024-04-17 00:53:57.647][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:53:57.627 | 2024-04-17 00:53:57.627) +[2024-04-17 00:53:57.651][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(11건 | 2024-04-17 00:53:57.629 | 2024-04-17 00:53:57.629) +[2024-04-17 00:53:58.586][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(26건 | 2024-04-17 00:53:58.573 | 2024-04-17 00:53:58.573) +[2024-04-17 00:53:58.594][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:53:58.577 | 2024-04-17 00:53:58.577) +[2024-04-17 00:53:58.600][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:53:58.581 | 2024-04-17 00:53:58.581) +[2024-04-17 00:53:58.606][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(11건 | 2024-04-17 00:53:58.584 | 2024-04-17 00:53:58.584) +[2024-04-17 00:53:59.542][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(26건 | 2024-04-17 00:53:59.530 | 2024-04-17 00:53:59.530) +[2024-04-17 00:53:59.554][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:53:59.532 | 2024-04-17 00:53:59.532) +[2024-04-17 00:53:59.570][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:53:59.537 | 2024-04-17 00:53:59.537) +[2024-04-17 00:53:59.587][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(11건 | 2024-04-17 00:53:59.540 | 2024-04-17 00:53:59.540) +[2024-04-17 00:54:00.505][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(26건 | 2024-04-17 00:54:00.488 | 2024-04-17 00:54:00.488) +[2024-04-17 00:54:00.511][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:54:00.491 | 2024-04-17 00:54:00.491) +[2024-04-17 00:54:00.518][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:54:00.494 | 2024-04-17 00:54:00.494) +[2024-04-17 00:54:00.521][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(11건 | 2024-04-17 00:54:00.496 | 2024-04-17 00:54:00.496) +[2024-04-17 00:54:01.451][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(26건 | 2024-04-17 00:54:01.447 | 2024-04-17 00:54:01.447) +[2024-04-17 00:54:01.456][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:54:01.449 | 2024-04-17 00:54:01.449) +[2024-04-17 00:54:01.463][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:54:01.451 | 2024-04-17 00:54:01.451) +[2024-04-17 00:54:01.465][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(11건 | 2024-04-17 00:54:01.453 | 2024-04-17 00:54:01.453) +[2024-04-17 00:54:02.409][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(26건 | 2024-04-17 00:54:02.405 | 2024-04-17 00:54:02.405) +[2024-04-17 00:54:02.413][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:54:02.407 | 2024-04-17 00:54:02.407) +[2024-04-17 00:54:02.415][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:54:02.409 | 2024-04-17 00:54:02.409) +[2024-04-17 00:54:02.417][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(10건 | 2024-04-17 00:54:02.412 | 2024-04-17 00:54:02.412) +[2024-04-17 00:54:03.371][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(26건 | 2024-04-17 00:54:03.367 | 2024-04-17 00:54:03.367) +[2024-04-17 00:54:03.374][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(28건 | 2024-04-17 00:54:03.368 | 2024-04-17 00:54:03.368) +[2024-04-17 00:54:03.376][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(26건 | 2024-04-17 00:54:03.371 | 2024-04-17 00:54:03.371) +[2024-04-17 00:54:03.378][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(11건 | 2024-04-17 00:54:03.373 | 2024-04-17 00:54:03.373) +[2024-04-17 00:54:04.329][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(26건 | 2024-04-17 00:54:04.324 | 2024-04-17 00:54:04.324) +[2024-04-17 00:54:04.334][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(28건 | 2024-04-17 00:54:04.326 | 2024-04-17 00:54:04.326) +[2024-04-17 00:54:04.339][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(26건 | 2024-04-17 00:54:04.329 | 2024-04-17 00:54:04.329) +[2024-04-17 00:54:04.367][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(11건 | 2024-04-17 00:54:04.333 | 2024-04-17 00:54:04.333) +[2024-04-17 00:54:05.288][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(26건 | 2024-04-17 00:54:05.285 | 2024-04-17 00:54:05.285) +[2024-04-17 00:54:05.292][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(28건 | 2024-04-17 00:54:05.286 | 2024-04-17 00:54:05.286) +[2024-04-17 00:54:05.295][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(26건 | 2024-04-17 00:54:05.288 | 2024-04-17 00:54:05.288) +[2024-04-17 00:54:05.296][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(11건 | 2024-04-17 00:54:05.290 | 2024-04-17 00:54:05.290) +[2024-04-17 00:54:06.247][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(26건 | 2024-04-17 00:54:06.244 | 2024-04-17 00:54:06.244) +[2024-04-17 00:54:06.251][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(28건 | 2024-04-17 00:54:06.246 | 2024-04-17 00:54:06.246) +[2024-04-17 00:54:06.253][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(26건 | 2024-04-17 00:54:06.247 | 2024-04-17 00:54:06.247) +[2024-04-17 00:54:06.254][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(13건 | 2024-04-17 00:54:06.249 | 2024-04-17 00:54:06.249) +[2024-04-17 00:54:07.205][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(26건 | 2024-04-17 00:54:07.202 | 2024-04-17 00:54:07.202) +[2024-04-17 00:54:07.208][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:54:07.204 | 2024-04-17 00:54:07.204) +[2024-04-17 00:54:07.211][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:54:07.206 | 2024-04-17 00:54:07.206) +[2024-04-17 00:54:07.213][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(11건 | 2024-04-17 00:54:07.208 | 2024-04-17 00:54:07.208) +[2024-04-17 00:54:08.164][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(26건 | 2024-04-17 00:54:08.161 | 2024-04-17 00:54:08.161) +[2024-04-17 00:54:08.167][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:54:08.163 | 2024-04-17 00:54:08.163) +[2024-04-17 00:54:08.169][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:54:08.164 | 2024-04-17 00:54:08.164) +[2024-04-17 00:54:08.171][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(11건 | 2024-04-17 00:54:08.166 | 2024-04-17 00:54:08.166) +[2024-04-17 00:54:09.133][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(26건 | 2024-04-17 00:54:09.127 | 2024-04-17 00:54:09.127) +[2024-04-17 00:54:09.137][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:54:09.129 | 2024-04-17 00:54:09.129) +[2024-04-17 00:54:09.142][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:54:09.132 | 2024-04-17 00:54:09.132) +[2024-04-17 00:54:09.153][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(10건 | 2024-04-17 00:54:09.135 | 2024-04-17 00:54:09.135) +[2024-04-17 00:54:10.081][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(26건 | 2024-04-17 00:54:10.077 | 2024-04-17 00:54:10.077) +[2024-04-17 00:54:10.085][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:54:10.079 | 2024-04-17 00:54:10.079) +[2024-04-17 00:54:10.089][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:54:10.081 | 2024-04-17 00:54:10.081) +[2024-04-17 00:54:10.090][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(9건 | 2024-04-17 00:54:10.085 | 2024-04-17 00:54:10.085) +[2024-04-17 00:54:11.041][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(26건 | 2024-04-17 00:54:11.038 | 2024-04-17 00:54:11.038) +[2024-04-17 00:54:11.044][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:54:11.040 | 2024-04-17 00:54:11.040) +[2024-04-17 00:54:11.047][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:54:11.041 | 2024-04-17 00:54:11.041) +[2024-04-17 00:54:11.048][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(9건 | 2024-04-17 00:54:11.043 | 2024-04-17 00:54:11.043) +[2024-04-17 00:54:12.000][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(26건 | 2024-04-17 00:54:11.996 | 2024-04-17 00:54:11.996) +[2024-04-17 00:54:12.007][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:54:11.998 | 2024-04-17 00:54:11.998) +[2024-04-17 00:54:12.012][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:54:12.000 | 2024-04-17 00:54:12.000) +[2024-04-17 00:54:12.014][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(9건 | 2024-04-17 00:54:12.002 | 2024-04-17 00:54:12.002) +[2024-04-17 00:54:12.958][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(26건 | 2024-04-17 00:54:12.954 | 2024-04-17 00:54:12.954) +[2024-04-17 00:54:12.961][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:54:12.956 | 2024-04-17 00:54:12.956) +[2024-04-17 00:54:12.964][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:54:12.957 | 2024-04-17 00:54:12.957) +[2024-04-17 00:54:12.965][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(11건 | 2024-04-17 00:54:12.959 | 2024-04-17 00:54:12.959) +[2024-04-17 00:54:13.918][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(26건 | 2024-04-17 00:54:13.912 | 2024-04-17 00:54:13.912) +[2024-04-17 00:54:13.922][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:54:13.914 | 2024-04-17 00:54:13.914) +[2024-04-17 00:54:13.926][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:54:13.918 | 2024-04-17 00:54:13.918) +[2024-04-17 00:54:13.929][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(11건 | 2024-04-17 00:54:13.921 | 2024-04-17 00:54:13.921) +[2024-04-17 00:54:14.875][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(26건 | 2024-04-17 00:54:14.872 | 2024-04-17 00:54:14.872) +[2024-04-17 00:54:14.877][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:54:14.874 | 2024-04-17 00:54:14.874) +[2024-04-17 00:54:14.879][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:54:14.875 | 2024-04-17 00:54:14.875) +[2024-04-17 00:54:14.880][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(10건 | 2024-04-17 00:54:14.876 | 2024-04-17 00:54:14.876) +[2024-04-17 00:54:15.834][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(26건 | 2024-04-17 00:54:15.831 | 2024-04-17 00:54:15.831) +[2024-04-17 00:54:15.837][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:54:15.833 | 2024-04-17 00:54:15.833) +[2024-04-17 00:54:15.841][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:54:15.834 | 2024-04-17 00:54:15.834) +[2024-04-17 00:54:15.842][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(10건 | 2024-04-17 00:54:15.835 | 2024-04-17 00:54:15.835) +[2024-04-17 00:54:16.794][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(26건 | 2024-04-17 00:54:16.790 | 2024-04-17 00:54:16.790) +[2024-04-17 00:54:16.796][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:54:16.792 | 2024-04-17 00:54:16.792) +[2024-04-17 00:54:16.799][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:54:16.793 | 2024-04-17 00:54:16.793) +[2024-04-17 00:54:16.801][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(8건 | 2024-04-17 00:54:16.794 | 2024-04-17 00:54:16.794) +[2024-04-17 00:54:17.749][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:54:17.746 | 2024-04-17 00:54:17.746) +[2024-04-17 00:54:17.751][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:54:17.747 | 2024-04-17 00:54:17.747) +[2024-04-17 00:54:17.753][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:54:17.749 | 2024-04-17 00:54:17.749) +[2024-04-17 00:54:17.755][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(7건 | 2024-04-17 00:54:17.750 | 2024-04-17 00:54:17.750) +[2024-04-17 00:54:48.797][I][StartupInfoLogger.logStarting ] Starting AsdeRecvApplication using Java 1.8.0_322 on DESKTOP-32A4E6F with PID 22952 (D:\Workspace\Odroid_repository\EyeGW_AsdeRecv\target\classes started by GMT in D:\Workspace\Odroid_repository\EyeGW_AsdeRecv\target\classes) +[2024-04-17 00:54:48.801][I][SpringApplication.logStartupProfileInfo ] The following 2 profiles are active: "default", "winTest" +[2024-04-17 00:54:50.911][I][TomcatWebServer.initialize ] Tomcat initialized with port(s): 18080 (http) +[2024-04-17 00:54:50.930][I][DirectJDKLog.log ] Initializing ProtocolHandler ["http-nio-18080"] +[2024-04-17 00:54:50.932][I][DirectJDKLog.log ] Starting service [Tomcat] +[2024-04-17 00:54:50.934][I][DirectJDKLog.log ] Starting Servlet engine: [Apache Tomcat/9.0.71] +[2024-04-17 00:54:51.054][I][DirectJDKLog.log ] Initializing Spring embedded WebApplicationContext +[2024-04-17 00:54:51.054][I][tionContext.prepareWebApplicationContext] Root WebApplicationContext: initialization completed in 2146 ms +[2024-04-17 00:54:53.337][I][MulticastIpworks.Initialize ] Multicast Server is running... +[2024-04-17 00:54:54.226][I][EndpointLinksResolver. ] Exposing 1 endpoint(s) beneath base path '/actuator' +[2024-04-17 00:54:54.278][I][DirectJDKLog.log ] Starting ProtocolHandler ["http-nio-18080"] +[2024-04-17 00:54:54.307][I][TomcatWebServer.start ] Tomcat started on port(s): 18080 (http) with context path '' +[2024-04-17 00:54:54.333][I][StartupInfoLogger.logStarted ] Started AsdeRecvApplication in 6.34 seconds (JVM running for 6.924) +[2024-04-17 00:54:54.347][I][UDPManager.initializeUDPFromXML ] [UDPManager] Load file .. : D:\Workspace\Odroid_repository\EyeGW_AsdeRecv\cfg\udpsocket.xml +[2024-04-17 00:54:54.368][I][UDPManager.initializeUDPFromXML ] [UDP Socket] ID : 1 IP : 127.0.0.1 PORT : 52114 +[2024-04-17 00:54:55.553][I][DirectJDKLog.log ] Initializing Spring DispatcherServlet 'dispatcherServlet' +[2024-04-17 00:54:55.554][I][FrameworkServlet.initServletBean ] Initializing Servlet 'dispatcherServlet' +[2024-04-17 00:54:55.557][I][FrameworkServlet.initServletBean ] Completed initialization in 2 ms +[2024-04-17 00:54:56.350][I][UDPSocket.activeSocket ] [UDP Socket] MultiCalstGroup : +239.11.12.5 port:52114 +[2024-04-17 00:54:56.351][I][UDPSocket.activeSocket ] [UDP Socket] recv : 127.0.0.1:52114 +[2024-04-17 00:54:56.351][I][UDPManager.startClient ] [UDP Manager][CONNECTED - PRIMARY][127.0.0.1][52114] +[2024-04-17 00:54:56.352][I][CustomThread.run ] [CustomThread] Started. +[2024-04-17 00:54:56.356][I][AsterixSpecLoader.initCategory ] Initializing.. +[2024-04-17 00:54:56.489][I][AsterixSpecLoader.initCategory ] Category-10 Spec 로드 성공 (파일:spec/alterixCat010Indra.yml) +[2024-04-17 00:54:56.570][I][AsterixSpecLoader.initCategory ] Category-11 Spec 로드 성공 (파일:spec/alterixCat011.yml) +[2024-04-17 00:54:56.570][I][AsterixSpecLoader.initCategory ] initialized. .. +[2024-04-17 00:54:57.141][I][AbstractConfig.logAll ] ProducerConfig values: + acks = -1 + batch.size = 16384 + bootstrap.servers = [10.200.31.6:9091, 10.200.31.8:9091, 10.200.31.142:9091] + 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 = 0 + 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 = 30000 + retries = 2147483647 + 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.connect.timeout.ms = null + sasl.login.read.timeout.ms = 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.login.retry.backoff.max.ms = 10000 + sasl.login.retry.backoff.ms = 100 + sasl.mechanism = GSSAPI + sasl.oauthbearer.clock.skew.seconds = 30 + sasl.oauthbearer.expected.audience = null + sasl.oauthbearer.expected.issuer = null + sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 + sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 + sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 + sasl.oauthbearer.jwks.endpoint.url = null + sasl.oauthbearer.scope.claim.name = scope + sasl.oauthbearer.sub.claim.name = sub + sasl.oauthbearer.token.endpoint.url = null + 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 + +[2024-04-17 00:54:57.183][I][KafkaProducer.configureTransactionState ] [Producer clientId=producer-1] Instantiated an idempotent producer. +[2024-04-17 00:54:57.238][I][AppInfoParser$AppInfo. ] Kafka version: 3.1.2 +[2024-04-17 00:54:57.240][I][AppInfoParser$AppInfo. ] Kafka commitId: f8c67dc3ae0a3265 +[2024-04-17 00:54:57.240][I][AppInfoParser$AppInfo. ] Kafka startTimeMs: 1713315297236 +[2024-04-17 00:54:57.638][W][MetadataUpdater.handleSuccessfulResponse] [Producer clientId=producer-1] Error while fetching metadata with correlation id 1 : {ic.recv.asde_test=LEADER_NOT_AVAILABLE} +[2024-04-17 00:54:57.640][I][Metadata.update ] [Producer clientId=producer-1] Cluster ID: kItbTcR-TnKq97Lzu_1hFA +[2024-04-17 00:54:57.642][I][TransactionManager.setProducerIdAndEpoch] [Producer clientId=producer-1] ProducerId set to 9055 with epoch 0 +[2024-04-17 00:54:57.742][I][Metadata.updateLatestMetadata ] [Producer clientId=producer-1] Resetting the last seen epoch of partition ic.recv.asde_test-0 to 0 since the associated topicId changed from null to WEQoTklxRZyebV-S9DP-Tg +[2024-04-17 00:54:57.772][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:54:57.040 | 2024-04-17 00:54:57.040) +[2024-04-17 00:54:57.813][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(28건 | 2024-04-17 00:54:57.072 | 2024-04-17 00:54:57.072) +[2024-04-17 00:54:57.842][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:54:57.087 | 2024-04-17 00:54:57.087) +[2024-04-17 00:54:57.854][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(5건 | 2024-04-17 00:54:57.093 | 2024-04-17 00:54:57.093) +[2024-04-17 00:54:58.013][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:54:58.001 | 2024-04-17 00:54:58.001) +[2024-04-17 00:54:58.024][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(28건 | 2024-04-17 00:54:58.005 | 2024-04-17 00:54:58.005) +[2024-04-17 00:54:58.042][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:54:58.010 | 2024-04-17 00:54:58.010) +[2024-04-17 00:54:58.046][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(5건 | 2024-04-17 00:54:58.015 | 2024-04-17 00:54:58.015) +[2024-04-17 00:54:58.963][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:54:58.954 | 2024-04-17 00:54:58.954) +[2024-04-17 00:54:58.970][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(28건 | 2024-04-17 00:54:58.958 | 2024-04-17 00:54:58.958) +[2024-04-17 00:54:58.977][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:54:58.961 | 2024-04-17 00:54:58.961) +[2024-04-17 00:54:58.980][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(5건 | 2024-04-17 00:54:58.964 | 2024-04-17 00:54:58.964) +[2024-04-17 00:54:59.922][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:54:59.916 | 2024-04-17 00:54:59.916) +[2024-04-17 00:54:59.925][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(28건 | 2024-04-17 00:54:59.918 | 2024-04-17 00:54:59.918) +[2024-04-17 00:54:59.930][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:54:59.920 | 2024-04-17 00:54:59.920) +[2024-04-17 00:54:59.933][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(7건 | 2024-04-17 00:54:59.921 | 2024-04-17 00:54:59.921) +[2024-04-17 00:55:00.878][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:55:00.873 | 2024-04-17 00:55:00.873) +[2024-04-17 00:55:00.887][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(28건 | 2024-04-17 00:55:00.874 | 2024-04-17 00:55:00.874) +[2024-04-17 00:55:00.893][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:55:00.877 | 2024-04-17 00:55:00.877) +[2024-04-17 00:55:00.897][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(7건 | 2024-04-17 00:55:00.880 | 2024-04-17 00:55:00.880) +[2024-04-17 00:55:01.842][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:55:01.835 | 2024-04-17 00:55:01.835) +[2024-04-17 00:55:01.848][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(28건 | 2024-04-17 00:55:01.838 | 2024-04-17 00:55:01.838) +[2024-04-17 00:55:01.853][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:55:01.840 | 2024-04-17 00:55:01.840) +[2024-04-17 00:55:01.858][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(7건 | 2024-04-17 00:55:01.842 | 2024-04-17 00:55:01.842) +[2024-04-17 00:55:02.796][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:55:02.792 | 2024-04-17 00:55:02.792) +[2024-04-17 00:55:02.817][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(28건 | 2024-04-17 00:55:02.793 | 2024-04-17 00:55:02.793) +[2024-04-17 00:55:02.822][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:55:02.795 | 2024-04-17 00:55:02.795) +[2024-04-17 00:55:02.824][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(7건 | 2024-04-17 00:55:02.797 | 2024-04-17 00:55:02.797) +[2024-04-17 00:55:03.752][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:55:03.748 | 2024-04-17 00:55:03.748) +[2024-04-17 00:55:03.756][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(28건 | 2024-04-17 00:55:03.750 | 2024-04-17 00:55:03.750) +[2024-04-17 00:55:03.761][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:55:03.752 | 2024-04-17 00:55:03.752) +[2024-04-17 00:55:03.763][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(9건 | 2024-04-17 00:55:03.754 | 2024-04-17 00:55:03.754) +[2024-04-17 00:55:04.711][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:55:04.707 | 2024-04-17 00:55:04.707) +[2024-04-17 00:55:04.714][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(28건 | 2024-04-17 00:55:04.709 | 2024-04-17 00:55:04.709) +[2024-04-17 00:55:04.717][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:55:04.710 | 2024-04-17 00:55:04.710) +[2024-04-17 00:55:04.719][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(10건 | 2024-04-17 00:55:04.712 | 2024-04-17 00:55:04.712) +[2024-04-17 00:55:05.670][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:55:05.665 | 2024-04-17 00:55:05.665) +[2024-04-17 00:55:05.674][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(28건 | 2024-04-17 00:55:05.668 | 2024-04-17 00:55:05.668) +[2024-04-17 00:55:05.677][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(27건 | 2024-04-17 00:55:05.670 | 2024-04-17 00:55:05.670) +[2024-04-17 00:55:05.679][I][KafkaProducer.sendASDEMessage ] kafka Produce complate(10건 | 2024-04-17 00:55:05.672 | 2024-04-17 00:55:05.672) diff --git a/pom.xml b/pom.xml index f818428..d682cdb 100644 --- a/pom.xml +++ b/pom.xml @@ -9,7 +9,6 @@ kr.gmtc.gw - asderecv 0.0.1-SNAPSHOT EyeGW_AsdeRecv @@ -28,37 +27,31 @@ - + + org.springframework.boot spring-boot-starter-web - + + + + org.springframework.kafka + spring-kafka kr.gmt.so state-spring-boot-starter - 1.0.3 + 1.0.5 system - ${basedir}/lib/state-spring-boot-starter-1.0.3.jar + ${basedir}/lib/state-spring-boot-starter-1.0.5.jar - - org.projectlombok lombok @@ -66,29 +59,15 @@ provided - - - ipworks.local ipworks-local-1.0.0 system 1.0.0 - ${basedir}/lib/ipworks/local/1.0.0/ipworks-local-1.0.0.jar + ${basedir}/lib/ipworks-local-1.0.0.jar - - - org.yaml @@ -107,7 +86,7 @@ - EyeGW_AsdeRecv-0.0.1 + EyeGW_AsdeRecv org.springframework.boot diff --git a/src/main/java/kr/gmtc/gw/asderecv/asde/parser/AsterixParserThread.java b/src/main/java/kr/gmtc/gw/asderecv/asde/parser/AsterixParserThread.java index 7ef0de6..d646147 100644 --- a/src/main/java/kr/gmtc/gw/asderecv/asde/parser/AsterixParserThread.java +++ b/src/main/java/kr/gmtc/gw/asderecv/asde/parser/AsterixParserThread.java @@ -12,6 +12,7 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; import com.fasterxml.jackson.databind.ObjectMapper; +import kr.gmtc.gw.asderecv.kafka.producer.KafkaProducer; import kr.gmtc.gw.asderecv.rest.vo.ServiceAsdeData; public class AsterixParserThread { @@ -32,8 +33,10 @@ public class AsterixParserThread { DateTimeFormatter dfPattern = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss.SSS"); + KafkaProducer kafkaProducer; + @SuppressWarnings("unused") - public AsterixParserThread(Queue packetQ, HashMap> serviceQueue) { + public AsterixParserThread(Queue packetQ, HashMap> serviceQueue, KafkaProducer kafkaProducer) { thread = new Thread(new Runnable() { @Override public void run() { @@ -75,13 +78,20 @@ public class AsterixParserThread { if(!serviceMap.isEmpty()) { - for(int idx=0; idx srcList = new ArrayList(); + srcList.addAll(serviceMap); + + serviceMap.clear(); + + kafkaProducer.sendASDEMessage(srcList); + + for(int idx=0; idx propMap = new Yaml().load(reader); // �뙆�씪�궡�슜�쓣 JSON �룷硫㏃쑝濡� 蹂��솚 - JSONObject jsonObject = new JSONObject(propMap); + // JSONObject jsonObject = new JSONObject(propMap); // JSON �뜲�씠�꽣瑜� Object濡� 蹂��솚 ObjectMapper objectMapper = new ObjectMapper(); @@ -50,8 +53,10 @@ public class YamlFileLoader { // Array Null媛�, 以묎컙以묎컙 議댁옱�븯吏� �븡�뒗 �븘�뱶 臾댁떆 objectMapper.enable(DeserializationFeature.ACCEPT_EMPTY_ARRAY_AS_NULL_OBJECT); objectMapper.configure(DeserializationFeature.FAIL_ON_MISSING_EXTERNAL_TYPE_ID_PROPERTY, false); - - returnObj = objectMapper.readValue(jsonObject.toJSONString(), cVO); + + //returnObj = objectMapper.readValue(jsonObject.toJSONString(), cVO); + + returnObj = objectMapper.convertValue(propMap, AsterixSpecVO.class ); } catch (Exception e) { e.printStackTrace(); diff --git a/src/main/java/kr/gmtc/gw/asderecv/controller/MainController.java b/src/main/java/kr/gmtc/gw/asderecv/controller/MainController.java index 830746b..e9751f3 100644 --- a/src/main/java/kr/gmtc/gw/asderecv/controller/MainController.java +++ b/src/main/java/kr/gmtc/gw/asderecv/controller/MainController.java @@ -1,8 +1,9 @@ package kr.gmtc.gw.asderecv.controller; import kr.gmt.so.state.StateManager; -import kr.gmt.so.state.callback.IState; +import kr.gmt.so.state.model.SystemState; import kr.gmtc.gw.asderecv.asde.parser.AsterixParserThread; +import kr.gmtc.gw.asderecv.kafka.producer.KafkaProducer; import kr.gmtc.gw.asderecv.rest.ServiceQueManager; import kr.gmtc.gw.asderecv.rest.vo.ServiceAsdeData; import kr.gmtc.gw.asderecv.utils.CmmnUtil; @@ -31,6 +32,10 @@ import javax.annotation.Resource; @Component("controller") public class MainController implements ApplicationListener{ + protected Logger logger; + + protected UDPManager udpManager; + Queue packetQ; HashMap> serviceQueue; @@ -55,18 +60,19 @@ public class MainController implements ApplicationListener{ @Resource(name = "serviceRunnig") private boolean serviceRunnig = false; - protected UDPManager udpManager; private UDPEventListener udpListener; private AsterixParserThread asterixParserThread; private ServiceQueManager serviceQueManager; - protected Logger logger; - + @Autowired private StateManager stateMgr; + @Autowired + private KafkaProducer kafkaProducer; + protected MainController(Queue packetQ, HashMap> serviceQueue){ this.packetQ = packetQ; @@ -82,7 +88,7 @@ public class MainController implements ApplicationListener{ udpListener = createUDPEventListener(); udpManager = new UDPManager(path, udpListener); - asterixParserThread = new AsterixParserThread(packetQ, serviceQueue); + asterixParserThread = new AsterixParserThread(packetQ, serviceQueue, kafkaProducer); asterixParserThread.setScvQcount(scvQcount); asterixParserThread.setDebugLogMode(debugLogMode); @@ -114,7 +120,7 @@ public class MainController implements ApplicationListener{ @Override public void udpDataIn(MsgObjVO vo) { recvPacketAdd(vo); - stateMgr.updateState(); + stateMgr.updateState(SystemState.Normal); } @Override diff --git a/src/main/java/kr/gmtc/gw/asderecv/kafka/config/KafkaConfig.java b/src/main/java/kr/gmtc/gw/asderecv/kafka/config/KafkaConfig.java new file mode 100644 index 0000000..7541b16 --- /dev/null +++ b/src/main/java/kr/gmtc/gw/asderecv/kafka/config/KafkaConfig.java @@ -0,0 +1,41 @@ +package kr.gmtc.gw.asderecv.kafka.config; + +import java.util.HashMap; +import java.util.Map; + +import org.apache.kafka.clients.consumer.ConsumerConfig; +import org.apache.kafka.clients.producer.ProducerConfig; +import org.apache.kafka.common.serialization.StringDeserializer; +import org.apache.kafka.common.serialization.StringSerializer; +import org.springframework.beans.factory.annotation.Value; +import org.springframework.context.annotation.Bean; +import org.springframework.context.annotation.Configuration; +import org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory; +import org.springframework.kafka.core.ConsumerFactory; +import org.springframework.kafka.core.DefaultKafkaConsumerFactory; +import org.springframework.kafka.core.DefaultKafkaProducerFactory; +import org.springframework.kafka.core.KafkaTemplate; +import org.springframework.kafka.core.ProducerFactory; + +@Configuration("KafkaConfig") +public class KafkaConfig { + + @Value("${kafka.bootstrapAddress}") + private String bootstrapServers; + + @Bean + public ProducerFactory producerFactoryString() { + Map configProps = new HashMap<>(); + configProps.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers); + configProps.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class); + configProps.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class); + return new DefaultKafkaProducerFactory<>(configProps); + } + + @Bean + public KafkaTemplate kafkaTemplateString() { + return new KafkaTemplate<>(producerFactoryString()); + } + + +} diff --git a/src/main/java/kr/gmtc/gw/asderecv/kafka/producer/KafkaProducer.java b/src/main/java/kr/gmtc/gw/asderecv/kafka/producer/KafkaProducer.java new file mode 100644 index 0000000..fb13ebd --- /dev/null +++ b/src/main/java/kr/gmtc/gw/asderecv/kafka/producer/KafkaProducer.java @@ -0,0 +1,143 @@ +package kr.gmtc.gw.asderecv.kafka.producer; + +import java.time.LocalDateTime; +import java.time.format.DateTimeFormatter; +import java.util.ArrayList; +import java.util.HashMap; +import java.util.LinkedList; +import java.util.List; +import java.util.Queue; + +import javax.annotation.Resource; + +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.beans.factory.annotation.Value; +import org.springframework.kafka.core.KafkaTemplate; +import org.springframework.scheduling.annotation.Scheduled; +import org.springframework.stereotype.Component; + +import com.fasterxml.jackson.core.JsonProcessingException; +import com.fasterxml.jackson.databind.ObjectMapper; + +import kr.gmt.so.state.StateManager; +import kr.gmtc.gw.asderecv.rest.vo.SacpServiceHeader; +import kr.gmtc.gw.asderecv.rest.vo.SacpServiceVO; +import kr.gmtc.gw.asderecv.rest.vo.ServiceAsdeData; + +// import gmt.common.type.LogLevelType; +// import gmt.logger.GmtLogManager; +// import kr.gmtc.eyegw.rest.vo.ServiceAsdeData; + +@Component("kafkaProducer") +public class KafkaProducer { + + private Logger logger = LoggerFactory.getLogger(this.getClass());; + + @Value("${kafka.message.topic.recv.asde}") + private String topicName; + + @Resource(name = "serviceQueue") + HashMap> sendQueue; + + + @Autowired + private KafkaTemplate kafkaTemplateString; + + ObjectMapper mapper = new ObjectMapper(); + + String sSendMsg = ""; + + boolean loopYn = true; + + @Autowired + private StateManager stateMgr; + + //@Scheduled(fixedDelay = 1000, initialDelay = 1000) + public void sendASDEMessage(List srcList) { + + String sendMsg = ""; + + int qidx = 2; + + stateMgr.updateState(); + + List _srcList = new ArrayList(); + _srcList.addAll(srcList); + + if(stateMgr.isActive()){ + //logger.info("************************** serviceList Count : " + sendQueue.get(qidx).size()); + + long qSize = _srcList.size(); + String logMsg = qSize + "嫄�"; + String sFirstDate = null, sEndDate = null; + + if(qSize > 0){ + loopYn = false; + //sendMsg = makeServiceData(sendQueue.get(qidx)); + sendMsg = makeServiceData(_srcList); + loopYn = true; + + sFirstDate = _srcList.get(0).getRecptn_dt(); + sEndDate = _srcList.get((int) (qSize -1)).getRecptn_dt(); + } + + + if(sendMsg != null && !sendMsg.equals("")){ + kafkaTemplateString.send(topicName, sendMsg); + logger.info("kafka Produce complate(" + logMsg + " | " + sFirstDate + " | " + sEndDate + ")" ); + } + } + + } + + //private String makeServiceData(Queue procQue){ + private String makeServiceData(List srcList){ + + String sendCode, sendMsg ; + SacpServiceHeader jsonHeader = new SacpServiceHeader(); + List jsonData = new ArrayList(); + + sendCode = "200"; + sendMsg = ""; + + SacpServiceVO sacpServiceVO = new SacpServiceVO(); + + for(int idx=0; idx 10 - 100mb + 100GB true @@ -88,20 +88,20 @@ - + - + - +