Skip to content

M
marketing
Commit 7f90382e authored by 宋新宇's avatar 宋新宇
Browse files
Options

抖音短剧归因

parent 7926dd47
Hide whitespace changes
Inline Side-by-side
Showing with 0 additions and 3936 deletions
logs/common-service-error.log deleted 100644 → 0
View file @ 7926dd47
[traceId=] 2024-03-14 16:00:33.214 -ERROR http-nio-8081-exec-1:o.a.c.c.C.[.[.[.[dispatcherServlet]:175 - Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Request processing failed; nested exception is org.springframework.jdbc.IncorrectResultSetColumnCountException: Incorrect column count: expected 1, actual 5] with root cause
org.springframework.jdbc.IncorrectResultSetColumnCountException: Incorrect column count: expected 1, actual 5
at org.springframework.jdbc.core.SingleColumnRowMapper.mapRow(SingleColumnRowMapper.java:108)
at org.springframework.jdbc.core.RowMapperResultSetExtractor.extractData(RowMapperResultSetExtractor.java:94)
at org.springframework.jdbc.core.RowMapperResultSetExtractor.extractData(RowMapperResultSetExtractor.java:61)
at org.springframework.jdbc.core.JdbcTemplate$1QueryStatementCallback.doInStatement(JdbcTemplate.java:453)
at org.springframework.jdbc.core.JdbcTemplate.execute(JdbcTemplate.java:381)
at org.springframework.jdbc.core.JdbcTemplate.query(JdbcTemplate.java:465)
at org.springframework.jdbc.core.JdbcTemplate.query(JdbcTemplate.java:475)
at org.springframework.jdbc.core.JdbcTemplate.queryForList(JdbcTemplate.java:520)
at com.lwby.marketing.controller.AttrController.getCrossPlatformMedia(AttrController.java:182)
at com.lwby.marketing.controller.AttrController.testCross(AttrController.java:171)
at com.lwby.marketing.controller.AttrController$$FastClassBySpringCGLIB$$5028e458.invoke(<generated>)
at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218)
at org.springframework.aop.framework.CglibAopProxy.invokeMethod(CglibAopProxy.java:386)
at org.springframework.aop.framework.CglibAopProxy.access$000(CglibAopProxy.java:85)
at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:704)
at com.lwby.marketing.controller.AttrController$$EnhancerBySpringCGLIB$$bf0173ff.testCross(<generated>)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.springframework.web.method.support.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:205)
at org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java:150)
at org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:117)
at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandlerMethod(RequestMappingHandlerAdapter.java:895)
at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java:808)
at org.springframework.web.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java:87)
at org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:1071)
at org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:964)
at org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:1006)
at org.springframework.web.servlet.FrameworkServlet.doGet(FrameworkServlet.java:898)
at javax.servlet.http.HttpServlet.service(HttpServlet.java:670)
at org.springframework.web.servlet.FrameworkServlet.service(FrameworkServlet.java:883)
at javax.servlet.http.HttpServlet.service(HttpServlet.java:779)
at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:227)
at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:162)
at org.apache.tomcat.websocket.server.WsFilter.doFilter(WsFilter.java:53)
at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:189)
at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:162)
at org.springframework.web.filter.RequestContextFilter.doFilterInternal(RequestContextFilter.java:100)
at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:117)
at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:189)
at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:162)
at org.springframework.web.filter.FormContentFilter.doFilterInternal(FormContentFilter.java:93)
at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:117)
at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:189)
at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:162)
at org.springframework.boot.actuate.metrics.web.servlet.WebMvcMetricsFilter.doFilterInternal(WebMvcMetricsFilter.java:96)
at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:117)
at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:189)
at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:162)
at org.springframework.web.filter.CharacterEncodingFilter.doFilterInternal(CharacterEncodingFilter.java:201)
at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:117)
at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:189)
at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:162)
at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:197)
at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:97)
at org.apache.catalina.authenticator.AuthenticatorBase.invoke(AuthenticatorBase.java:541)
at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:135)
at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:92)
at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:78)
at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:360)
at org.apache.coyote.http11.Http11Processor.service(Http11Processor.java:399)
at org.apache.coyote.AbstractProcessorLight.process(AbstractProcessorLight.java:65)
at org.apache.coyote.AbstractProtocol$ConnectionHandler.process(AbstractProtocol.java:893)
at org.apache.tomcat.util.net.NioEndpoint$SocketProcessor.doRun(NioEndpoint.java:1789)
at org.apache.tomcat.util.net.SocketProcessorBase.run(SocketProcessorBase.java:49)
at org.apache.tomcat.util.threads.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1191)
at org.apache.tomcat.util.threads.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:659)
at org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61)
at java.lang.Thread.run(Thread.java:748)
[traceId=] 2024-03-14 16:00:33.264 -ERROR org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1:o.a.k.c.c.i.ConsumerCoordinator:1231 - [Consumer clientId=consumer-test_novel_dy_active-1, groupId=test_novel_dy_active] Offset commit failed on partition testNovelActive-0 at offset 0: The coordinator is not aware of this member.
[traceId=] 2024-03-14 16:08:15.695 -ERROR http-nio-8081-exec-2:o.a.c.c.C.[.[.[.[dispatcherServlet]:175 - Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Request processing failed; nested exception is org.springframework.jdbc.IncorrectResultSetColumnCountException: Incorrect column count: expected 1, actual 4] with root cause
org.springframework.jdbc.IncorrectResultSetColumnCountException: Incorrect column count: expected 1, actual 4
at org.springframework.jdbc.core.SingleColumnRowMapper.mapRow(SingleColumnRowMapper.java:108)
at org.springframework.jdbc.core.RowMapperResultSetExtractor.extractData(RowMapperResultSetExtractor.java:94)
at org.springframework.jdbc.core.RowMapperResultSetExtractor.extractData(RowMapperResultSetExtractor.java:61)
at org.springframework.jdbc.core.JdbcTemplate$1QueryStatementCallback.doInStatement(JdbcTemplate.java:453)
at org.springframework.jdbc.core.JdbcTemplate.execute(JdbcTemplate.java:381)
at org.springframework.jdbc.core.JdbcTemplate.query(JdbcTemplate.java:465)
at org.springframework.jdbc.core.JdbcTemplate.query(JdbcTemplate.java:475)
at org.springframework.jdbc.core.JdbcTemplate.queryForList(JdbcTemplate.java:520)
at com.lwby.marketing.controller.AttrController.getCrossPlatformMedia(AttrController.java:182)
at com.lwby.marketing.controller.AttrController.testCross(AttrController.java:171)
at com.lwby.marketing.controller.AttrController$$FastClassBySpringCGLIB$$5028e458.invoke(<generated>)
at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218)
at org.springframework.aop.framework.CglibAopProxy.invokeMethod(CglibAopProxy.java:386)
at org.springframework.aop.framework.CglibAopProxy.access$000(CglibAopProxy.java:85)
at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:704)
at com.lwby.marketing.controller.AttrController$$EnhancerBySpringCGLIB$$e991faaa.testCross(<generated>)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.springframework.web.method.support.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:205)
at org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java:150)
at org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:117)
at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandlerMethod(RequestMappingHandlerAdapter.java:895)
at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java:808)
at org.springframework.web.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java:87)
at org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:1071)
at org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:964)
at org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:1006)
at org.springframework.web.servlet.FrameworkServlet.doGet(FrameworkServlet.java:898)
at javax.servlet.http.HttpServlet.service(HttpServlet.java:670)
at org.springframework.web.servlet.FrameworkServlet.service(FrameworkServlet.java:883)
at javax.servlet.http.HttpServlet.service(HttpServlet.java:779)
at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:227)
at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:162)
at org.apache.tomcat.websocket.server.WsFilter.doFilter(WsFilter.java:53)
at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:189)
at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:162)
at org.springframework.web.filter.RequestContextFilter.doFilterInternal(RequestContextFilter.java:100)
at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:117)
at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:189)
at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:162)
at org.springframework.web.filter.FormContentFilter.doFilterInternal(FormContentFilter.java:93)
at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:117)
at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:189)
at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:162)
at org.springframework.boot.actuate.metrics.web.servlet.WebMvcMetricsFilter.doFilterInternal(WebMvcMetricsFilter.java:96)
at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:117)
at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:189)
at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:162)
at org.springframework.web.filter.CharacterEncodingFilter.doFilterInternal(CharacterEncodingFilter.java:201)
at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:117)
at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:189)
at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:162)
at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:197)
at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:97)
at org.apache.catalina.authenticator.AuthenticatorBase.invoke(AuthenticatorBase.java:541)
at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:135)
at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:92)
at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:78)
at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:360)
at org.apache.coyote.http11.Http11Processor.service(Http11Processor.java:399)
at org.apache.coyote.AbstractProcessorLight.process(AbstractProcessorLight.java:65)
at org.apache.coyote.AbstractProtocol$ConnectionHandler.process(AbstractProtocol.java:893)
at org.apache.tomcat.util.net.NioEndpoint$SocketProcessor.doRun(NioEndpoint.java:1789)
at org.apache.tomcat.util.net.SocketProcessorBase.run(SocketProcessorBase.java:49)
at org.apache.tomcat.util.threads.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1191)
at org.apache.tomcat.util.threads.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:659)
at org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61)
at java.lang.Thread.run(Thread.java:748)
logs/common-service.log deleted 100644 → 0
View file @ 7926dd47
This source diff could not be displayed because it is too large. You can view the blob instead.
logs/history/2024-03-07/common-service-error.2024-03-07-0.log deleted 100644 → 0
View file @ 7926dd47
[traceId=] 2024-03-07 16:45:12.921 -ERROR org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1:c.l.m.a.s.StoryNovelPayConsumer:46 - story.novel.pay.onMessage failed, data={"clientInfo":{"pkv":1,"platformId":601},"createTime":1709800560175,"extraData":{},"id":"17e45093-f226-4ee3-a6c8-c3bf363f61a6","openId":"_0001oR1eBGI2jG-UEcOlP4xI1qhuRLIbuo2","productId":"1","userId":3,"userUploadEvent":2}, costTime=6547 ms
java.lang.NullPointerException: null
at com.lwby.marketing.att.storynovel.handle.ParameterSetupStoryNovelFlow.process(ParameterSetupStoryNovelFlow.java:47)
at com.lwby.marketing.att.storynovel.handle.ParameterSetupStoryNovelFlow.process(ParameterSetupStoryNovelFlow.java:18)
at com.lwby.marketing.flow.FlowExecutor.executeNormalNode(FlowExecutor.java:51)
at com.lwby.marketing.flow.FlowExecutor.execute(FlowExecutor.java:32)
at com.lwby.marketing.att.storynovel.StoryNovelPayConsumer.onMessage(StoryNovelPayConsumer.java:44)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:169)
at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:119)
at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:56)
at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:347)
at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:92)
at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:53)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2588)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:2569)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2483)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:2405)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:2284)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:1958)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeIfHaveRecords(KafkaMessageListenerContainer.java:1353)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1344)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1236)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run$$$capture(FutureTask.java:266)
at java.util.concurrent.FutureTask.run(FutureTask.java)
at java.lang.Thread.run(Thread.java:748)
logs/history/2024-03-07/common-service.2024-03-07-0.log deleted 100644 → 0
View file @ 7926dd47
[traceId=] 2024-03-07 16:44:58.302 - INFO main:c.l.marketing.Main:55 - Starting Main using Java 1.8.0_141 on DESKTOP-7OBDIPT with PID 14056 (D:\lanwan\workspace\20240122\marketing\target\classes started by Lenovo in D:\lanwan\workspace\20240122\marketing)
[traceId=] 2024-03-07 16:44:58.307 - INFO main:c.l.marketing.Main:640 - The following 1 profile is active: "test"
[traceId=] 2024-03-07 16:44:59.734 - INFO main:o.s.d.r.c.RepositoryConfigurationDelegate:262 - Multiple Spring Data modules found, entering strict repository configuration mode
[traceId=] 2024-03-07 16:44:59.737 - INFO main:o.s.d.r.c.RepositoryConfigurationDelegate:132 - Bootstrapping Spring Data Redis repositories in DEFAULT mode.
[traceId=] 2024-03-07 16:44:59.781 - INFO main:o.s.d.r.c.RepositoryConfigurationDelegate:201 - Finished Spring Data repository scanning in 23 ms. Found 0 Redis repository interfaces.
[traceId=] 2024-03-07 16:45:00.100 - INFO main:o.s.c.s.PostProcessorRegistrationDelegate$BeanPostProcessorChecker:376 - Bean 'com.alicp.jetcache.anno.config.JetCacheProxyConfiguration' of type [com.alicp.jetcache.anno.config.JetCacheProxyConfiguration$$EnhancerBySpringCGLIB$$10e98224] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
[traceId=] 2024-03-07 16:45:00.162 - INFO main:o.s.c.s.PostProcessorRegistrationDelegate$BeanPostProcessorChecker:376 - Bean 'com.alicp.jetcache.anno.config.CommonConfiguration' of type [com.alicp.jetcache.anno.config.CommonConfiguration$$EnhancerBySpringCGLIB$$8fefc79c] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
[traceId=] 2024-03-07 16:45:00.524 - INFO main:o.s.b.w.e.t.TomcatWebServer:108 - Tomcat initialized with port(s): 8081 (http)
[traceId=] 2024-03-07 16:45:00.532 - INFO main:o.a.c.h.Http11NioProtocol:173 - Initializing ProtocolHandler ["http-nio-8081"]
[traceId=] 2024-03-07 16:45:00.533 - INFO main:o.a.c.c.StandardService:173 - Starting service [Tomcat]
[traceId=] 2024-03-07 16:45:00.533 - INFO main:o.a.c.c.StandardEngine:173 - Starting Servlet engine: [Apache Tomcat/9.0.68]
[traceId=] 2024-03-07 16:45:00.771 - INFO main:o.a.c.c.C.[.[.[/]:173 - Initializing Spring embedded WebApplicationContext
[traceId=] 2024-03-07 16:45:00.771 - INFO main:o.s.b.w.s.c.ServletWebServerApplicationContext:292 - Root WebApplicationContext: initialization completed in 2330 ms
[traceId=] 2024-03-07 16:45:01.807 - INFO main:c.a.j.a.AbstractCacheAutoInit:65 - init cache area default , type= linkedhashmap
[traceId=] 2024-03-07 16:45:01.830 - INFO main:c.a.j.s.DefaultMetricsManager:84 - cache stat period at 15 MINUTES
[traceId=] 2024-03-07 16:45:02.342 - INFO main:o.s.b.a.e.w.EndpointLinksResolver:58 - Exposing 13 endpoint(s) beneath base path '/actuator'
[traceId=] 2024-03-07 16:45:02.461 - INFO main:o.a.k.c.c.ConsumerConfig:376 - ConsumerConfig values:
allow.auto.create.topics = true
auto.commit.interval.ms = 5000
auto.offset.reset = earliest
bootstrap.servers = [172.17.255.113:9092]
check.crcs = true
client.dns.lookup = use_all_dns_ips
client.id = consumer-test_story_dy_pay-1
client.rack =
connections.max.idle.ms = 540000
default.api.timeout.ms = 60000
enable.auto.commit = true
exclude.internal.topics = true
fetch.max.bytes = 52428800
fetch.max.wait.ms = 500
fetch.min.bytes = 1
group.id = test_story_dy_pay
group.instance.id = null
heartbeat.interval.ms = 3000
interceptor.classes = []
internal.leave.group.on.close = true
internal.throw.on.fetch.stable.offset.unsupported = false
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, class org.apache.kafka.clients.consumer.CooperativeStickyAssignor]
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.connect.timeout.ms = null
sasl.login.read.timeout.ms = null
sasl.login.refresh.buffer.seconds = 300
sasl.login.refresh.min.period.seconds = 60
sasl.login.refresh.window.factor = 0.8
sasl.login.refresh.window.jitter = 0.05
sasl.login.retry.backoff.max.ms = 10000
sasl.login.retry.backoff.ms = 100
sasl.mechanism = GSSAPI
sasl.oauthbearer.clock.skew.seconds = 30
sasl.oauthbearer.expected.audience = null
sasl.oauthbearer.expected.issuer = null
sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000
sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000
sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100
sasl.oauthbearer.jwks.endpoint.url = null
sasl.oauthbearer.scope.claim.name = scope
sasl.oauthbearer.sub.claim.name = sub
sasl.oauthbearer.token.endpoint.url = null
security.protocol = PLAINTEXT
security.providers = null
send.buffer.bytes = 131072
session.timeout.ms = 45000
socket.connection.setup.timeout.max.ms = 30000
socket.connection.setup.timeout.ms = 10000
ssl.cipher.suites = null
ssl.enabled.protocols = [TLSv1.2]
ssl.endpoint.identification.algorithm = https
ssl.engine.factory.class = null
ssl.key.password = null
ssl.keymanager.algorithm = SunX509
ssl.keystore.certificate.chain = null
ssl.keystore.key = null
ssl.keystore.location = null
ssl.keystore.password = null
ssl.keystore.type = JKS
ssl.protocol = TLSv1.2
ssl.provider = null
ssl.secure.random.implementation = null
ssl.trustmanager.algorithm = PKIX
ssl.truststore.certificates = null
ssl.truststore.location = null
ssl.truststore.password = null
ssl.truststore.type = JKS
value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
[traceId=] 2024-03-07 16:45:02.555 - INFO main:o.a.k.c.u.AppInfoParser:119 - Kafka version: 3.1.2
[traceId=] 2024-03-07 16:45:02.555 - INFO main:o.a.k.c.u.AppInfoParser:120 - Kafka commitId: f8c67dc3ae0a3265
[traceId=] 2024-03-07 16:45:02.555 - INFO main:o.a.k.c.u.AppInfoParser:121 - Kafka startTimeMs: 1709801102553
[traceId=] 2024-03-07 16:45:02.586 - INFO main:o.a.k.c.c.KafkaConsumer:966 - [Consumer clientId=consumer-test_story_dy_pay-1, groupId=test_story_dy_pay] Subscribed to topic(s): testStoryNovelpay
[traceId=] 2024-03-07 16:45:02.603 - INFO main:o.a.k.c.c.ConsumerConfig:376 - ConsumerConfig values:
allow.auto.create.topics = true
auto.commit.interval.ms = 5000
auto.offset.reset = earliest
bootstrap.servers = [172.17.255.113:9092]
check.crcs = true
client.dns.lookup = use_all_dns_ips
client.id = consumer-test_novel_dy_active-2
client.rack =
connections.max.idle.ms = 540000
default.api.timeout.ms = 60000
enable.auto.commit = true
exclude.internal.topics = true
fetch.max.bytes = 52428800
fetch.max.wait.ms = 500
fetch.min.bytes = 1
group.id = test_novel_dy_active
group.instance.id = null
heartbeat.interval.ms = 3000
interceptor.classes = []
internal.leave.group.on.close = true
internal.throw.on.fetch.stable.offset.unsupported = false
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, class org.apache.kafka.clients.consumer.CooperativeStickyAssignor]
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.connect.timeout.ms = null
sasl.login.read.timeout.ms = null
sasl.login.refresh.buffer.seconds = 300
sasl.login.refresh.min.period.seconds = 60
sasl.login.refresh.window.factor = 0.8
sasl.login.refresh.window.jitter = 0.05
sasl.login.retry.backoff.max.ms = 10000
sasl.login.retry.backoff.ms = 100
sasl.mechanism = GSSAPI
sasl.oauthbearer.clock.skew.seconds = 30
sasl.oauthbearer.expected.audience = null
sasl.oauthbearer.expected.issuer = null
sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000
sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000
sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100
sasl.oauthbearer.jwks.endpoint.url = null
sasl.oauthbearer.scope.claim.name = scope
sasl.oauthbearer.sub.claim.name = sub
sasl.oauthbearer.token.endpoint.url = null
security.protocol = PLAINTEXT
security.providers = null
send.buffer.bytes = 131072
session.timeout.ms = 45000
socket.connection.setup.timeout.max.ms = 30000
socket.connection.setup.timeout.ms = 10000
ssl.cipher.suites = null
ssl.enabled.protocols = [TLSv1.2]
ssl.endpoint.identification.algorithm = https
ssl.engine.factory.class = null
ssl.key.password = null
ssl.keymanager.algorithm = SunX509
ssl.keystore.certificate.chain = null
ssl.keystore.key = null
ssl.keystore.location = null
ssl.keystore.password = null
ssl.keystore.type = JKS
ssl.protocol = TLSv1.2
ssl.provider = null
ssl.secure.random.implementation = null
ssl.trustmanager.algorithm = PKIX
ssl.truststore.certificates = null
ssl.truststore.location = null
ssl.truststore.password = null
ssl.truststore.type = JKS
value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
[traceId=] 2024-03-07 16:45:02.616 - INFO main:o.a.k.c.u.AppInfoParser:119 - Kafka version: 3.1.2
[traceId=] 2024-03-07 16:45:02.616 - INFO main:o.a.k.c.u.AppInfoParser:120 - Kafka commitId: f8c67dc3ae0a3265
[traceId=] 2024-03-07 16:45:02.616 - INFO main:o.a.k.c.u.AppInfoParser:121 - Kafka startTimeMs: 1709801102616
[traceId=] 2024-03-07 16:45:02.629 - INFO main:o.a.k.c.c.KafkaConsumer:966 - [Consumer clientId=consumer-test_novel_dy_active-2, groupId=test_novel_dy_active] Subscribed to topic(s): testNovelActive
[traceId=] 2024-03-07 16:45:02.633 - INFO main:o.a.k.c.c.ConsumerConfig:376 - ConsumerConfig values:
allow.auto.create.topics = true
auto.commit.interval.ms = 5000
auto.offset.reset = earliest
bootstrap.servers = [172.17.255.113:9092]
check.crcs = true
client.dns.lookup = use_all_dns_ips
client.id = consumer-test_story_dy_active-3
client.rack =
connections.max.idle.ms = 540000
default.api.timeout.ms = 60000
enable.auto.commit = true
exclude.internal.topics = true
fetch.max.bytes = 52428800
fetch.max.wait.ms = 500
fetch.min.bytes = 1
group.id = test_story_dy_active
group.instance.id = null
heartbeat.interval.ms = 3000
interceptor.classes = []
internal.leave.group.on.close = true
internal.throw.on.fetch.stable.offset.unsupported = false
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, class org.apache.kafka.clients.consumer.CooperativeStickyAssignor]
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.connect.timeout.ms = null
sasl.login.read.timeout.ms = null
sasl.login.refresh.buffer.seconds = 300
sasl.login.refresh.min.period.seconds = 60
sasl.login.refresh.window.factor = 0.8
sasl.login.refresh.window.jitter = 0.05
sasl.login.retry.backoff.max.ms = 10000
sasl.login.retry.backoff.ms = 100
sasl.mechanism = GSSAPI
sasl.oauthbearer.clock.skew.seconds = 30
sasl.oauthbearer.expected.audience = null
sasl.oauthbearer.expected.issuer = null
sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000
sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000
sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100
sasl.oauthbearer.jwks.endpoint.url = null
sasl.oauthbearer.scope.claim.name = scope
sasl.oauthbearer.sub.claim.name = sub
sasl.oauthbearer.token.endpoint.url = null
security.protocol = PLAINTEXT
security.providers = null
send.buffer.bytes = 131072
session.timeout.ms = 45000
socket.connection.setup.timeout.max.ms = 30000
socket.connection.setup.timeout.ms = 10000
ssl.cipher.suites = null
ssl.enabled.protocols = [TLSv1.2]
ssl.endpoint.identification.algorithm = https
ssl.engine.factory.class = null
ssl.key.password = null
ssl.keymanager.algorithm = SunX509
ssl.keystore.certificate.chain = null
ssl.keystore.key = null
ssl.keystore.location = null
ssl.keystore.password = null
ssl.keystore.type = JKS
ssl.protocol = TLSv1.2
ssl.provider = null
ssl.secure.random.implementation = null
ssl.trustmanager.algorithm = PKIX
ssl.truststore.certificates = null
ssl.truststore.location = null
ssl.truststore.password = null
ssl.truststore.type = JKS
value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
[traceId=] 2024-03-07 16:45:02.645 - INFO main:o.a.k.c.u.AppInfoParser:119 - Kafka version: 3.1.2
[traceId=] 2024-03-07 16:45:02.646 - INFO main:o.a.k.c.u.AppInfoParser:120 - Kafka commitId: f8c67dc3ae0a3265
[traceId=] 2024-03-07 16:45:02.646 - INFO main:o.a.k.c.u.AppInfoParser:121 - Kafka startTimeMs: 1709801102645
[traceId=] 2024-03-07 16:45:02.658 - INFO main:o.a.k.c.c.KafkaConsumer:966 - [Consumer clientId=consumer-test_story_dy_active-3, groupId=test_story_dy_active] Subscribed to topic(s): testStoryNovelActive
[traceId=] 2024-03-07 16:45:02.660 - INFO main:o.a.c.h.Http11NioProtocol:173 - Starting ProtocolHandler ["http-nio-8081"]
[traceId=] 2024-03-07 16:45:02.679 - INFO main:o.s.b.w.e.t.TomcatWebServer:220 - Tomcat started on port(s): 8081 (http) with context path ''
[traceId=] 2024-03-07 16:45:02.704 - INFO main:c.l.marketing.Main:61 - Started Main in 5.213 seconds (JVM running for 8.565)
[traceId=] 2024-03-07 16:45:03.129 - INFO org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1:o.a.k.c.Metadata:287 - [Consumer clientId=consumer-test_story_dy_pay-1, groupId=test_story_dy_pay] Cluster ID: S20Z6oWOQ5-RFjHUZlW-lQ
[traceId=] 2024-03-07 16:45:03.129 - INFO org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1:o.a.k.c.Metadata:287 - [Consumer clientId=consumer-test_story_dy_active-3, groupId=test_story_dy_active] Cluster ID: S20Z6oWOQ5-RFjHUZlW-lQ
[traceId=] 2024-03-07 16:45:03.130 - INFO org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1:o.a.k.c.Metadata:287 - [Consumer clientId=consumer-test_novel_dy_active-2, groupId=test_novel_dy_active] Cluster ID: S20Z6oWOQ5-RFjHUZlW-lQ
[traceId=] 2024-03-07 16:45:03.132 - INFO org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1:o.a.k.c.c.i.ConsumerCoordinator:853 - [Consumer clientId=consumer-test_story_dy_active-3, groupId=test_story_dy_active] Discovered group coordinator 172.17.255.113:9092 (id: 2147482868 rack: null)
[traceId=] 2024-03-07 16:45:03.132 - INFO org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1:o.a.k.c.c.i.ConsumerCoordinator:853 - [Consumer clientId=consumer-test_novel_dy_active-2, groupId=test_novel_dy_active] Discovered group coordinator 172.17.255.113:9092 (id: 2147482868 rack: null)
[traceId=] 2024-03-07 16:45:03.132 - INFO org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1:o.a.k.c.c.i.ConsumerCoordinator:853 - [Consumer clientId=consumer-test_story_dy_pay-1, groupId=test_story_dy_pay] Discovered group coordinator 172.17.255.113:9092 (id: 2147482868 rack: null)
[traceId=] 2024-03-07 16:45:03.138 - INFO org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1:o.a.k.c.c.i.ConsumerCoordinator:535 - [Consumer clientId=consumer-test_novel_dy_active-2, groupId=test_novel_dy_active] (Re-)joining group
[traceId=] 2024-03-07 16:45:03.138 - INFO org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1:o.a.k.c.c.i.ConsumerCoordinator:535 - [Consumer clientId=consumer-test_story_dy_active-3, groupId=test_story_dy_active] (Re-)joining group
[traceId=] 2024-03-07 16:45:03.138 - INFO org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1:o.a.k.c.c.i.ConsumerCoordinator:535 - [Consumer clientId=consumer-test_story_dy_pay-1, groupId=test_story_dy_pay] (Re-)joining group
[traceId=] 2024-03-07 16:45:03.183 - INFO org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1:o.a.k.c.c.i.ConsumerCoordinator:1000 - [Consumer clientId=consumer-test_novel_dy_active-2, groupId=test_novel_dy_active] Request joining group due to: need to re-join with the given member-id
[traceId=] 2024-03-07 16:45:03.183 - INFO org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1:o.a.k.c.c.i.ConsumerCoordinator:1000 - [Consumer clientId=consumer-test_story_dy_pay-1, groupId=test_story_dy_pay] Request joining group due to: need to re-join with the given member-id
[traceId=] 2024-03-07 16:45:03.183 - INFO org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1:o.a.k.c.c.i.ConsumerCoordinator:1000 - [Consumer clientId=consumer-test_story_dy_active-3, groupId=test_story_dy_active] Request joining group due to: need to re-join with the given member-id
[traceId=] 2024-03-07 16:45:03.183 - INFO org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1:o.a.k.c.c.i.ConsumerCoordinator:535 - [Consumer clientId=consumer-test_story_dy_pay-1, groupId=test_story_dy_pay] (Re-)joining group
[traceId=] 2024-03-07 16:45:03.183 - INFO org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1:o.a.k.c.c.i.ConsumerCoordinator:535 - [Consumer clientId=consumer-test_novel_dy_active-2, groupId=test_novel_dy_active] (Re-)joining group
[traceId=] 2024-03-07 16:45:03.183 - INFO org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1:o.a.k.c.c.i.ConsumerCoordinator:535 - [Consumer clientId=consumer-test_story_dy_active-3, groupId=test_story_dy_active] (Re-)joining group
[traceId=] 2024-03-07 16:45:04.284 - INFO RMI TCP Connection(1)-192.168.215.8:o.a.c.c.C.[.[.[/]:173 - Initializing Spring DispatcherServlet 'dispatcherServlet'
[traceId=] 2024-03-07 16:45:04.284 - INFO RMI TCP Connection(1)-192.168.215.8:o.s.w.s.DispatcherServlet:525 - Initializing Servlet 'dispatcherServlet'
[traceId=] 2024-03-07 16:45:04.286 - INFO RMI TCP Connection(1)-192.168.215.8:o.s.w.s.DispatcherServlet:547 - Completed initialization in 1 ms
[traceId=] 2024-03-07 16:45:06.197 - INFO org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1:o.a.k.c.c.i.ConsumerCoordinator:595 - [Consumer clientId=consumer-test_novel_dy_active-2, groupId=test_novel_dy_active] Successfully joined group with generation Generation{generationId=46, memberId='consumer-test_novel_dy_active-2-32b27c7d-6d99-4e79-bd19-51275bc50916', protocol='range'}
[traceId=] 2024-03-07 16:45:06.197 - INFO org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1:o.a.k.c.c.i.ConsumerCoordinator:595 - [Consumer clientId=consumer-test_story_dy_pay-1, groupId=test_story_dy_pay] Successfully joined group with generation Generation{generationId=46, memberId='consumer-test_story_dy_pay-1-75482434-1733-4062-82d9-f4b3c998bf2c', protocol='range'}
[traceId=] 2024-03-07 16:45:06.197 - INFO org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1:o.a.k.c.c.i.ConsumerCoordinator:595 - [Consumer clientId=consumer-test_story_dy_active-3, groupId=test_story_dy_active] Successfully joined group with generation Generation{generationId=37, memberId='consumer-test_story_dy_active-3-f8be6b17-f994-487c-83ab-9e303d668b7d', protocol='range'}
[traceId=] 2024-03-07 16:45:06.207 - INFO org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1:o.a.k.c.c.i.ConsumerCoordinator:659 - [Consumer clientId=consumer-test_story_dy_pay-1, groupId=test_story_dy_pay] Finished assignment for group at generation 46: {consumer-test_story_dy_pay-1-75482434-1733-4062-82d9-f4b3c998bf2c=Assignment(partitions=[testStoryNovelpay-0])}
[traceId=] 2024-03-07 16:45:06.207 - INFO org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1:o.a.k.c.c.i.ConsumerCoordinator:659 - [Consumer clientId=consumer-test_story_dy_active-3, groupId=test_story_dy_active] Finished assignment for group at generation 37: {consumer-test_story_dy_active-3-f8be6b17-f994-487c-83ab-9e303d668b7d=Assignment(partitions=[testStoryNovelActive-0])}
[traceId=] 2024-03-07 16:45:06.207 - INFO org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1:o.a.k.c.c.i.ConsumerCoordinator:659 - [Consumer clientId=consumer-test_novel_dy_active-2, groupId=test_novel_dy_active] Finished assignment for group at generation 46: {consumer-test_novel_dy_active-2-32b27c7d-6d99-4e79-bd19-51275bc50916=Assignment(partitions=[testNovelActive-0])}
[traceId=] 2024-03-07 16:45:06.243 - INFO org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1:o.a.k.c.c.i.ConsumerCoordinator:761 - [Consumer clientId=consumer-test_story_dy_active-3, groupId=test_story_dy_active] Successfully synced group in generation Generation{generationId=37, memberId='consumer-test_story_dy_active-3-f8be6b17-f994-487c-83ab-9e303d668b7d', protocol='range'}
[traceId=] 2024-03-07 16:45:06.243 - INFO org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1:o.a.k.c.c.i.ConsumerCoordinator:761 - [Consumer clientId=consumer-test_novel_dy_active-2, groupId=test_novel_dy_active] Successfully synced group in generation Generation{generationId=46, memberId='consumer-test_novel_dy_active-2-32b27c7d-6d99-4e79-bd19-51275bc50916', protocol='range'}
[traceId=] 2024-03-07 16:45:06.243 - INFO org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1:o.a.k.c.c.i.ConsumerCoordinator:761 - [Consumer clientId=consumer-test_story_dy_pay-1, groupId=test_story_dy_pay] Successfully synced group in generation Generation{generationId=46, memberId='consumer-test_story_dy_pay-1-75482434-1733-4062-82d9-f4b3c998bf2c', protocol='range'}
[traceId=] 2024-03-07 16:45:06.244 - INFO org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1:o.a.k.c.c.i.ConsumerCoordinator:280 - [Consumer clientId=consumer-test_novel_dy_active-2, groupId=test_novel_dy_active] Notifying assignor about the new Assignment(partitions=[testNovelActive-0])
[traceId=] 2024-03-07 16:45:06.244 - INFO org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1:o.a.k.c.c.i.ConsumerCoordinator:280 - [Consumer clientId=consumer-test_story_dy_active-3, groupId=test_story_dy_active] Notifying assignor about the new Assignment(partitions=[testStoryNovelActive-0])
[traceId=] 2024-03-07 16:45:06.244 - INFO org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1:o.a.k.c.c.i.ConsumerCoordinator:280 - [Consumer clientId=consumer-test_story_dy_pay-1, groupId=test_story_dy_pay] Notifying assignor about the new Assignment(partitions=[testStoryNovelpay-0])
[traceId=] 2024-03-07 16:45:06.250 - INFO org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1:o.a.k.c.c.i.ConsumerCoordinator:292 - [Consumer clientId=consumer-test_story_dy_active-3, groupId=test_story_dy_active] Adding newly assigned partitions: testStoryNovelActive-0
[traceId=] 2024-03-07 16:45:06.250 - INFO org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1:o.a.k.c.c.i.ConsumerCoordinator:292 - [Consumer clientId=consumer-test_novel_dy_active-2, groupId=test_novel_dy_active] Adding newly assigned partitions: testNovelActive-0
[traceId=] 2024-03-07 16:45:06.250 - INFO org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1:o.a.k.c.c.i.ConsumerCoordinator:292 - [Consumer clientId=consumer-test_story_dy_pay-1, groupId=test_story_dy_pay] Adding newly assigned partitions: testStoryNovelpay-0
[traceId=] 2024-03-07 16:45:06.277 - INFO org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1:o.a.k.c.c.i.ConsumerCoordinator:851 - [Consumer clientId=consumer-test_story_dy_pay-1, groupId=test_story_dy_pay] Setting offset for partition testStoryNovelpay-0 to the committed offset FetchPosition{offset=3, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.17.255.113:9092 (id: 779 rack: null)], epoch=absent}}
[traceId=] 2024-03-07 16:45:06.277 - INFO org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1:o.a.k.c.c.i.ConsumerCoordinator:851 - [Consumer clientId=consumer-test_story_dy_active-3, groupId=test_story_dy_active] Setting offset for partition testStoryNovelActive-0 to the committed offset FetchPosition{offset=25, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.17.255.113:9092 (id: 779 rack: null)], epoch=absent}}
[traceId=] 2024-03-07 16:45:06.277 - INFO org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1:o.a.k.c.c.i.ConsumerCoordinator:851 - [Consumer clientId=consumer-test_novel_dy_active-2, groupId=test_novel_dy_active] Setting offset for partition testNovelActive-0 to the committed offset FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.255.113:9092 (id: 779 rack: null)], epoch=absent}}
[traceId=] 2024-03-07 16:45:06.279 - INFO org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1:o.s.k.l.KafkaMessageListenerContainer:292 - test_story_dy_active: partitions assigned: [testStoryNovelActive-0]
[traceId=] 2024-03-07 16:45:06.279 - INFO org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1:o.s.k.l.KafkaMessageListenerContainer:292 - test_novel_dy_active: partitions assigned: [testNovelActive-0]
[traceId=] 2024-03-07 16:45:06.279 - INFO org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1:o.s.k.l.KafkaMessageListenerContainer:292 - test_story_dy_pay: partitions assigned: [testStoryNovelpay-0]
[traceId=] 2024-03-07 16:45:11.253 - INFO org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1:c.l.m.a.s.StoryNovelPayConsumer:32 - media.pay.story.onMessage start, data={"clientInfo":{"pkv":1,"platformId":601},"createTime":1709800560175,"extraData":{},"id":"17e45093-f226-4ee3-a6c8-c3bf363f61a6","openId":"_0001oR1eBGI2jG-UEcOlP4xI1qhuRLIbuo2","productId":"1","userId":3,"userUploadEvent":2}
[traceId=] 2024-03-07 16:45:11.690 - INFO org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1:c.l.m.a.s.StoryNovelPayConsumer:39 - media.pay.story.topic=testStoryNovelpay, bookStoreEvent={"clientInfo":{"pkv":1,"platformId":601},"createTime":1709800560175,"extraData":{},"id":"17e45093-f226-4ee3-a6c8-c3bf363f61a6","openId":"_0001oR1eBGI2jG-UEcOlP4xI1qhuRLIbuo2","productId":"1","userId":3,"userUploadEvent":2}
[traceId=] 2024-03-07 16:45:12.921 -ERROR org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1:c.l.m.a.s.StoryNovelPayConsumer:46 - story.novel.pay.onMessage failed, data={"clientInfo":{"pkv":1,"platformId":601},"createTime":1709800560175,"extraData":{},"id":"17e45093-f226-4ee3-a6c8-c3bf363f61a6","openId":"_0001oR1eBGI2jG-UEcOlP4xI1qhuRLIbuo2","productId":"1","userId":3,"userUploadEvent":2}, costTime=6547 ms
java.lang.NullPointerException: null
at com.lwby.marketing.att.storynovel.handle.ParameterSetupStoryNovelFlow.process(ParameterSetupStoryNovelFlow.java:47)
at com.lwby.marketing.att.storynovel.handle.ParameterSetupStoryNovelFlow.process(ParameterSetupStoryNovelFlow.java:18)
at com.lwby.marketing.flow.FlowExecutor.executeNormalNode(FlowExecutor.java:51)
at com.lwby.marketing.flow.FlowExecutor.execute(FlowExecutor.java:32)
at com.lwby.marketing.att.storynovel.StoryNovelPayConsumer.onMessage(StoryNovelPayConsumer.java:44)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:169)
at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:119)
at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:56)
at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:347)
at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:92)
at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:53)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2588)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:2569)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2483)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:2405)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:2284)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:1958)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeIfHaveRecords(KafkaMessageListenerContainer.java:1353)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1344)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1236)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run$$$capture(FutureTask.java:266)
at java.util.concurrent.FutureTask.run(FutureTask.java)
at java.lang.Thread.run(Thread.java:748)
logs/history/2024-03-13/common-service-error.2024-03-13-0.log deleted 100644 → 0
View file @ 7926dd47
[traceId=] 2024-03-13 22:07:55.156 -ERROR org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1:o.a.k.c.c.i.ConsumerCoordinator:1231 - [Consumer clientId=consumer-test_novel_dy_active-1, groupId=test_novel_dy_active] Offset commit failed on partition testNovelActive-0 at offset 0: The coordinator is not aware of this member.
[traceId=] 2024-03-13 22:07:55.156 -ERROR org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1:o.a.k.c.c.i.ConsumerCoordinator:1231 - [Consumer clientId=consumer-test_story_dy_pay-3, groupId=test_story_dy_pay] Offset commit failed on partition testStoryNovelpay-0 at offset 12: The coordinator is not aware of this member.
[traceId=] 2024-03-13 22:12:20.027 -ERROR org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1:o.a.k.c.c.i.ConsumerCoordinator:1231 - [Consumer clientId=consumer-test_story_dy_pay-3, groupId=test_story_dy_pay] Offset commit failed on partition testStoryNovelpay-0 at offset 12: The coordinator is not aware of this member.
[traceId=] 2024-03-13 22:12:20.028 -ERROR org.springframework.kafka.KafkaListenerEndpointContainer#2-0-C-1:o.a.k.c.c.i.ConsumerCoordinator:1231 - [Consumer clientId=consumer-test_novel_dy_active-1, groupId=test_novel_dy_active] Offset commit failed on partition testNovelActive-0 at offset 0: The coordinator is not aware of this member.
logs/history/2024-03-13/common-service.2024-03-13-0.log deleted 100644 → 0
View file @ 7926dd47
This source diff could not be displayed because it is too large. You can view the blob instead.
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment