lottery/logs/log_all.log

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.