2023-04-15 15:47:23.169 INFO 11692 --- [main] com.seamew.lottery.LotteryApplication : Starting LotteryApplication on SEAMEW-WINDOWS with PID 11692 (D:\project\java\personal-study-project\lottery\lottery-interfaces\target\classes started by seamew in D:\project\java\personal-study-project\lottery) 2023-04-15 15:47:23.182 INFO 11692 --- [main] com.seamew.lottery.LotteryApplication : No active profile set, falling back to default profiles: default 2023-04-15 15:47:23.860 INFO 11692 --- [main] .s.d.r.c.RepositoryConfigurationDelegate : Multiple Spring Data modules found, entering strict repository configuration mode! 2023-04-15 15:47:23.861 INFO 11692 --- [main] .s.d.r.c.RepositoryConfigurationDelegate : Bootstrapping Spring Data Redis repositories in DEFAULT mode. 2023-04-15 15:47:23.887 INFO 11692 --- [main] .s.d.r.c.RepositoryConfigurationDelegate : Finished Spring Data repository scanning in 13ms. Found 0 Redis repository interfaces. 2023-04-15 15:47:24.337 INFO 11692 --- [main] o.s.b.w.embedded.tomcat.TomcatWebServer : Tomcat initialized with port(s): 8085 (http) 2023-04-15 15:47:24.343 INFO 11692 --- [main] o.apache.catalina.core.StandardService : Starting service [Tomcat] 2023-04-15 15:47:24.343 INFO 11692 --- [main] org.apache.catalina.core.StandardEngine : Starting Servlet engine: [Apache Tomcat/9.0.39] 2023-04-15 15:47:24.413 INFO 11692 --- [main] o.a.c.c.C.[Tomcat].[localhost].[/] : Initializing Spring embedded WebApplicationContext 2023-04-15 15:47:24.413 INFO 11692 --- [main] w.s.c.ServletWebServerApplicationContext : Root WebApplicationContext: initialization completed in 1050 ms 2023-04-15 15:47:25.274 INFO 11692 --- [main] c.s.l.a.worker.LotteryXxlJobConfig : >>>>>>>>>>> xxl-job config init. 2023-04-15 15:47:25.364 INFO 11692 --- [main] o.s.s.concurrent.ThreadPoolTaskExecutor : Initializing ExecutorService 'applicationTaskExecutor' 2023-04-15 15:47:25.588 INFO 11692 --- [main] c.xxl.job.core.executor.XxlJobExecutor : >>>>>>>>>>> xxl-job register jobhandler success, name:lotteryOrderMQStateJobHandler, jobHandler:com.xxl.job.core.handler.impl.MethodJobHandler@5b7ee56c[class com.seamew.lottery.application.worker.LotteryXxlJob#lotteryOrderMQStateJobHandler] 2023-04-15 15:47:25.589 INFO 11692 --- [main] c.xxl.job.core.executor.XxlJobExecutor : >>>>>>>>>>> xxl-job register jobhandler success, name:lotteryActivityStateJobHandler, jobHandler:com.xxl.job.core.handler.impl.MethodJobHandler@311a0b3e[class com.seamew.lottery.application.worker.LotteryXxlJob#lotteryActivityStateJobHandler] 2023-04-15 15:47:25.685 INFO 11692 --- [main] o.a.k.clients.consumer.ConsumerConfig : ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [180.76.231.231:9092] check.crcs = true client.dns.lookup = default client.id = client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = lottery group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 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.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer 2023-04-15 15:47:25.728 INFO 11692 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka version: 2.5.1 2023-04-15 15:47:25.728 INFO 11692 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka commitId: 0efa8fb0f4c73d92 2023-04-15 15:47:25.728 INFO 11692 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka startTimeMs: 1681544845727 2023-04-15 15:47:25.730 INFO 11692 --- [main] o.a.k.clients.consumer.KafkaConsumer : [Consumer clientId=consumer-lottery-1, groupId=lottery] Subscribed to topic(s): lottery_invoice 2023-04-15 15:47:25.731 INFO 11692 --- [main] o.s.s.c.ThreadPoolTaskScheduler : Initializing ExecutorService 2023-04-15 15:47:25.735 INFO 11692 --- [main] o.a.k.clients.consumer.ConsumerConfig : ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [180.76.231.231:9092] check.crcs = true client.dns.lookup = default client.id = client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = lottery group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 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.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer 2023-04-15 15:47:25.738 INFO 11692 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka version: 2.5.1 2023-04-15 15:47:25.738 INFO 11692 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka commitId: 0efa8fb0f4c73d92 2023-04-15 15:47:25.739 INFO 11692 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka startTimeMs: 1681544845738 2023-04-15 15:47:25.739 INFO 11692 --- [main] o.a.k.clients.consumer.KafkaConsumer : [Consumer clientId=consumer-lottery-2, groupId=lottery] Subscribed to topic(s): lottery_invoice 2023-04-15 15:47:25.739 INFO 11692 --- [main] o.s.s.c.ThreadPoolTaskScheduler : Initializing ExecutorService 2023-04-15 15:47:25.740 INFO 11692 --- [main] o.a.k.clients.consumer.ConsumerConfig : ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [180.76.231.231:9092] check.crcs = true client.dns.lookup = default client.id = client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = lottery group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 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.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer 2023-04-15 15:47:25.745 INFO 11692 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka version: 2.5.1 2023-04-15 15:47:25.745 INFO 11692 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka commitId: 0efa8fb0f4c73d92 2023-04-15 15:47:25.745 INFO 11692 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka startTimeMs: 1681544845745 2023-04-15 15:47:25.746 INFO 11692 --- [main] o.a.k.clients.consumer.KafkaConsumer : [Consumer clientId=consumer-lottery-3, groupId=lottery] Subscribed to topic(s): lottery_invoice 2023-04-15 15:47:25.746 INFO 11692 --- [main] o.s.s.c.ThreadPoolTaskScheduler : Initializing ExecutorService 2023-04-15 15:47:25.747 INFO 11692 --- [main] o.a.k.clients.consumer.ConsumerConfig : ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [180.76.231.231:9092] check.crcs = true client.dns.lookup = default client.id = client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = lottery group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 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.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer 2023-04-15 15:47:25.749 INFO 11692 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka version: 2.5.1 2023-04-15 15:47:25.749 INFO 11692 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka commitId: 0efa8fb0f4c73d92 2023-04-15 15:47:25.749 INFO 11692 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka startTimeMs: 1681544845749 2023-04-15 15:47:25.749 INFO 11692 --- [main] o.a.k.clients.consumer.KafkaConsumer : [Consumer clientId=consumer-lottery-4, groupId=lottery] Subscribed to topic(s): lottery_invoice 2023-04-15 15:47:25.749 INFO 11692 --- [main] o.s.s.c.ThreadPoolTaskScheduler : Initializing ExecutorService 2023-04-15 15:47:25.750 INFO 11692 --- [main] o.a.k.clients.consumer.ConsumerConfig : ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [180.76.231.231:9092] check.crcs = true client.dns.lookup = default client.id = client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = lottery group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 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.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer 2023-04-15 15:47:25.752 INFO 11692 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka version: 2.5.1 2023-04-15 15:47:25.752 INFO 11692 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka commitId: 0efa8fb0f4c73d92 2023-04-15 15:47:25.752 INFO 11692 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka startTimeMs: 1681544845752 2023-04-15 15:47:25.752 INFO 11692 --- [main] o.a.k.clients.consumer.KafkaConsumer : [Consumer clientId=consumer-lottery-5, groupId=lottery] Subscribed to topic(s): lottery_invoice 2023-04-15 15:47:25.752 INFO 11692 --- [main] o.s.s.c.ThreadPoolTaskScheduler : Initializing ExecutorService 2023-04-15 15:47:25.753 INFO 11692 --- [main] o.a.k.clients.consumer.ConsumerConfig : ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [180.76.231.231:9092] check.crcs = true client.dns.lookup = default client.id = client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = lottery group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 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.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer 2023-04-15 15:47:25.754 INFO 11692 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka version: 2.5.1 2023-04-15 15:47:25.755 INFO 11692 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka commitId: 0efa8fb0f4c73d92 2023-04-15 15:47:25.755 INFO 11692 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka startTimeMs: 1681544845754 2023-04-15 15:47:25.755 INFO 11692 --- [main] o.a.k.clients.consumer.KafkaConsumer : [Consumer clientId=consumer-lottery-6, groupId=lottery] Subscribed to topic(s): lottery_activity_partake 2023-04-15 15:47:25.755 INFO 11692 --- [main] o.s.s.c.ThreadPoolTaskScheduler : Initializing ExecutorService 2023-04-15 15:47:25.755 INFO 11692 --- [main] o.a.k.clients.consumer.ConsumerConfig : ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [180.76.231.231:9092] check.crcs = true client.dns.lookup = default client.id = client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = lottery group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 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.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer 2023-04-15 15:47:25.757 INFO 11692 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka version: 2.5.1 2023-04-15 15:47:25.757 INFO 11692 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka commitId: 0efa8fb0f4c73d92 2023-04-15 15:47:25.757 INFO 11692 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka startTimeMs: 1681544845757 2023-04-15 15:47:25.757 INFO 11692 --- [main] o.a.k.clients.consumer.KafkaConsumer : [Consumer clientId=consumer-lottery-7, groupId=lottery] Subscribed to topic(s): lottery_activity_partake 2023-04-15 15:47:25.757 INFO 11692 --- [main] o.s.s.c.ThreadPoolTaskScheduler : Initializing ExecutorService 2023-04-15 15:47:25.758 INFO 11692 --- [main] o.a.k.clients.consumer.ConsumerConfig : ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [180.76.231.231:9092] check.crcs = true client.dns.lookup = default client.id = client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = lottery group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 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.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer 2023-04-15 15:47:25.759 INFO 11692 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka version: 2.5.1 2023-04-15 15:47:25.760 INFO 11692 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka commitId: 0efa8fb0f4c73d92 2023-04-15 15:47:25.760 INFO 11692 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka startTimeMs: 1681544845759 2023-04-15 15:47:25.760 INFO 11692 --- [main] o.a.k.clients.consumer.KafkaConsumer : [Consumer clientId=consumer-lottery-8, groupId=lottery] Subscribed to topic(s): lottery_activity_partake 2023-04-15 15:47:25.760 INFO 11692 --- [main] o.s.s.c.ThreadPoolTaskScheduler : Initializing ExecutorService 2023-04-15 15:47:25.760 INFO 11692 --- [main] o.a.k.clients.consumer.ConsumerConfig : ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [180.76.231.231:9092] check.crcs = true client.dns.lookup = default client.id = client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = lottery group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 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.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer 2023-04-15 15:47:25.762 INFO 11692 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka version: 2.5.1 2023-04-15 15:47:25.762 INFO 11692 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka commitId: 0efa8fb0f4c73d92 2023-04-15 15:47:25.762 INFO 11692 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka startTimeMs: 1681544845762 2023-04-15 15:47:25.762 INFO 11692 --- [main] o.a.k.clients.consumer.KafkaConsumer : [Consumer clientId=consumer-lottery-9, groupId=lottery] Subscribed to topic(s): lottery_activity_partake 2023-04-15 15:47:25.762 INFO 11692 --- [main] o.s.s.c.ThreadPoolTaskScheduler : Initializing ExecutorService 2023-04-15 15:47:25.768 INFO 11692 --- [main] o.a.k.clients.consumer.ConsumerConfig : ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [180.76.231.231:9092] check.crcs = true client.dns.lookup = default client.id = client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = lottery group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 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.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer 2023-04-15 15:47:25.769 INFO 11692 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka version: 2.5.1 2023-04-15 15:47:25.769 INFO 11692 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka commitId: 0efa8fb0f4c73d92 2023-04-15 15:47:25.769 INFO 11692 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka startTimeMs: 1681544845769 2023-04-15 15:47:25.769 INFO 11692 --- [main] o.a.k.clients.consumer.KafkaConsumer : [Consumer clientId=consumer-lottery-10, groupId=lottery] Subscribed to topic(s): lottery_activity_partake 2023-04-15 15:47:25.770 INFO 11692 --- [main] o.s.s.c.ThreadPoolTaskScheduler : Initializing ExecutorService 2023-04-15 15:47:25.770 INFO 11692 --- [main] o.a.k.clients.consumer.ConsumerConfig : ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [180.76.231.231:9092] check.crcs = true client.dns.lookup = default client.id = client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = lottery group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 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.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer 2023-04-15 15:47:25.772 INFO 11692 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka version: 2.5.1 2023-04-15 15:47:25.772 INFO 11692 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka commitId: 0efa8fb0f4c73d92 2023-04-15 15:47:25.772 INFO 11692 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka startTimeMs: 1681544845772 2023-04-15 15:47:25.772 INFO 11692 --- [main] o.a.k.clients.consumer.KafkaConsumer : [Consumer clientId=consumer-lottery-11, groupId=lottery] Subscribed to topic(s): lottery_award_surplus_count 2023-04-15 15:47:25.772 INFO 11692 --- [main] o.s.s.c.ThreadPoolTaskScheduler : Initializing ExecutorService 2023-04-15 15:47:25.772 INFO 11692 --- [main] o.a.k.clients.consumer.ConsumerConfig : ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [180.76.231.231:9092] check.crcs = true client.dns.lookup = default client.id = client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = lottery group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 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.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer 2023-04-15 15:47:25.774 INFO 11692 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka version: 2.5.1 2023-04-15 15:47:25.774 INFO 11692 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka commitId: 0efa8fb0f4c73d92 2023-04-15 15:47:25.774 INFO 11692 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka startTimeMs: 1681544845773 2023-04-15 15:47:25.774 INFO 11692 --- [main] o.a.k.clients.consumer.KafkaConsumer : [Consumer clientId=consumer-lottery-12, groupId=lottery] Subscribed to topic(s): lottery_award_surplus_count 2023-04-15 15:47:25.774 INFO 11692 --- [main] o.s.s.c.ThreadPoolTaskScheduler : Initializing ExecutorService 2023-04-15 15:47:25.775 INFO 11692 --- [main] o.a.k.clients.consumer.ConsumerConfig : ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [180.76.231.231:9092] check.crcs = true client.dns.lookup = default client.id = client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = lottery group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 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.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer 2023-04-15 15:47:25.776 INFO 11692 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka version: 2.5.1 2023-04-15 15:47:25.776 INFO 11692 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka commitId: 0efa8fb0f4c73d92 2023-04-15 15:47:25.776 INFO 11692 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka startTimeMs: 1681544845776 2023-04-15 15:47:25.776 INFO 11692 --- [main] o.a.k.clients.consumer.KafkaConsumer : [Consumer clientId=consumer-lottery-13, groupId=lottery] Subscribed to topic(s): lottery_award_surplus_count 2023-04-15 15:47:25.777 INFO 11692 --- [main] o.s.s.c.ThreadPoolTaskScheduler : Initializing ExecutorService 2023-04-15 15:47:25.777 INFO 11692 --- [main] o.a.k.clients.consumer.ConsumerConfig : ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [180.76.231.231:9092] check.crcs = true client.dns.lookup = default client.id = client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = lottery group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 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.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer 2023-04-15 15:47:25.778 INFO 11692 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka version: 2.5.1 2023-04-15 15:47:25.778 INFO 11692 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka commitId: 0efa8fb0f4c73d92 2023-04-15 15:47:25.778 INFO 11692 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka startTimeMs: 1681544845778 2023-04-15 15:47:25.778 INFO 11692 --- [main] o.a.k.clients.consumer.KafkaConsumer : [Consumer clientId=consumer-lottery-14, groupId=lottery] Subscribed to topic(s): lottery_award_surplus_count 2023-04-15 15:47:25.779 INFO 11692 --- [main] o.s.s.c.ThreadPoolTaskScheduler : Initializing ExecutorService 2023-04-15 15:47:25.779 INFO 11692 --- [main] o.a.k.clients.consumer.ConsumerConfig : ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [180.76.231.231:9092] check.crcs = true client.dns.lookup = default client.id = client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = lottery group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 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.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer 2023-04-15 15:47:25.780 INFO 11692 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka version: 2.5.1 2023-04-15 15:47:25.780 INFO 11692 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka commitId: 0efa8fb0f4c73d92 2023-04-15 15:47:25.780 INFO 11692 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka startTimeMs: 1681544845780 2023-04-15 15:47:25.780 INFO 11692 --- [main] o.a.k.clients.consumer.KafkaConsumer : [Consumer clientId=consumer-lottery-15, groupId=lottery] Subscribed to topic(s): lottery_award_surplus_count 2023-04-15 15:47:25.780 INFO 11692 --- [main] o.s.s.c.ThreadPoolTaskScheduler : Initializing ExecutorService 2023-04-15 15:47:25.792 INFO 11692 --- [main] o.s.b.w.embedded.tomcat.TomcatWebServer : Tomcat started on port(s): 8085 (http) with context path '' 2023-04-15 15:47:25.798 INFO 11692 --- [main] com.seamew.lottery.LotteryApplication : Started LotteryApplication in 2.921 seconds (JVM running for 3.958) 2023-04-15 15:47:26.293 INFO 11692 --- [Thread-10] com.xxl.job.core.server.EmbedServer : >>>>>>>>>>> xxl-job remoting server start success, nettype = class com.xxl.job.core.server.EmbedServer, port = 9998 2023-04-15 15:47:27.959 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-11, groupId=lottery] Connection to node -1 (/180.76.231.231:9092) could not be established. Broker may not be available. 2023-04-15 15:47:27.959 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-3-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-4, groupId=lottery] Connection to node -1 (/180.76.231.231:9092) could not be established. Broker may not be available. 2023-04-15 15:47:27.959 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-3-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-4, groupId=lottery] Bootstrap broker 180.76.231.231:9092 (id: -1 rack: null) disconnected 2023-04-15 15:47:27.959 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-4-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-15, groupId=lottery] Connection to node -1 (/180.76.231.231:9092) could not be established. Broker may not be available. 2023-04-15 15:47:27.959 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-4-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-15, groupId=lottery] Bootstrap broker 180.76.231.231:9092 (id: -1 rack: null) disconnected 2023-04-15 15:47:27.959 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-11, groupId=lottery] Bootstrap broker 180.76.231.231:9092 (id: -1 rack: null) disconnected 2023-04-15 15:47:27.959 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-2-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-13, groupId=lottery] Connection to node -1 (/180.76.231.231:9092) could not be established. Broker may not be available. 2023-04-15 15:47:27.959 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-2-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-13, groupId=lottery] Bootstrap broker 180.76.231.231:9092 (id: -1 rack: null) disconnected 2023-04-15 15:47:27.959 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-3-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-9, groupId=lottery] Connection to node -1 (/180.76.231.231:9092) could not be established. Broker may not be available. 2023-04-15 15:47:27.959 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-3-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-9, groupId=lottery] Bootstrap broker 180.76.231.231:9092 (id: -1 rack: null) disconnected 2023-04-15 15:47:27.959 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-4-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-10, groupId=lottery] Connection to node -1 (/180.76.231.231:9092) could not be established. Broker may not be available. 2023-04-15 15:47:27.959 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-6, groupId=lottery] Connection to node -1 (/180.76.231.231:9092) could not be established. Broker may not be available. 2023-04-15 15:47:27.959 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-1-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-12, groupId=lottery] Connection to node -1 (/180.76.231.231:9092) could not be established. Broker may not be available. 2023-04-15 15:47:27.960 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-3-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-14, groupId=lottery] Connection to node -1 (/180.76.231.231:9092) could not be established. Broker may not be available. 2023-04-15 15:47:27.961 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-1-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-12, groupId=lottery] Bootstrap broker 180.76.231.231:9092 (id: -1 rack: null) disconnected 2023-04-15 15:47:27.961 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-3-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-14, groupId=lottery] Bootstrap broker 180.76.231.231:9092 (id: -1 rack: null) disconnected 2023-04-15 15:47:27.960 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-4-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-5, groupId=lottery] Connection to node -1 (/180.76.231.231:9092) could not be established. Broker may not be available. 2023-04-15 15:47:27.961 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-6, groupId=lottery] Bootstrap broker 180.76.231.231:9092 (id: -1 rack: null) disconnected 2023-04-15 15:47:27.961 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-4-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-5, groupId=lottery] Bootstrap broker 180.76.231.231:9092 (id: -1 rack: null) disconnected 2023-04-15 15:47:27.960 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-4-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-10, groupId=lottery] Bootstrap broker 180.76.231.231:9092 (id: -1 rack: null) disconnected 2023-04-15 15:47:27.960 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-2-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-8, groupId=lottery] Connection to node -1 (/180.76.231.231:9092) could not be established. Broker may not be available. 2023-04-15 15:47:27.962 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-2-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-8, groupId=lottery] Bootstrap broker 180.76.231.231:9092 (id: -1 rack: null) disconnected 2023-04-15 15:47:27.960 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-1-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-2, groupId=lottery] Connection to node -1 (/180.76.231.231:9092) could not be established. Broker may not be available. 2023-04-15 15:47:27.960 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-1, groupId=lottery] Connection to node -1 (/180.76.231.231:9092) could not be established. Broker may not be available. 2023-04-15 15:47:27.963 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-1, groupId=lottery] Bootstrap broker 180.76.231.231:9092 (id: -1 rack: null) disconnected 2023-04-15 15:47:27.960 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-1-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-7, groupId=lottery] Connection to node -1 (/180.76.231.231:9092) could not be established. Broker may not be available. 2023-04-15 15:47:27.962 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-1-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-2, groupId=lottery] Bootstrap broker 180.76.231.231:9092 (id: -1 rack: null) disconnected 2023-04-15 15:47:27.963 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-1-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-7, groupId=lottery] Bootstrap broker 180.76.231.231:9092 (id: -1 rack: null) disconnected 2023-04-15 15:47:27.960 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-2-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-3, groupId=lottery] Connection to node -1 (/180.76.231.231:9092) could not be established. Broker may not be available. 2023-04-15 15:47:27.963 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-2-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-3, groupId=lottery] Bootstrap broker 180.76.231.231:9092 (id: -1 rack: null) disconnected 2023-04-15 15:47:30.164 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-3-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-4, groupId=lottery] Connection to node -1 (/180.76.231.231:9092) could not be established. Broker may not be available. 2023-04-15 15:47:30.164 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-3-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-4, groupId=lottery] Bootstrap broker 180.76.231.231:9092 (id: -1 rack: null) disconnected 2023-04-15 15:47:30.164 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-1-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-12, groupId=lottery] Connection to node -1 (/180.76.231.231:9092) could not be established. Broker may not be available. 2023-04-15 15:47:30.164 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-1-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-12, groupId=lottery] Bootstrap broker 180.76.231.231:9092 (id: -1 rack: null) disconnected 2023-04-15 15:47:30.165 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-1-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-2, groupId=lottery] Connection to node -1 (/180.76.231.231:9092) could not be established. Broker may not be available. 2023-04-15 15:47:30.165 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-1-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-2, groupId=lottery] Bootstrap broker 180.76.231.231:9092 (id: -1 rack: null) disconnected 2023-04-15 15:47:30.170 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-3-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-14, groupId=lottery] Connection to node -1 (/180.76.231.231:9092) could not be established. Broker may not be available. 2023-04-15 15:47:30.170 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-3-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-14, groupId=lottery] Bootstrap broker 180.76.231.231:9092 (id: -1 rack: null) disconnected 2023-04-15 15:47:30.170 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-4-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-5, groupId=lottery] Connection to node -1 (/180.76.231.231:9092) could not be established. Broker may not be available. 2023-04-15 15:47:30.170 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-4-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-5, groupId=lottery] Bootstrap broker 180.76.231.231:9092 (id: -1 rack: null) disconnected 2023-04-15 15:47:30.170 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-1-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-7, groupId=lottery] Connection to node -1 (/180.76.231.231:9092) could not be established. Broker may not be available. 2023-04-15 15:47:30.170 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-1-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-7, groupId=lottery] Bootstrap broker 180.76.231.231:9092 (id: -1 rack: null) disconnected 2023-04-15 15:47:30.170 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-1, groupId=lottery] Connection to node -1 (/180.76.231.231:9092) could not be established. Broker may not be available. 2023-04-15 15:47:30.170 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-1, groupId=lottery] Bootstrap broker 180.76.231.231:9092 (id: -1 rack: null) disconnected 2023-04-15 15:47:30.170 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-2-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-13, groupId=lottery] Connection to node -1 (/180.76.231.231:9092) could not be established. Broker may not be available. 2023-04-15 15:47:30.170 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-2-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-13, groupId=lottery] Bootstrap broker 180.76.231.231:9092 (id: -1 rack: null) disconnected 2023-04-15 15:47:30.170 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-2-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-8, groupId=lottery] Connection to node -1 (/180.76.231.231:9092) could not be established. Broker may not be available. 2023-04-15 15:47:30.170 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-2-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-8, groupId=lottery] Bootstrap broker 180.76.231.231:9092 (id: -1 rack: null) disconnected 2023-04-15 15:47:30.171 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-2-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-3, groupId=lottery] Connection to node -1 (/180.76.231.231:9092) could not be established. Broker may not be available. 2023-04-15 15:47:30.171 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-2-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-3, groupId=lottery] Bootstrap broker 180.76.231.231:9092 (id: -1 rack: null) disconnected 2023-04-15 15:47:30.171 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-3-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-9, groupId=lottery] Connection to node -1 (/180.76.231.231:9092) could not be established. Broker may not be available. 2023-04-15 15:47:30.171 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-3-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-9, groupId=lottery] Bootstrap broker 180.76.231.231:9092 (id: -1 rack: null) disconnected 2023-04-15 15:47:30.171 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-4-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-15, groupId=lottery] Connection to node -1 (/180.76.231.231:9092) could not be established. Broker may not be available. 2023-04-15 15:47:30.171 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-4-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-15, groupId=lottery] Bootstrap broker 180.76.231.231:9092 (id: -1 rack: null) disconnected 2023-04-15 15:47:30.171 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-11, groupId=lottery] Connection to node -1 (/180.76.231.231:9092) could not be established. Broker may not be available. 2023-04-15 15:47:30.171 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-11, groupId=lottery] Bootstrap broker 180.76.231.231:9092 (id: -1 rack: null) disconnected 2023-04-15 15:47:30.185 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-6, groupId=lottery] Connection to node -1 (/180.76.231.231:9092) could not be established. Broker may not be available. 2023-04-15 15:47:30.185 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-4-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-10, groupId=lottery] Connection to node -1 (/180.76.231.231:9092) could not be established. Broker may not be available. 2023-04-15 15:47:30.185 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-4-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-10, groupId=lottery] Bootstrap broker 180.76.231.231:9092 (id: -1 rack: null) disconnected 2023-04-15 15:47:30.185 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-6, groupId=lottery] Bootstrap broker 180.76.231.231:9092 (id: -1 rack: null) disconnected 2023-04-15 15:47:32.332 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-3-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-4, groupId=lottery] Connection to node -1 (/180.76.231.231:9092) could not be established. Broker may not be available. 2023-04-15 15:47:32.332 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-3-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-4, groupId=lottery] Bootstrap broker 180.76.231.231:9092 (id: -1 rack: null) disconnected 2023-04-15 15:47:32.347 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-3-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-9, groupId=lottery] Connection to node -1 (/180.76.231.231:9092) could not be established. Broker may not be available. 2023-04-15 15:47:32.348 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-3-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-9, groupId=lottery] Bootstrap broker 180.76.231.231:9092 (id: -1 rack: null) disconnected 2023-04-15 15:47:32.348 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-1-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-2, groupId=lottery] Connection to node -1 (/180.76.231.231:9092) could not be established. Broker may not be available. 2023-04-15 15:47:32.348 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-1-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-2, groupId=lottery] Bootstrap broker 180.76.231.231:9092 (id: -1 rack: null) disconnected 2023-04-15 15:47:32.348 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-1-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-7, groupId=lottery] Connection to node -1 (/180.76.231.231:9092) could not be established. Broker may not be available. 2023-04-15 15:47:32.348 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-1-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-7, groupId=lottery] Bootstrap broker 180.76.231.231:9092 (id: -1 rack: null) disconnected 2023-04-15 15:47:32.348 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-2-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-3, groupId=lottery] Connection to node -1 (/180.76.231.231:9092) could not be established. Broker may not be available. 2023-04-15 15:47:32.349 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-2-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-3, groupId=lottery] Bootstrap broker 180.76.231.231:9092 (id: -1 rack: null) disconnected 2023-04-15 15:47:32.349 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-2-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-13, groupId=lottery] Connection to node -1 (/180.76.231.231:9092) could not be established. Broker may not be available. 2023-04-15 15:47:32.349 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-2-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-13, groupId=lottery] Bootstrap broker 180.76.231.231:9092 (id: -1 rack: null) disconnected 2023-04-15 15:47:32.349 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-3-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-14, groupId=lottery] Connection to node -1 (/180.76.231.231:9092) could not be established. Broker may not be available. 2023-04-15 15:47:32.349 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-3-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-14, groupId=lottery] Bootstrap broker 180.76.231.231:9092 (id: -1 rack: null) disconnected 2023-04-15 15:47:32.349 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-1, groupId=lottery] Connection to node -1 (/180.76.231.231:9092) could not be established. Broker may not be available. 2023-04-15 15:47:32.349 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-1, groupId=lottery] Bootstrap broker 180.76.231.231:9092 (id: -1 rack: null) disconnected 2023-04-15 15:47:32.361 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-4-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-10, groupId=lottery] Connection to node -1 (/180.76.231.231:9092) could not be established. Broker may not be available. 2023-04-15 15:47:32.361 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-4-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-10, groupId=lottery] Bootstrap broker 180.76.231.231:9092 (id: -1 rack: null) disconnected 2023-04-15 15:47:32.410 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-1-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-12, groupId=lottery] Connection to node -1 (/180.76.231.231:9092) could not be established. Broker may not be available. 2023-04-15 15:47:32.410 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-1-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-12, groupId=lottery] Bootstrap broker 180.76.231.231:9092 (id: -1 rack: null) disconnected 2023-04-15 15:47:32.410 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-2-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-8, groupId=lottery] Connection to node -1 (/180.76.231.231:9092) could not be established. Broker may not be available. 2023-04-15 15:47:32.410 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-2-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-8, groupId=lottery] Bootstrap broker 180.76.231.231:9092 (id: -1 rack: null) disconnected 2023-04-15 15:47:32.411 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-4-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-15, groupId=lottery] Connection to node -1 (/180.76.231.231:9092) could not be established. Broker may not be available. 2023-04-15 15:47:32.411 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-4-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-15, groupId=lottery] Bootstrap broker 180.76.231.231:9092 (id: -1 rack: null) disconnected 2023-04-15 15:47:32.411 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-4-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-5, groupId=lottery] Connection to node -1 (/180.76.231.231:9092) could not be established. Broker may not be available. 2023-04-15 15:47:32.411 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-4-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-5, groupId=lottery] Bootstrap broker 180.76.231.231:9092 (id: -1 rack: null) disconnected 2023-04-15 15:47:32.425 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-6, groupId=lottery] Connection to node -1 (/180.76.231.231:9092) could not be established. Broker may not be available. 2023-04-15 15:47:32.426 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-6, groupId=lottery] Bootstrap broker 180.76.231.231:9092 (id: -1 rack: null) disconnected 2023-04-15 15:47:32.427 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-11, groupId=lottery] Connection to node -1 (/180.76.231.231:9092) could not be established. Broker may not be available. 2023-04-15 15:47:32.427 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-11, groupId=lottery] Bootstrap broker 180.76.231.231:9092 (id: -1 rack: null) disconnected 2023-04-15 15:47:34.607 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-4-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-10, groupId=lottery] Connection to node -1 (/180.76.231.231:9092) could not be established. Broker may not be available. 2023-04-15 15:47:34.607 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-4-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-10, groupId=lottery] Bootstrap broker 180.76.231.231:9092 (id: -1 rack: null) disconnected 2023-04-15 15:47:34.659 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-1-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-7, groupId=lottery] Connection to node -1 (/180.76.231.231:9092) could not be established. Broker may not be available. 2023-04-15 15:47:34.659 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-4-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-5, groupId=lottery] Connection to node -1 (/180.76.231.231:9092) could not be established. Broker may not be available. 2023-04-15 15:47:34.659 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-2-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-13, groupId=lottery] Connection to node -1 (/180.76.231.231:9092) could not be established. Broker may not be available. 2023-04-15 15:47:34.659 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-2-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-13, groupId=lottery] Bootstrap broker 180.76.231.231:9092 (id: -1 rack: null) disconnected 2023-04-15 15:47:34.659 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-1, groupId=lottery] Connection to node -1 (/180.76.231.231:9092) could not be established. Broker may not be available. 2023-04-15 15:47:34.659 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-1, groupId=lottery] Bootstrap broker 180.76.231.231:9092 (id: -1 rack: null) disconnected 2023-04-15 15:47:34.659 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-3-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-14, groupId=lottery] Connection to node -1 (/180.76.231.231:9092) could not be established. Broker may not be available. 2023-04-15 15:47:34.659 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-3-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-14, groupId=lottery] Bootstrap broker 180.76.231.231:9092 (id: -1 rack: null) disconnected 2023-04-15 15:47:34.659 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-3-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-9, groupId=lottery] Connection to node -1 (/180.76.231.231:9092) could not be established. Broker may not be available. 2023-04-15 15:47:34.659 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-2-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-3, groupId=lottery] Connection to node -1 (/180.76.231.231:9092) could not be established. Broker may not be available. 2023-04-15 15:47:34.659 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-3-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-4, groupId=lottery] Connection to node -1 (/180.76.231.231:9092) could not be established. Broker may not be available. 2023-04-15 15:47:34.660 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-2-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-3, groupId=lottery] Bootstrap broker 180.76.231.231:9092 (id: -1 rack: null) disconnected 2023-04-15 15:47:34.660 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-3-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-4, groupId=lottery] Bootstrap broker 180.76.231.231:9092 (id: -1 rack: null) disconnected 2023-04-15 15:47:34.659 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-1-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-7, groupId=lottery] Bootstrap broker 180.76.231.231:9092 (id: -1 rack: null) disconnected 2023-04-15 15:47:34.659 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-4-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-5, groupId=lottery] Bootstrap broker 180.76.231.231:9092 (id: -1 rack: null) disconnected 2023-04-15 15:47:34.659 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-3-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-9, groupId=lottery] Bootstrap broker 180.76.231.231:9092 (id: -1 rack: null) disconnected 2023-04-15 15:47:34.674 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-1-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-2, groupId=lottery] Connection to node -1 (/180.76.231.231:9092) could not be established. Broker may not be available. 2023-04-15 15:47:34.674 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-1-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-2, groupId=lottery] Bootstrap broker 180.76.231.231:9092 (id: -1 rack: null) disconnected 2023-04-15 15:47:34.714 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-4-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-15, groupId=lottery] Connection to node -1 (/180.76.231.231:9092) could not be established. Broker may not be available. 2023-04-15 15:47:34.714 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-4-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-15, groupId=lottery] Bootstrap broker 180.76.231.231:9092 (id: -1 rack: null) disconnected 2023-04-15 15:47:34.731 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-6, groupId=lottery] Connection to node -1 (/180.76.231.231:9092) could not be established. Broker may not be available. 2023-04-15 15:47:34.731 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-6, groupId=lottery] Bootstrap broker 180.76.231.231:9092 (id: -1 rack: null) disconnected 2023-04-15 15:47:34.733 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-11, groupId=lottery] Connection to node -1 (/180.76.231.231:9092) could not be established. Broker may not be available. 2023-04-15 15:47:34.733 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-11, groupId=lottery] Bootstrap broker 180.76.231.231:9092 (id: -1 rack: null) disconnected 2023-04-15 15:47:34.737 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-2-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-8, groupId=lottery] Connection to node -1 (/180.76.231.231:9092) could not be established. Broker may not be available. 2023-04-15 15:47:34.737 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-1-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-12, groupId=lottery] Connection to node -1 (/180.76.231.231:9092) could not be established. Broker may not be available. 2023-04-15 15:47:34.737 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-2-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-8, groupId=lottery] Bootstrap broker 180.76.231.231:9092 (id: -1 rack: null) disconnected 2023-04-15 15:47:34.737 WARN 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-1-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-lottery-12, groupId=lottery] Bootstrap broker 180.76.231.231:9092 (id: -1 rack: null) disconnected 2023-04-15 15:47:36.670 INFO 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] o.a.k.clients.consumer.KafkaConsumer : [Consumer clientId=consumer-lottery-1, groupId=lottery] Unsubscribed all topics or patterns and assigned partitions 2023-04-15 15:47:36.671 INFO 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] o.s.s.c.ThreadPoolTaskScheduler : Shutting down ExecutorService 2023-04-15 15:47:36.673 INFO 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] essageListenerContainer$ListenerConsumer : lottery: Consumer stopped 2023-04-15 15:47:36.674 INFO 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-1-C-1] o.a.k.clients.consumer.KafkaConsumer : [Consumer clientId=consumer-lottery-2, groupId=lottery] Unsubscribed all topics or patterns and assigned partitions 2023-04-15 15:47:36.674 INFO 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-1-C-1] o.s.s.c.ThreadPoolTaskScheduler : Shutting down ExecutorService 2023-04-15 15:47:36.674 INFO 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-1-C-1] essageListenerContainer$ListenerConsumer : lottery: Consumer stopped 2023-04-15 15:47:36.675 INFO 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-2-C-1] o.a.k.clients.consumer.KafkaConsumer : [Consumer clientId=consumer-lottery-3, groupId=lottery] Unsubscribed all topics or patterns and assigned partitions 2023-04-15 15:47:36.675 INFO 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-2-C-1] o.s.s.c.ThreadPoolTaskScheduler : Shutting down ExecutorService 2023-04-15 15:47:36.675 INFO 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] o.a.k.clients.consumer.KafkaConsumer : [Consumer clientId=consumer-lottery-6, groupId=lottery] Unsubscribed all topics or patterns and assigned partitions 2023-04-15 15:47:36.675 INFO 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] o.s.s.c.ThreadPoolTaskScheduler : Shutting down ExecutorService 2023-04-15 15:47:36.676 INFO 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-3-C-1] o.a.k.clients.consumer.KafkaConsumer : [Consumer clientId=consumer-lottery-4, groupId=lottery] Unsubscribed all topics or patterns and assigned partitions 2023-04-15 15:47:36.676 INFO 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-3-C-1] o.s.s.c.ThreadPoolTaskScheduler : Shutting down ExecutorService 2023-04-15 15:47:36.676 INFO 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-4-C-1] o.a.k.clients.consumer.KafkaConsumer : [Consumer clientId=consumer-lottery-5, groupId=lottery] Unsubscribed all topics or patterns and assigned partitions 2023-04-15 15:47:36.676 INFO 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-4-C-1] o.s.s.c.ThreadPoolTaskScheduler : Shutting down ExecutorService 2023-04-15 15:47:36.677 INFO 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-1-C-1] o.a.k.clients.consumer.KafkaConsumer : [Consumer clientId=consumer-lottery-7, groupId=lottery] Unsubscribed all topics or patterns and assigned partitions 2023-04-15 15:47:36.678 INFO 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] essageListenerContainer$ListenerConsumer : lottery: Consumer stopped 2023-04-15 15:47:36.677 INFO 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-2-C-1] essageListenerContainer$ListenerConsumer : lottery: Consumer stopped 2023-04-15 15:47:36.679 INFO 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-1-C-1] o.s.s.c.ThreadPoolTaskScheduler : Shutting down ExecutorService 2023-04-15 15:47:36.677 INFO 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-4-C-1] essageListenerContainer$ListenerConsumer : lottery: Consumer stopped 2023-04-15 15:47:36.677 INFO 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-3-C-1] essageListenerContainer$ListenerConsumer : lottery: Consumer stopped 2023-04-15 15:47:36.679 INFO 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-3-C-1] o.a.k.clients.consumer.KafkaConsumer : [Consumer clientId=consumer-lottery-14, groupId=lottery] Unsubscribed all topics or patterns and assigned partitions 2023-04-15 15:47:36.679 INFO 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-3-C-1] o.s.s.c.ThreadPoolTaskScheduler : Shutting down ExecutorService 2023-04-15 15:47:36.679 INFO 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-4-C-1] o.a.k.clients.consumer.KafkaConsumer : [Consumer clientId=consumer-lottery-15, groupId=lottery] Unsubscribed all topics or patterns and assigned partitions 2023-04-15 15:47:36.679 INFO 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-4-C-1] o.s.s.c.ThreadPoolTaskScheduler : Shutting down ExecutorService 2023-04-15 15:47:36.679 INFO 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-2-C-1] o.a.k.clients.consumer.KafkaConsumer : [Consumer clientId=consumer-lottery-13, groupId=lottery] Unsubscribed all topics or patterns and assigned partitions 2023-04-15 15:47:36.679 INFO 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-2-C-1] o.s.s.c.ThreadPoolTaskScheduler : Shutting down ExecutorService 2023-04-15 15:47:36.680 INFO 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-2-C-1] o.a.k.clients.consumer.KafkaConsumer : [Consumer clientId=consumer-lottery-8, groupId=lottery] Unsubscribed all topics or patterns and assigned partitions 2023-04-15 15:47:36.680 INFO 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-2-C-1] o.s.s.c.ThreadPoolTaskScheduler : Shutting down ExecutorService 2023-04-15 15:47:36.680 INFO 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-1-C-1] o.a.k.clients.consumer.KafkaConsumer : [Consumer clientId=consumer-lottery-12, groupId=lottery] Unsubscribed all topics or patterns and assigned partitions 2023-04-15 15:47:36.680 INFO 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-1-C-1] o.s.s.c.ThreadPoolTaskScheduler : Shutting down ExecutorService 2023-04-15 15:47:36.677 INFO 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1] o.a.k.clients.consumer.KafkaConsumer : [Consumer clientId=consumer-lottery-11, groupId=lottery] Unsubscribed all topics or patterns and assigned partitions 2023-04-15 15:47:36.677 INFO 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-3-C-1] o.a.k.clients.consumer.KafkaConsumer : [Consumer clientId=consumer-lottery-9, groupId=lottery] Unsubscribed all topics or patterns and assigned partitions 2023-04-15 15:47:36.681 INFO 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1] o.s.s.c.ThreadPoolTaskScheduler : Shutting down ExecutorService 2023-04-15 15:47:36.681 INFO 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-3-C-1] o.s.s.c.ThreadPoolTaskScheduler : Shutting down ExecutorService 2023-04-15 15:47:36.681 INFO 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-1-C-1] essageListenerContainer$ListenerConsumer : lottery: Consumer stopped 2023-04-15 15:47:36.677 INFO 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-4-C-1] o.a.k.clients.consumer.KafkaConsumer : [Consumer clientId=consumer-lottery-10, groupId=lottery] Unsubscribed all topics or patterns and assigned partitions 2023-04-15 15:47:36.682 INFO 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-4-C-1] o.s.s.c.ThreadPoolTaskScheduler : Shutting down ExecutorService 2023-04-15 15:47:36.683 INFO 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-4-C-1] essageListenerContainer$ListenerConsumer : lottery: Consumer stopped 2023-04-15 15:47:36.683 INFO 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-4-C-1] essageListenerContainer$ListenerConsumer : lottery: Consumer stopped 2023-04-15 15:47:36.684 INFO 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-2-C-1] essageListenerContainer$ListenerConsumer : lottery: Consumer stopped 2023-04-15 15:47:36.684 INFO 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-3-C-1] essageListenerContainer$ListenerConsumer : lottery: Consumer stopped 2023-04-15 15:47:36.684 INFO 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-2-C-1] essageListenerContainer$ListenerConsumer : lottery: Consumer stopped 2023-04-15 15:47:36.684 INFO 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1] essageListenerContainer$ListenerConsumer : lottery: Consumer stopped 2023-04-15 15:47:36.684 INFO 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-1-C-1] essageListenerContainer$ListenerConsumer : lottery: Consumer stopped 2023-04-15 15:47:36.684 INFO 11692 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-3-C-1] essageListenerContainer$ListenerConsumer : lottery: Consumer stopped 2023-04-15 15:47:36.685 INFO 11692 --- [SpringContextShutdownHook] o.s.s.concurrent.ThreadPoolTaskExecutor : Shutting down ExecutorService 'applicationTaskExecutor' 2023-04-15 15:47:36.685 INFO 11692 --- [Thread-10] com.xxl.job.core.server.EmbedServer : >>>>>>>>>>> xxl-job remoting server stop. 2023-04-15 15:47:36.697 INFO 11692 --- [xxl-job, executor ExecutorRegistryThread] c.x.j.c.thread.ExecutorRegistryThread : >>>>>>>>>>> xxl-job registry-remove success, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='lottery-job', registryValue='http://192.168.137.1:9998/'}, registryResult:ReturnT [code=200, msg=null, content=null] 2023-04-15 15:47:36.698 INFO 11692 --- [xxl-job, executor ExecutorRegistryThread] c.x.j.c.thread.ExecutorRegistryThread : >>>>>>>>>>> xxl-job, executor registry thread destroy. 2023-04-15 15:47:36.698 INFO 11692 --- [SpringContextShutdownHook] com.xxl.job.core.server.EmbedServer : >>>>>>>>>>> xxl-job remoting server destroy success. 2023-04-15 15:47:36.698 INFO 11692 --- [xxl-job, executor JobLogFileCleanThread] c.x.j.core.thread.JobLogFileCleanThread : >>>>>>>>>>> xxl-job, executor JobLogFileCleanThread thread destroy. 2023-04-15 15:47:36.698 INFO 11692 --- [xxl-job, executor TriggerCallbackThread] c.x.j.core.thread.TriggerCallbackThread : >>>>>>>>>>> xxl-job, executor callback thread destroy. 2023-04-15 15:47:36.698 INFO 11692 --- [Thread-9] c.x.j.core.thread.TriggerCallbackThread : >>>>>>>>>>> xxl-job, executor retry callback thread destroy. 2023-04-15 15:48:17.920 INFO 18324 --- [main] com.seamew.lottery.LotteryApplication : Starting LotteryApplication on SEAMEW-WINDOWS with PID 18324 (D:\project\java\personal-study-project\lottery\lottery-interfaces\target\classes started by seamew in D:\project\java\personal-study-project\lottery) 2023-04-15 15:48:17.922 INFO 18324 --- [main] com.seamew.lottery.LotteryApplication : No active profile set, falling back to default profiles: default 2023-04-15 15:48:18.410 INFO 18324 --- [main] .s.d.r.c.RepositoryConfigurationDelegate : Multiple Spring Data modules found, entering strict repository configuration mode! 2023-04-15 15:48:18.412 INFO 18324 --- [main] .s.d.r.c.RepositoryConfigurationDelegate : Bootstrapping Spring Data Redis repositories in DEFAULT mode. 2023-04-15 15:48:18.433 INFO 18324 --- [main] .s.d.r.c.RepositoryConfigurationDelegate : Finished Spring Data repository scanning in 13ms. Found 0 Redis repository interfaces. 2023-04-15 15:48:18.787 INFO 18324 --- [main] o.s.b.w.embedded.tomcat.TomcatWebServer : Tomcat initialized with port(s): 8085 (http) 2023-04-15 15:48:18.792 INFO 18324 --- [main] o.apache.catalina.core.StandardService : Starting service [Tomcat] 2023-04-15 15:48:18.792 INFO 18324 --- [main] org.apache.catalina.core.StandardEngine : Starting Servlet engine: [Apache Tomcat/9.0.39] 2023-04-15 15:48:18.837 INFO 18324 --- [main] o.a.c.c.C.[Tomcat].[localhost].[/] : Initializing Spring embedded WebApplicationContext 2023-04-15 15:48:18.837 INFO 18324 --- [main] w.s.c.ServletWebServerApplicationContext : Root WebApplicationContext: initialization completed in 785 ms 2023-04-15 15:48:19.550 INFO 18324 --- [main] c.s.l.a.worker.LotteryXxlJobConfig : >>>>>>>>>>> xxl-job config init. 2023-04-15 15:48:19.627 INFO 18324 --- [main] o.s.s.concurrent.ThreadPoolTaskExecutor : Initializing ExecutorService 'applicationTaskExecutor' 2023-04-15 15:48:19.828 INFO 18324 --- [main] c.xxl.job.core.executor.XxlJobExecutor : >>>>>>>>>>> xxl-job register jobhandler success, name:lotteryOrderMQStateJobHandler, jobHandler:com.xxl.job.core.handler.impl.MethodJobHandler@356341c9[class com.seamew.lottery.application.worker.LotteryXxlJob#lotteryOrderMQStateJobHandler] 2023-04-15 15:48:19.828 INFO 18324 --- [main] c.xxl.job.core.executor.XxlJobExecutor : >>>>>>>>>>> xxl-job register jobhandler success, name:lotteryActivityStateJobHandler, jobHandler:com.xxl.job.core.handler.impl.MethodJobHandler@3a70575[class com.seamew.lottery.application.worker.LotteryXxlJob#lotteryActivityStateJobHandler] 2023-04-15 15:48:19.907 INFO 18324 --- [main] o.a.k.clients.consumer.ConsumerConfig : ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [180.76.231.231:9092] check.crcs = true client.dns.lookup = default client.id = client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = lottery group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 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.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer 2023-04-15 15:48:19.943 INFO 18324 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka version: 2.5.1 2023-04-15 15:48:19.943 INFO 18324 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka commitId: 0efa8fb0f4c73d92 2023-04-15 15:48:19.943 INFO 18324 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka startTimeMs: 1681544899942 2023-04-15 15:48:19.945 INFO 18324 --- [main] o.a.k.clients.consumer.KafkaConsumer : [Consumer clientId=consumer-lottery-1, groupId=lottery] Subscribed to topic(s): lottery_invoice 2023-04-15 15:48:19.946 INFO 18324 --- [main] o.s.s.c.ThreadPoolTaskScheduler : Initializing ExecutorService 2023-04-15 15:48:19.950 INFO 18324 --- [main] o.a.k.clients.consumer.ConsumerConfig : ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [180.76.231.231:9092] check.crcs = true client.dns.lookup = default client.id = client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = lottery group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 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.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer 2023-04-15 15:48:19.954 INFO 18324 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka version: 2.5.1 2023-04-15 15:48:19.954 INFO 18324 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka commitId: 0efa8fb0f4c73d92 2023-04-15 15:48:19.954 INFO 18324 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka startTimeMs: 1681544899954 2023-04-15 15:48:19.954 INFO 18324 --- [main] o.a.k.clients.consumer.KafkaConsumer : [Consumer clientId=consumer-lottery-2, groupId=lottery] Subscribed to topic(s): lottery_invoice 2023-04-15 15:48:19.954 INFO 18324 --- [main] o.s.s.c.ThreadPoolTaskScheduler : Initializing ExecutorService 2023-04-15 15:48:19.955 INFO 18324 --- [main] o.a.k.clients.consumer.ConsumerConfig : ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [180.76.231.231:9092] check.crcs = true client.dns.lookup = default client.id = client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = lottery group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 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.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer 2023-04-15 15:48:19.959 INFO 18324 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka version: 2.5.1 2023-04-15 15:48:19.960 INFO 18324 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka commitId: 0efa8fb0f4c73d92 2023-04-15 15:48:19.960 INFO 18324 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka startTimeMs: 1681544899959 2023-04-15 15:48:19.960 INFO 18324 --- [main] o.a.k.clients.consumer.KafkaConsumer : [Consumer clientId=consumer-lottery-3, groupId=lottery] Subscribed to topic(s): lottery_invoice 2023-04-15 15:48:19.960 INFO 18324 --- [main] o.s.s.c.ThreadPoolTaskScheduler : Initializing ExecutorService 2023-04-15 15:48:19.961 INFO 18324 --- [main] o.a.k.clients.consumer.ConsumerConfig : ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [180.76.231.231:9092] check.crcs = true client.dns.lookup = default client.id = client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = lottery group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 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.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer 2023-04-15 15:48:19.963 INFO 18324 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka version: 2.5.1 2023-04-15 15:48:19.963 INFO 18324 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka commitId: 0efa8fb0f4c73d92 2023-04-15 15:48:19.963 INFO 18324 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka startTimeMs: 1681544899963 2023-04-15 15:48:19.963 INFO 18324 --- [main] o.a.k.clients.consumer.KafkaConsumer : [Consumer clientId=consumer-lottery-4, groupId=lottery] Subscribed to topic(s): lottery_invoice 2023-04-15 15:48:19.963 INFO 18324 --- [main] o.s.s.c.ThreadPoolTaskScheduler : Initializing ExecutorService 2023-04-15 15:48:19.964 INFO 18324 --- [main] o.a.k.clients.consumer.ConsumerConfig : ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [180.76.231.231:9092] check.crcs = true client.dns.lookup = default client.id = client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = lottery group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 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.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer 2023-04-15 15:48:19.966 INFO 18324 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka version: 2.5.1 2023-04-15 15:48:19.966 INFO 18324 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka commitId: 0efa8fb0f4c73d92 2023-04-15 15:48:19.966 INFO 18324 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka startTimeMs: 1681544899966 2023-04-15 15:48:19.966 INFO 18324 --- [main] o.a.k.clients.consumer.KafkaConsumer : [Consumer clientId=consumer-lottery-5, groupId=lottery] Subscribed to topic(s): lottery_invoice 2023-04-15 15:48:19.966 INFO 18324 --- [main] o.s.s.c.ThreadPoolTaskScheduler : Initializing ExecutorService 2023-04-15 15:48:19.967 INFO 18324 --- [main] o.a.k.clients.consumer.ConsumerConfig : ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [180.76.231.231:9092] check.crcs = true client.dns.lookup = default client.id = client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = lottery group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 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.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer 2023-04-15 15:48:19.969 INFO 18324 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka version: 2.5.1 2023-04-15 15:48:19.969 INFO 18324 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka commitId: 0efa8fb0f4c73d92 2023-04-15 15:48:19.969 INFO 18324 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka startTimeMs: 1681544899969 2023-04-15 15:48:19.969 INFO 18324 --- [main] o.a.k.clients.consumer.KafkaConsumer : [Consumer clientId=consumer-lottery-6, groupId=lottery] Subscribed to topic(s): lottery_activity_partake 2023-04-15 15:48:19.969 INFO 18324 --- [main] o.s.s.c.ThreadPoolTaskScheduler : Initializing ExecutorService 2023-04-15 15:48:19.970 INFO 18324 --- [main] o.a.k.clients.consumer.ConsumerConfig : ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [180.76.231.231:9092] check.crcs = true client.dns.lookup = default client.id = client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = lottery group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 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.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer 2023-04-15 15:48:19.972 INFO 18324 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka version: 2.5.1 2023-04-15 15:48:19.972 INFO 18324 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka commitId: 0efa8fb0f4c73d92 2023-04-15 15:48:19.972 INFO 18324 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka startTimeMs: 1681544899972 2023-04-15 15:48:19.972 INFO 18324 --- [main] o.a.k.clients.consumer.KafkaConsumer : [Consumer clientId=consumer-lottery-7, groupId=lottery] Subscribed to topic(s): lottery_activity_partake 2023-04-15 15:48:19.972 INFO 18324 --- [main] o.s.s.c.ThreadPoolTaskScheduler : Initializing ExecutorService 2023-04-15 15:48:19.973 INFO 18324 --- [main] o.a.k.clients.consumer.ConsumerConfig : ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [180.76.231.231:9092] check.crcs = true client.dns.lookup = default client.id = client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = lottery group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 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.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer 2023-04-15 15:48:19.974 INFO 18324 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka version: 2.5.1 2023-04-15 15:48:19.975 INFO 18324 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka commitId: 0efa8fb0f4c73d92 2023-04-15 15:48:19.975 INFO 18324 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka startTimeMs: 1681544899974 2023-04-15 15:48:19.975 INFO 18324 --- [main] o.a.k.clients.consumer.KafkaConsumer : [Consumer clientId=consumer-lottery-8, groupId=lottery] Subscribed to topic(s): lottery_activity_partake 2023-04-15 15:48:19.975 INFO 18324 --- [main] o.s.s.c.ThreadPoolTaskScheduler : Initializing ExecutorService 2023-04-15 15:48:19.975 INFO 18324 --- [main] o.a.k.clients.consumer.ConsumerConfig : ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [180.76.231.231:9092] check.crcs = true client.dns.lookup = default client.id = client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = lottery group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 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.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer 2023-04-15 15:48:19.977 INFO 18324 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka version: 2.5.1 2023-04-15 15:48:19.977 INFO 18324 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka commitId: 0efa8fb0f4c73d92 2023-04-15 15:48:19.978 INFO 18324 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka startTimeMs: 1681544899977 2023-04-15 15:48:19.978 INFO 18324 --- [main] o.a.k.clients.consumer.KafkaConsumer : [Consumer clientId=consumer-lottery-9, groupId=lottery] Subscribed to topic(s): lottery_activity_partake 2023-04-15 15:48:19.978 INFO 18324 --- [main] o.s.s.c.ThreadPoolTaskScheduler : Initializing ExecutorService 2023-04-15 15:48:19.983 INFO 18324 --- [main] o.a.k.clients.consumer.ConsumerConfig : ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [180.76.231.231:9092] check.crcs = true client.dns.lookup = default client.id = client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = lottery group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 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.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer 2023-04-15 15:48:19.985 INFO 18324 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka version: 2.5.1 2023-04-15 15:48:19.985 INFO 18324 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka commitId: 0efa8fb0f4c73d92 2023-04-15 15:48:19.985 INFO 18324 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka startTimeMs: 1681544899985 2023-04-15 15:48:19.985 INFO 18324 --- [main] o.a.k.clients.consumer.KafkaConsumer : [Consumer clientId=consumer-lottery-10, groupId=lottery] Subscribed to topic(s): lottery_activity_partake 2023-04-15 15:48:19.985 INFO 18324 --- [main] o.s.s.c.ThreadPoolTaskScheduler : Initializing ExecutorService 2023-04-15 15:48:19.986 INFO 18324 --- [main] o.a.k.clients.consumer.ConsumerConfig : ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [180.76.231.231:9092] check.crcs = true client.dns.lookup = default client.id = client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = lottery group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 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.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer 2023-04-15 15:48:19.987 INFO 18324 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka version: 2.5.1 2023-04-15 15:48:19.987 INFO 18324 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka commitId: 0efa8fb0f4c73d92 2023-04-15 15:48:19.987 INFO 18324 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka startTimeMs: 1681544899987 2023-04-15 15:48:19.987 INFO 18324 --- [main] o.a.k.clients.consumer.KafkaConsumer : [Consumer clientId=consumer-lottery-11, groupId=lottery] Subscribed to topic(s): lottery_award_surplus_count 2023-04-15 15:48:19.987 INFO 18324 --- [main] o.s.s.c.ThreadPoolTaskScheduler : Initializing ExecutorService 2023-04-15 15:48:19.988 INFO 18324 --- [main] o.a.k.clients.consumer.ConsumerConfig : ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [180.76.231.231:9092] check.crcs = true client.dns.lookup = default client.id = client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = lottery group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 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.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer 2023-04-15 15:48:19.989 INFO 18324 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka version: 2.5.1 2023-04-15 15:48:19.989 INFO 18324 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka commitId: 0efa8fb0f4c73d92 2023-04-15 15:48:19.989 INFO 18324 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka startTimeMs: 1681544899989 2023-04-15 15:48:19.989 INFO 18324 --- [main] o.a.k.clients.consumer.KafkaConsumer : [Consumer clientId=consumer-lottery-12, groupId=lottery] Subscribed to topic(s): lottery_award_surplus_count 2023-04-15 15:48:19.989 INFO 18324 --- [main] o.s.s.c.ThreadPoolTaskScheduler : Initializing ExecutorService 2023-04-15 15:48:19.990 INFO 18324 --- [main] o.a.k.clients.consumer.ConsumerConfig : ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [180.76.231.231:9092] check.crcs = true client.dns.lookup = default client.id = client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = lottery group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 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.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer 2023-04-15 15:48:19.991 INFO 18324 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka version: 2.5.1 2023-04-15 15:48:19.991 INFO 18324 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka commitId: 0efa8fb0f4c73d92 2023-04-15 15:48:19.991 INFO 18324 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka startTimeMs: 1681544899991 2023-04-15 15:48:19.991 INFO 18324 --- [main] o.a.k.clients.consumer.KafkaConsumer : [Consumer clientId=consumer-lottery-13, groupId=lottery] Subscribed to topic(s): lottery_award_surplus_count 2023-04-15 15:48:19.991 INFO 18324 --- [main] o.s.s.c.ThreadPoolTaskScheduler : Initializing ExecutorService 2023-04-15 15:48:19.992 INFO 18324 --- [main] o.a.k.clients.consumer.ConsumerConfig : ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [180.76.231.231:9092] check.crcs = true client.dns.lookup = default client.id = client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = lottery group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 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.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer 2023-04-15 15:48:19.993 INFO 18324 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka version: 2.5.1 2023-04-15 15:48:19.993 INFO 18324 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka commitId: 0efa8fb0f4c73d92 2023-04-15 15:48:19.993 INFO 18324 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka startTimeMs: 1681544899993 2023-04-15 15:48:19.993 INFO 18324 --- [main] o.a.k.clients.consumer.KafkaConsumer : [Consumer clientId=consumer-lottery-14, groupId=lottery] Subscribed to topic(s): lottery_award_surplus_count 2023-04-15 15:48:19.993 INFO 18324 --- [main] o.s.s.c.ThreadPoolTaskScheduler : Initializing ExecutorService 2023-04-15 15:48:19.993 INFO 18324 --- [main] o.a.k.clients.consumer.ConsumerConfig : ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [180.76.231.231:9092] check.crcs = true client.dns.lookup = default client.id = client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = lottery group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 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.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer 2023-04-15 15:48:19.994 INFO 18324 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka version: 2.5.1 2023-04-15 15:48:19.995 INFO 18324 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka commitId: 0efa8fb0f4c73d92 2023-04-15 15:48:19.995 INFO 18324 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka startTimeMs: 1681544899994 2023-04-15 15:48:19.995 INFO 18324 --- [main] o.a.k.clients.consumer.KafkaConsumer : [Consumer clientId=consumer-lottery-15, groupId=lottery] Subscribed to topic(s): lottery_award_surplus_count 2023-04-15 15:48:19.995 INFO 18324 --- [main] o.s.s.c.ThreadPoolTaskScheduler : Initializing ExecutorService 2023-04-15 15:48:20.006 INFO 18324 --- [main] o.s.b.w.embedded.tomcat.TomcatWebServer : Tomcat started on port(s): 8085 (http) with context path '' 2023-04-15 15:48:20.012 INFO 18324 --- [main] com.seamew.lottery.LotteryApplication : Started LotteryApplication in 2.316 seconds (JVM running for 2.938) 2023-04-15 15:48:20.165 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-2-C-1] org.apache.kafka.clients.Metadata : [Consumer clientId=consumer-lottery-13, groupId=lottery] Cluster ID: EBnAOAyMQcCI6C_dT09iPw 2023-04-15 15:48:20.165 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-1-C-1] org.apache.kafka.clients.Metadata : [Consumer clientId=consumer-lottery-7, groupId=lottery] Cluster ID: EBnAOAyMQcCI6C_dT09iPw 2023-04-15 15:48:20.165 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-1-C-1] org.apache.kafka.clients.Metadata : [Consumer clientId=consumer-lottery-12, groupId=lottery] Cluster ID: EBnAOAyMQcCI6C_dT09iPw 2023-04-15 15:48:20.165 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-4-C-1] org.apache.kafka.clients.Metadata : [Consumer clientId=consumer-lottery-10, groupId=lottery] Cluster ID: EBnAOAyMQcCI6C_dT09iPw 2023-04-15 15:48:20.165 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-3-C-1] org.apache.kafka.clients.Metadata : [Consumer clientId=consumer-lottery-4, groupId=lottery] Cluster ID: EBnAOAyMQcCI6C_dT09iPw 2023-04-15 15:48:20.165 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] org.apache.kafka.clients.Metadata : [Consumer clientId=consumer-lottery-1, groupId=lottery] Cluster ID: EBnAOAyMQcCI6C_dT09iPw 2023-04-15 15:48:20.165 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-1-C-1] org.apache.kafka.clients.Metadata : [Consumer clientId=consumer-lottery-2, groupId=lottery] Cluster ID: EBnAOAyMQcCI6C_dT09iPw 2023-04-15 15:48:20.165 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] org.apache.kafka.clients.Metadata : [Consumer clientId=consumer-lottery-6, groupId=lottery] Cluster ID: EBnAOAyMQcCI6C_dT09iPw 2023-04-15 15:48:20.165 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1] org.apache.kafka.clients.Metadata : [Consumer clientId=consumer-lottery-11, groupId=lottery] Cluster ID: EBnAOAyMQcCI6C_dT09iPw 2023-04-15 15:48:20.165 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-2-C-1] org.apache.kafka.clients.Metadata : [Consumer clientId=consumer-lottery-3, groupId=lottery] Cluster ID: EBnAOAyMQcCI6C_dT09iPw 2023-04-15 15:48:20.165 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-4-C-1] org.apache.kafka.clients.Metadata : [Consumer clientId=consumer-lottery-5, groupId=lottery] Cluster ID: EBnAOAyMQcCI6C_dT09iPw 2023-04-15 15:48:20.165 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-4-C-1] org.apache.kafka.clients.Metadata : [Consumer clientId=consumer-lottery-15, groupId=lottery] Cluster ID: EBnAOAyMQcCI6C_dT09iPw 2023-04-15 15:48:20.165 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-3-C-1] org.apache.kafka.clients.Metadata : [Consumer clientId=consumer-lottery-14, groupId=lottery] Cluster ID: EBnAOAyMQcCI6C_dT09iPw 2023-04-15 15:48:20.165 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-2-C-1] org.apache.kafka.clients.Metadata : [Consumer clientId=consumer-lottery-8, groupId=lottery] Cluster ID: EBnAOAyMQcCI6C_dT09iPw 2023-04-15 15:48:20.165 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-3-C-1] org.apache.kafka.clients.Metadata : [Consumer clientId=consumer-lottery-9, groupId=lottery] Cluster ID: EBnAOAyMQcCI6C_dT09iPw 2023-04-15 15:48:20.166 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-1-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-2, groupId=lottery] Discovered group coordinator 180.76.231.231:9092 (id: 2147483647 rack: null) 2023-04-15 15:48:20.166 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-1-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-12, groupId=lottery] Discovered group coordinator 180.76.231.231:9092 (id: 2147483647 rack: null) 2023-04-15 15:48:20.166 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-4-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-5, groupId=lottery] Discovered group coordinator 180.76.231.231:9092 (id: 2147483647 rack: null) 2023-04-15 15:48:20.166 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-1-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-7, groupId=lottery] Discovered group coordinator 180.76.231.231:9092 (id: 2147483647 rack: null) 2023-04-15 15:48:20.166 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-3-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-14, groupId=lottery] Discovered group coordinator 180.76.231.231:9092 (id: 2147483647 rack: null) 2023-04-15 15:48:20.166 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-4-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-10, groupId=lottery] Discovered group coordinator 180.76.231.231:9092 (id: 2147483647 rack: null) 2023-04-15 15:48:20.166 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-2-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-3, groupId=lottery] Discovered group coordinator 180.76.231.231:9092 (id: 2147483647 rack: null) 2023-04-15 15:48:20.166 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-2-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-8, groupId=lottery] Discovered group coordinator 180.76.231.231:9092 (id: 2147483647 rack: null) 2023-04-15 15:48:20.166 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-2-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-13, groupId=lottery] Discovered group coordinator 180.76.231.231:9092 (id: 2147483647 rack: null) 2023-04-15 15:48:20.166 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-3-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-4, groupId=lottery] Discovered group coordinator 180.76.231.231:9092 (id: 2147483647 rack: null) 2023-04-15 15:48:20.166 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-6, groupId=lottery] Discovered group coordinator 180.76.231.231:9092 (id: 2147483647 rack: null) 2023-04-15 15:48:20.166 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-3-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-9, groupId=lottery] Discovered group coordinator 180.76.231.231:9092 (id: 2147483647 rack: null) 2023-04-15 15:48:20.166 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-11, groupId=lottery] Discovered group coordinator 180.76.231.231:9092 (id: 2147483647 rack: null) 2023-04-15 15:48:20.166 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-1, groupId=lottery] Discovered group coordinator 180.76.231.231:9092 (id: 2147483647 rack: null) 2023-04-15 15:48:20.166 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-4-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-15, groupId=lottery] Discovered group coordinator 180.76.231.231:9092 (id: 2147483647 rack: null) 2023-04-15 15:48:20.168 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-3-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-9, groupId=lottery] (Re-)joining group 2023-04-15 15:48:20.168 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-1, groupId=lottery] (Re-)joining group 2023-04-15 15:48:20.168 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-1-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-7, groupId=lottery] (Re-)joining group 2023-04-15 15:48:20.168 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-2-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-8, groupId=lottery] (Re-)joining group 2023-04-15 15:48:20.168 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-2-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-13, groupId=lottery] (Re-)joining group 2023-04-15 15:48:20.168 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-1-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-2, groupId=lottery] (Re-)joining group 2023-04-15 15:48:20.168 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-3-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-4, groupId=lottery] (Re-)joining group 2023-04-15 15:48:20.168 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-1-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-12, groupId=lottery] (Re-)joining group 2023-04-15 15:48:20.168 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-6, groupId=lottery] (Re-)joining group 2023-04-15 15:48:20.168 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-11, groupId=lottery] (Re-)joining group 2023-04-15 15:48:20.169 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-4-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-10, groupId=lottery] (Re-)joining group 2023-04-15 15:48:20.169 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-2-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-3, groupId=lottery] (Re-)joining group 2023-04-15 15:48:20.169 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-4-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-15, groupId=lottery] (Re-)joining group 2023-04-15 15:48:20.169 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-4-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-5, groupId=lottery] (Re-)joining group 2023-04-15 15:48:20.169 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-3-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-14, groupId=lottery] (Re-)joining group 2023-04-15 15:48:20.202 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-1-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-7, groupId=lottery] Join group failed with org.apache.kafka.common.errors.MemberIdRequiredException: The group member needs to have a valid member id before actually entering a consumer group 2023-04-15 15:48:20.202 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-1-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-7, groupId=lottery] (Re-)joining group 2023-04-15 15:48:20.206 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-1-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-2, groupId=lottery] Join group failed with org.apache.kafka.common.errors.MemberIdRequiredException: The group member needs to have a valid member id before actually entering a consumer group 2023-04-15 15:48:20.206 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-1-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-2, groupId=lottery] (Re-)joining group 2023-04-15 15:48:20.206 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-4-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-10, groupId=lottery] Join group failed with org.apache.kafka.common.errors.MemberIdRequiredException: The group member needs to have a valid member id before actually entering a consumer group 2023-04-15 15:48:20.206 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-3-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-9, groupId=lottery] Join group failed with org.apache.kafka.common.errors.MemberIdRequiredException: The group member needs to have a valid member id before actually entering a consumer group 2023-04-15 15:48:20.206 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-4-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-10, groupId=lottery] (Re-)joining group 2023-04-15 15:48:20.206 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-3-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-9, groupId=lottery] (Re-)joining group 2023-04-15 15:48:20.206 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-3-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-14, groupId=lottery] Join group failed with org.apache.kafka.common.errors.MemberIdRequiredException: The group member needs to have a valid member id before actually entering a consumer group 2023-04-15 15:48:20.207 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-3-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-14, groupId=lottery] (Re-)joining group 2023-04-15 15:48:20.209 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-4-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-5, groupId=lottery] Join group failed with org.apache.kafka.common.errors.MemberIdRequiredException: The group member needs to have a valid member id before actually entering a consumer group 2023-04-15 15:48:20.209 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-1-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-12, groupId=lottery] Join group failed with org.apache.kafka.common.errors.MemberIdRequiredException: The group member needs to have a valid member id before actually entering a consumer group 2023-04-15 15:48:20.209 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-4-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-5, groupId=lottery] (Re-)joining group 2023-04-15 15:48:20.209 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-1-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-12, groupId=lottery] (Re-)joining group 2023-04-15 15:48:20.209 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-4-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-15, groupId=lottery] Join group failed with org.apache.kafka.common.errors.MemberIdRequiredException: The group member needs to have a valid member id before actually entering a consumer group 2023-04-15 15:48:20.209 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-4-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-15, groupId=lottery] (Re-)joining group 2023-04-15 15:48:20.210 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-2-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-3, groupId=lottery] Join group failed with org.apache.kafka.common.errors.MemberIdRequiredException: The group member needs to have a valid member id before actually entering a consumer group 2023-04-15 15:48:20.210 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-2-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-3, groupId=lottery] (Re-)joining group 2023-04-15 15:48:20.212 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-1, groupId=lottery] Join group failed with org.apache.kafka.common.errors.MemberIdRequiredException: The group member needs to have a valid member id before actually entering a consumer group 2023-04-15 15:48:20.212 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-1, groupId=lottery] (Re-)joining group 2023-04-15 15:48:20.214 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-2-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-13, groupId=lottery] Join group failed with org.apache.kafka.common.errors.MemberIdRequiredException: The group member needs to have a valid member id before actually entering a consumer group 2023-04-15 15:48:20.214 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-2-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-13, groupId=lottery] (Re-)joining group 2023-04-15 15:48:20.214 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-3-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-4, groupId=lottery] Join group failed with org.apache.kafka.common.errors.MemberIdRequiredException: The group member needs to have a valid member id before actually entering a consumer group 2023-04-15 15:48:20.214 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-3-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-4, groupId=lottery] (Re-)joining group 2023-04-15 15:48:20.216 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-2-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-8, groupId=lottery] Join group failed with org.apache.kafka.common.errors.MemberIdRequiredException: The group member needs to have a valid member id before actually entering a consumer group 2023-04-15 15:48:20.216 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-2-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-8, groupId=lottery] (Re-)joining group 2023-04-15 15:48:20.219 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-11, groupId=lottery] Join group failed with org.apache.kafka.common.errors.MemberIdRequiredException: The group member needs to have a valid member id before actually entering a consumer group 2023-04-15 15:48:20.219 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-11, groupId=lottery] (Re-)joining group 2023-04-15 15:48:20.221 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-6, groupId=lottery] Join group failed with org.apache.kafka.common.errors.MemberIdRequiredException: The group member needs to have a valid member id before actually entering a consumer group 2023-04-15 15:48:20.221 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-6, groupId=lottery] (Re-)joining group 2023-04-15 15:48:20.483 INFO 18324 --- [Thread-8] com.xxl.job.core.server.EmbedServer : >>>>>>>>>>> xxl-job remoting server start success, nettype = class com.xxl.job.core.server.EmbedServer, port = 9998 2023-04-15 15:48:22.575 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-4-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-15, groupId=lottery] Successfully joined group with generation 340 2023-04-15 15:48:22.575 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-1-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-2, groupId=lottery] Successfully joined group with generation 340 2023-04-15 15:48:22.576 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-4-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-lottery-15, groupId=lottery] Adding newly assigned partitions: 2023-04-15 15:48:22.576 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-1-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-lottery-2, groupId=lottery] Adding newly assigned partitions: 2023-04-15 15:48:22.576 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-1-C-1] o.s.k.l.KafkaMessageListenerContainer : lottery: partitions assigned: [] 2023-04-15 15:48:22.576 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-4-C-1] o.s.k.l.KafkaMessageListenerContainer : lottery: partitions assigned: [] 2023-04-15 15:48:22.579 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-11, groupId=lottery] Successfully joined group with generation 340 2023-04-15 15:48:22.579 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-4-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-10, groupId=lottery] Successfully joined group with generation 340 2023-04-15 15:48:22.579 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-lottery-11, groupId=lottery] Adding newly assigned partitions: 2023-04-15 15:48:22.579 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1] o.s.k.l.KafkaMessageListenerContainer : lottery: partitions assigned: [] 2023-04-15 15:48:22.579 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-3-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-14, groupId=lottery] Successfully joined group with generation 340 2023-04-15 15:48:22.579 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-1, groupId=lottery] Successfully joined group with generation 340 2023-04-15 15:48:22.579 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-lottery-1, groupId=lottery] Adding newly assigned partitions: 2023-04-15 15:48:22.579 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-3-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-9, groupId=lottery] Successfully joined group with generation 340 2023-04-15 15:48:22.579 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] o.s.k.l.KafkaMessageListenerContainer : lottery: partitions assigned: [] 2023-04-15 15:48:22.579 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-3-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-4, groupId=lottery] Successfully joined group with generation 340 2023-04-15 15:48:22.580 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-2-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-3, groupId=lottery] Successfully joined group with generation 340 2023-04-15 15:48:22.580 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-2-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-8, groupId=lottery] Successfully joined group with generation 340 2023-04-15 15:48:22.580 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-2-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-lottery-3, groupId=lottery] Adding newly assigned partitions: 2023-04-15 15:48:22.580 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-2-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-13, groupId=lottery] Successfully joined group with generation 340 2023-04-15 15:48:22.579 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-4-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-5, groupId=lottery] Successfully joined group with generation 340 2023-04-15 15:48:22.580 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-2-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-lottery-8, groupId=lottery] Adding newly assigned partitions: 2023-04-15 15:48:22.581 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-3-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-lottery-9, groupId=lottery] Adding newly assigned partitions: 2023-04-15 15:48:22.581 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-2-C-1] o.s.k.l.KafkaMessageListenerContainer : lottery: partitions assigned: [] 2023-04-15 15:48:22.581 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-3-C-1] o.s.k.l.KafkaMessageListenerContainer : lottery: partitions assigned: [] 2023-04-15 15:48:22.581 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-3-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-lottery-14, groupId=lottery] Adding newly assigned partitions: 2023-04-15 15:48:22.581 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-3-C-1] o.s.k.l.KafkaMessageListenerContainer : lottery: partitions assigned: [] 2023-04-15 15:48:22.581 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-1-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-12, groupId=lottery] Successfully joined group with generation 340 2023-04-15 15:48:22.581 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-4-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-lottery-5, groupId=lottery] Adding newly assigned partitions: 2023-04-15 15:48:22.580 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-2-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-lottery-13, groupId=lottery] Adding newly assigned partitions: 2023-04-15 15:48:22.581 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-2-C-1] o.s.k.l.KafkaMessageListenerContainer : lottery: partitions assigned: [] 2023-04-15 15:48:22.581 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-4-C-1] o.s.k.l.KafkaMessageListenerContainer : lottery: partitions assigned: [] 2023-04-15 15:48:22.580 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-2-C-1] o.s.k.l.KafkaMessageListenerContainer : lottery: partitions assigned: [] 2023-04-15 15:48:22.580 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-3-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-lottery-4, groupId=lottery] Adding newly assigned partitions: 2023-04-15 15:48:22.582 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-3-C-1] o.s.k.l.KafkaMessageListenerContainer : lottery: partitions assigned: [] 2023-04-15 15:48:22.582 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-1-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-lottery-12, groupId=lottery] Adding newly assigned partitions: 2023-04-15 15:48:22.582 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-1-C-1] o.s.k.l.KafkaMessageListenerContainer : lottery: partitions assigned: [] 2023-04-15 15:48:22.582 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-6, groupId=lottery] Successfully joined group with generation 340 2023-04-15 15:48:22.582 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-lottery-6, groupId=lottery] Adding newly assigned partitions: 2023-04-15 15:48:22.582 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer : lottery: partitions assigned: [] 2023-04-15 15:48:22.583 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-1-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-7, groupId=lottery] Successfully joined group with generation 340 2023-04-15 15:48:22.583 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-1-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-lottery-7, groupId=lottery] Adding newly assigned partitions: 2023-04-15 15:48:22.583 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-1-C-1] o.s.k.l.KafkaMessageListenerContainer : lottery: partitions assigned: [] 2023-04-15 15:48:22.583 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-4-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-lottery-10, groupId=lottery] Adding newly assigned partitions: lottery_activity_partake-0 2023-04-15 15:48:22.597 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-4-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-lottery-10, groupId=lottery] Setting offset for partition lottery_activity_partake-0 to the committed offset FetchPosition{offset=42910, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[180.76.231.231:9092 (id: 0 rack: null)], epoch=0}} 2023-04-15 15:48:22.598 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-4-C-1] o.s.k.l.KafkaMessageListenerContainer : lottery: partitions assigned: [lottery_activity_partake-0] 2023-04-15 15:49:10.252 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-1-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-7, groupId=lottery] Member consumer-lottery-7-4c1031e5-33ac-4d93-af35-5fb7b917b364 sending LeaveGroup request to coordinator 180.76.231.231:9092 (id: 2147483647 rack: null) due to the consumer unsubscribed from all topics 2023-04-15 15:49:10.252 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-11, groupId=lottery] Member consumer-lottery-11-cc3bd70c-27f1-47a7-893c-db33a1352b3a sending LeaveGroup request to coordinator 180.76.231.231:9092 (id: 2147483647 rack: null) due to the consumer unsubscribed from all topics 2023-04-15 15:49:10.252 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-1, groupId=lottery] Member consumer-lottery-1-db32a779-ef73-47b0-9422-d3fa4f7a84cf sending LeaveGroup request to coordinator 180.76.231.231:9092 (id: 2147483647 rack: null) due to the consumer unsubscribed from all topics 2023-04-15 15:49:10.252 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-1-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-2, groupId=lottery] Member consumer-lottery-2-1fea427c-9c21-4063-b0aa-b2bf14366370 sending LeaveGroup request to coordinator 180.76.231.231:9092 (id: 2147483647 rack: null) due to the consumer unsubscribed from all topics 2023-04-15 15:49:10.252 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-4-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-5, groupId=lottery] Member consumer-lottery-5-22f262a3-15cb-46cd-8898-28814717e70c sending LeaveGroup request to coordinator 180.76.231.231:9092 (id: 2147483647 rack: null) due to the consumer unsubscribed from all topics 2023-04-15 15:49:10.252 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-4-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-lottery-10, groupId=lottery] Revoke previously assigned partitions lottery_activity_partake-0 2023-04-15 15:49:10.252 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-2-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-13, groupId=lottery] Member consumer-lottery-13-b1ce27ff-73ef-4097-ad0f-c89dd06d98fc sending LeaveGroup request to coordinator 180.76.231.231:9092 (id: 2147483647 rack: null) due to the consumer unsubscribed from all topics 2023-04-15 15:49:10.253 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-2-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-8, groupId=lottery] Member consumer-lottery-8-c363068a-31c7-4d64-9937-5baeefa40308 sending LeaveGroup request to coordinator 180.76.231.231:9092 (id: 2147483647 rack: null) due to the consumer unsubscribed from all topics 2023-04-15 15:49:10.253 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-3-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-14, groupId=lottery] Member consumer-lottery-14-10bad1b5-ad7b-43af-ae86-d22a3664d179 sending LeaveGroup request to coordinator 180.76.231.231:9092 (id: 2147483647 rack: null) due to the consumer unsubscribed from all topics 2023-04-15 15:49:10.253 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-6, groupId=lottery] Member consumer-lottery-6-c1fa3268-f181-4fbd-9012-b6ad907413fc sending LeaveGroup request to coordinator 180.76.231.231:9092 (id: 2147483647 rack: null) due to the consumer unsubscribed from all topics 2023-04-15 15:49:10.253 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-4-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-15, groupId=lottery] Member consumer-lottery-15-2747c024-867d-4948-84e8-defe295c23cc sending LeaveGroup request to coordinator 180.76.231.231:9092 (id: 2147483647 rack: null) due to the consumer unsubscribed from all topics 2023-04-15 15:49:10.253 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-1-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-12, groupId=lottery] Member consumer-lottery-12-cabd0d4f-5bab-4d47-8f50-4f0417a33d36 sending LeaveGroup request to coordinator 180.76.231.231:9092 (id: 2147483647 rack: null) due to the consumer unsubscribed from all topics 2023-04-15 15:49:10.252 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-2-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-3, groupId=lottery] Member consumer-lottery-3-5b37f952-7589-4dff-8356-6dafb3663e6a sending LeaveGroup request to coordinator 180.76.231.231:9092 (id: 2147483647 rack: null) due to the consumer unsubscribed from all topics 2023-04-15 15:49:10.253 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-3-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-9, groupId=lottery] Member consumer-lottery-9-ae090fa4-def4-4c9c-85e0-c5410eda2709 sending LeaveGroup request to coordinator 180.76.231.231:9092 (id: 2147483647 rack: null) due to the consumer unsubscribed from all topics 2023-04-15 15:49:10.253 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-4-C-1] o.s.k.l.KafkaMessageListenerContainer : lottery: partitions revoked: [lottery_activity_partake-0] 2023-04-15 15:49:10.253 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-3-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-4, groupId=lottery] Member consumer-lottery-4-60fbf026-ec96-4daa-a1e9-d90b78305950 sending LeaveGroup request to coordinator 180.76.231.231:9092 (id: 2147483647 rack: null) due to the consumer unsubscribed from all topics 2023-04-15 15:49:10.253 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-4-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-lottery-10, groupId=lottery] Member consumer-lottery-10-d1964c41-1bb1-4e5f-985f-395e9dd78888 sending LeaveGroup request to coordinator 180.76.231.231:9092 (id: 2147483647 rack: null) due to the consumer unsubscribed from all topics 2023-04-15 15:49:10.254 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-2-C-1] o.a.k.clients.consumer.KafkaConsumer : [Consumer clientId=consumer-lottery-3, groupId=lottery] Unsubscribed all topics or patterns and assigned partitions 2023-04-15 15:49:10.254 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-1-C-1] o.a.k.clients.consumer.KafkaConsumer : [Consumer clientId=consumer-lottery-12, groupId=lottery] Unsubscribed all topics or patterns and assigned partitions 2023-04-15 15:49:10.254 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1] o.a.k.clients.consumer.KafkaConsumer : [Consumer clientId=consumer-lottery-11, groupId=lottery] Unsubscribed all topics or patterns and assigned partitions 2023-04-15 15:49:10.254 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-3-C-1] o.a.k.clients.consumer.KafkaConsumer : [Consumer clientId=consumer-lottery-9, groupId=lottery] Unsubscribed all topics or patterns and assigned partitions 2023-04-15 15:49:10.254 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-3-C-1] o.a.k.clients.consumer.KafkaConsumer : [Consumer clientId=consumer-lottery-4, groupId=lottery] Unsubscribed all topics or patterns and assigned partitions 2023-04-15 15:49:10.254 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1] o.s.s.c.ThreadPoolTaskScheduler : Shutting down ExecutorService 2023-04-15 15:49:10.254 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-3-C-1] o.s.s.c.ThreadPoolTaskScheduler : Shutting down ExecutorService 2023-04-15 15:49:10.254 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-3-C-1] o.s.s.c.ThreadPoolTaskScheduler : Shutting down ExecutorService 2023-04-15 15:49:10.254 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-4-C-1] o.a.k.clients.consumer.KafkaConsumer : [Consumer clientId=consumer-lottery-10, groupId=lottery] Unsubscribed all topics or patterns and assigned partitions 2023-04-15 15:49:10.254 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-2-C-1] o.a.k.clients.consumer.KafkaConsumer : [Consumer clientId=consumer-lottery-13, groupId=lottery] Unsubscribed all topics or patterns and assigned partitions 2023-04-15 15:49:10.254 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-4-C-1] o.s.s.c.ThreadPoolTaskScheduler : Shutting down ExecutorService 2023-04-15 15:49:10.254 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-1-C-1] o.s.s.c.ThreadPoolTaskScheduler : Shutting down ExecutorService 2023-04-15 15:49:10.254 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] o.a.k.clients.consumer.KafkaConsumer : [Consumer clientId=consumer-lottery-6, groupId=lottery] Unsubscribed all topics or patterns and assigned partitions 2023-04-15 15:49:10.254 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-2-C-1] o.s.s.c.ThreadPoolTaskScheduler : Shutting down ExecutorService 2023-04-15 15:49:10.255 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-3-C-1] o.a.k.clients.consumer.KafkaConsumer : [Consumer clientId=consumer-lottery-14, groupId=lottery] Unsubscribed all topics or patterns and assigned partitions 2023-04-15 15:49:10.255 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-3-C-1] o.s.s.c.ThreadPoolTaskScheduler : Shutting down ExecutorService 2023-04-15 15:49:10.254 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-4-C-1] o.a.k.clients.consumer.KafkaConsumer : [Consumer clientId=consumer-lottery-15, groupId=lottery] Unsubscribed all topics or patterns and assigned partitions 2023-04-15 15:49:10.254 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-2-C-1] o.s.s.c.ThreadPoolTaskScheduler : Shutting down ExecutorService 2023-04-15 15:49:10.255 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-4-C-1] o.s.s.c.ThreadPoolTaskScheduler : Shutting down ExecutorService 2023-04-15 15:49:10.255 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-2-C-1] o.a.k.clients.consumer.KafkaConsumer : [Consumer clientId=consumer-lottery-8, groupId=lottery] Unsubscribed all topics or patterns and assigned partitions 2023-04-15 15:49:10.255 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-2-C-1] o.s.s.c.ThreadPoolTaskScheduler : Shutting down ExecutorService 2023-04-15 15:49:10.255 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-1-C-1] o.a.k.clients.consumer.KafkaConsumer : [Consumer clientId=consumer-lottery-7, groupId=lottery] Unsubscribed all topics or patterns and assigned partitions 2023-04-15 15:49:10.255 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-4-C-1] o.a.k.clients.consumer.KafkaConsumer : [Consumer clientId=consumer-lottery-5, groupId=lottery] Unsubscribed all topics or patterns and assigned partitions 2023-04-15 15:49:10.255 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] o.s.s.c.ThreadPoolTaskScheduler : Shutting down ExecutorService 2023-04-15 15:49:10.255 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-1-C-1] o.s.s.c.ThreadPoolTaskScheduler : Shutting down ExecutorService 2023-04-15 15:49:10.255 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-1-C-1] o.a.k.clients.consumer.KafkaConsumer : [Consumer clientId=consumer-lottery-2, groupId=lottery] Unsubscribed all topics or patterns and assigned partitions 2023-04-15 15:49:10.255 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] o.a.k.clients.consumer.KafkaConsumer : [Consumer clientId=consumer-lottery-1, groupId=lottery] Unsubscribed all topics or patterns and assigned partitions 2023-04-15 15:49:10.255 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-1-C-1] o.s.s.c.ThreadPoolTaskScheduler : Shutting down ExecutorService 2023-04-15 15:49:10.255 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-4-C-1] o.s.s.c.ThreadPoolTaskScheduler : Shutting down ExecutorService 2023-04-15 15:49:10.255 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] o.s.s.c.ThreadPoolTaskScheduler : Shutting down ExecutorService 2023-04-15 15:49:10.272 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-4-C-1] essageListenerContainer$ListenerConsumer : lottery: Consumer stopped 2023-04-15 15:49:10.276 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-1-C-1] essageListenerContainer$ListenerConsumer : lottery: Consumer stopped 2023-04-15 15:49:10.277 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1] essageListenerContainer$ListenerConsumer : lottery: Consumer stopped 2023-04-15 15:49:10.277 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-1-C-1] essageListenerContainer$ListenerConsumer : lottery: Consumer stopped 2023-04-15 15:49:10.277 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-4-C-1] essageListenerContainer$ListenerConsumer : lottery: Consumer stopped 2023-04-15 15:49:10.277 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-3-C-1] essageListenerContainer$ListenerConsumer : lottery: Consumer stopped 2023-04-15 15:49:10.278 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-2-C-1] essageListenerContainer$ListenerConsumer : lottery: Consumer stopped 2023-04-15 15:49:10.278 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-4-C-1] essageListenerContainer$ListenerConsumer : lottery: Consumer stopped 2023-04-15 15:49:10.279 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1] essageListenerContainer$ListenerConsumer : lottery: Consumer stopped 2023-04-15 15:49:10.279 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-3-C-1] essageListenerContainer$ListenerConsumer : lottery: Consumer stopped 2023-04-15 15:49:10.279 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-2-C-1] essageListenerContainer$ListenerConsumer : lottery: Consumer stopped 2023-04-15 15:49:10.279 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-3-C-1] essageListenerContainer$ListenerConsumer : lottery: Consumer stopped 2023-04-15 15:49:10.279 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] essageListenerContainer$ListenerConsumer : lottery: Consumer stopped 2023-04-15 15:49:10.279 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#1-1-C-1] essageListenerContainer$ListenerConsumer : lottery: Consumer stopped 2023-04-15 15:49:10.279 INFO 18324 --- [org.springframework.kafka.KafkaListenerEndpointContainer#2-2-C-1] essageListenerContainer$ListenerConsumer : lottery: Consumer stopped 2023-04-15 15:49:10.280 INFO 18324 --- [SpringContextShutdownHook] o.s.s.concurrent.ThreadPoolTaskExecutor : Shutting down ExecutorService 'applicationTaskExecutor' 2023-04-15 15:49:10.280 INFO 18324 --- [Thread-8] com.xxl.job.core.server.EmbedServer : >>>>>>>>>>> xxl-job remoting server stop. 2023-04-15 15:49:10.293 INFO 18324 --- [xxl-job, executor ExecutorRegistryThread] c.x.j.c.thread.ExecutorRegistryThread : >>>>>>>>>>> xxl-job registry-remove success, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='lottery-job', registryValue='http://192.168.137.1:9998/'}, registryResult:ReturnT [code=200, msg=null, content=null] 2023-04-15 15:49:10.293 INFO 18324 --- [xxl-job, executor ExecutorRegistryThread] c.x.j.c.thread.ExecutorRegistryThread : >>>>>>>>>>> xxl-job, executor registry thread destroy. 2023-04-15 15:49:10.293 INFO 18324 --- [SpringContextShutdownHook] com.xxl.job.core.server.EmbedServer : >>>>>>>>>>> xxl-job remoting server destroy success. 2023-04-15 15:49:10.293 INFO 18324 --- [xxl-job, executor JobLogFileCleanThread] c.x.j.core.thread.JobLogFileCleanThread : >>>>>>>>>>> xxl-job, executor JobLogFileCleanThread thread destroy. 2023-04-15 15:49:10.293 INFO 18324 --- [xxl-job, executor TriggerCallbackThread] c.x.j.core.thread.TriggerCallbackThread : >>>>>>>>>>> xxl-job, executor callback thread destroy. 2023-04-15 15:49:10.293 INFO 18324 --- [Thread-7] c.x.j.core.thread.TriggerCallbackThread : >>>>>>>>>>> xxl-job, executor retry callback thread destroy.