1.  
2. PS C:\Users\asifa\Downloads\my-kafka>
3. PS C:\Users\asifa\Downloads\my-kafka>  c:; cd 'c:\Users\asifa\Downloads\my-kafka'; & 'C:\Program Files\Microsoft\jdk-17.0.9.8-hotspot\bin\java.exe'
4.  '@C:\Users\asifa\AppData\Local\Temp\cp_86mbliqctbcf23t4yegt6uwup.argfile' 'com.aacprojects.stockservices.StockServicesApplication'
5.  
6.   .   ____          _            __ _ _
7.  /\\ / ___'_ __ _ _(_)_ __  __ _ \ \ \ \
8. ( ( )\___ | '_ | '_| | '_ \/ _` | \ \ \ \
9.  \\/  ___)| |_)| | | | | || (_| |  ) ) ) )
10.   '  |____| .__|_| |_|_| |_\__, | / / / /
11.  =========|_|==============|___/=/_/_/_/
12.  :: Spring Boot ::             (v3.0.0-M3)
13.  
14. 2024-04-20T21:48:52.435+05:30  INFO 22272 --- [           main] c.a.s.StockServicesApplication           : Starting StockServicesApplication using Java 17.0.9 on LAPTOP-HVLQ013S with PID 22272 (C:\Users\asifa\Downloads\my-kafka\stock-services\target\classes started by asifa in C:\Users\asifa\Downloads\my-kafka)
15. 2024-04-20T21:48:52.449+05:30  INFO 22272 --- [           main] c.a.s.StockServicesApplication           : No active profile set, falling back to 1 default profile: "default"
16. 2024-04-20T21:48:54.519+05:30  INFO 22272 --- [           main] .s.d.r.c.RepositoryConfigurationDelegate : Bootstrapping Spring Data JPA repositories in DEFAULT mode.
17. 2024-04-20T21:48:54.617+05:30  INFO 22272 --- [           main] .s.d.r.c.RepositoryConfigurationDelegate : Finished Spring Data repository scanning in 84 ms. Found 2 JPA repository interfaces.
18. 2024-04-20T21:48:55.671+05:30  INFO 22272 --- [           main] o.s.b.w.embedded.tomcat.TomcatWebServer  : Tomcat initialized with port(s): 8080 (http)
19. 2024-04-20T21:48:55.690+05:30  INFO 22272 --- [           main] o.apache.catalina.core.StandardService   : Starting service [Tomcat]
20. 2024-04-20T21:48:55.691+05:30  INFO 22272 --- [           main] org.apache.catalina.core.StandardEngine  : Starting Servlet engine: [Apache Tomcat/10.0.21]
21. 2024-04-20T21:48:55.930+05:30  INFO 22272 --- [           main] o.a.c.c.C.[Tomcat].[localhost].[/]       : Initializing Spring embedded WebApplicationContext
22. 2024-04-20T21:48:55.931+05:30  INFO 22272 --- [           main] w.s.c.ServletWebServerApplicationContext : Root WebApplicationContext: initialization completed in 3338 ms
23. 2024-04-20T21:48:56.542+05:30  INFO 22272 --- [           main] o.hibernate.jpa.internal.util.LogHelper  : HHH000204: Processing PersistenceUnitInfo [name: default]
24. 2024-04-20T21:48:56.733+05:30  INFO 22272 --- [           main] org.hibernate.Version                    : HHH000412: Hibernate ORM core version 5.6.9.Final
25. 2024-04-20T21:48:57.123+05:30  INFO 22272 --- [           main] o.hibernate.annotations.common.Version   : HCANN000001: Hibernate Commons Annotations {5.1.2.Final}
26. 2024-04-20T21:48:57.295+05:30  INFO 22272 --- [           main] com.zaxxer.hikari.HikariDataSource       : HikariPool-1 - Starting...
27. 2024-04-20T21:48:57.860+05:30  INFO 22272 --- [           main] com.zaxxer.hikari.pool.HikariPool        : HikariPool-1 - Added connection com.mysql.cj.jdbc.ConnectionImpl@402d6012
28. 2024-04-20T21:48:57.867+05:30  INFO 22272 --- [           main] com.zaxxer.hikari.HikariDataSource       : HikariPool-1 - Start completed.
29. 2024-04-20T21:48:57.905+05:30  INFO 22272 --- [           main] org.hibernate.dialect.Dialect            : HHH000400: Using dialect: org.hibernate.dialect.MySQL8Dialect
30. 2024-04-20T21:48:59.116+05:30  INFO 22272 --- [           main] o.h.e.t.j.p.i.JtaPlatformInitiator       : HHH000490: Using JtaPlatform implementation: [org.hibernate.engine.transaction.jta.platform.internal.NoJtaPlatform]
31. 2024-04-20T21:48:59.127+05:30  INFO 22272 --- [           main] j.LocalContainerEntityManagerFactoryBean : Initialized JPA EntityManagerFactory for persistence unit 'default'
32. 2024-04-20T21:48:59.959+05:30  WARN 22272 --- [           main] JpaBaseConfiguration$JpaWebConfiguration : spring.jpa.open-in-view is enabled by default. Therefore, database queries may be performed during view rendering. Explicitly configure spring.jpa.open-in-view to disable this warning    
33. 2024-04-20T21:49:01.211+05:30  INFO 22272 --- [           main] o.s.b.a.e.web.EndpointLinksResolver      : Exposing 1 endpoint(s) beneath base path '/actuator'
34. 2024-04-20T21:49:01.533+05:30  INFO 22272 --- [           main] o.a.k.clients.consumer.ConsumerConfig    : ConsumerConfig values:
35.         allow.auto.create.topics = true
36.         auto.commit.interval.ms = 5000
37.         auto.offset.reset = earliest
38.         bootstrap.servers = [localhost:9092]
39.         check.crcs = true
40.         client.dns.lookup = use_all_dns_ips
41.         client.id = consumer-stock-1
42.         client.rack =
43.         connections.max.idle.ms = 540000
44.         default.api.timeout.ms = 60000
45.         enable.auto.commit = false
46.         exclude.internal.topics = true
47.         fetch.max.bytes = 52428800
48.         fetch.max.wait.ms = 500
49.         fetch.min.bytes = 1
50.         group.id = stock
51.         group.instance.id = null
52.         heartbeat.interval.ms = 3000
53.         interceptor.classes = []
54.         internal.leave.group.on.close = true
55.         internal.throw.on.fetch.stable.offset.unsupported = false
56.         isolation.level = read_uncommitted
57.         key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
58.         max.partition.fetch.bytes = 1048576
59.         max.poll.interval.ms = 300000
60.         max.poll.records = 500
61.         metadata.max.age.ms = 300000
62.         metric.reporters = []
63.         metrics.num.samples = 2
64.         metrics.recording.level = INFO
65.         metrics.sample.window.ms = 30000
66.         partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor, class org.apache.kafka.clients.consumer.CooperativeStickyAssignor]
67.         receive.buffer.bytes = 65536
68.         reconnect.backoff.max.ms = 1000
69.         reconnect.backoff.ms = 50
70.         request.timeout.ms = 30000
71.         retry.backoff.ms = 100
72.         sasl.client.callback.handler.class = null
73.         sasl.jaas.config = null
74.         sasl.kerberos.kinit.cmd = /usr/bin/kinit
75.         sasl.kerberos.min.time.before.relogin = 60000
76.         sasl.kerberos.service.name = null
77.         sasl.kerberos.ticket.renew.jitter = 0.05
78.         sasl.kerberos.ticket.renew.window.factor = 0.8
79.         sasl.login.callback.handler.class = null
80.         sasl.login.class = null
81.         sasl.login.connect.timeout.ms = null
82.         sasl.login.read.timeout.ms = null
83.         sasl.login.refresh.buffer.seconds = 300
84.         sasl.login.refresh.min.period.seconds = 60
85.         sasl.login.refresh.window.factor = 0.8
86.         sasl.login.refresh.window.jitter = 0.05
87.         sasl.login.retry.backoff.max.ms = 10000
88.         sasl.login.retry.backoff.ms = 100
89.         sasl.mechanism = GSSAPI
90.         sasl.oauthbearer.clock.skew.seconds = 30
91.         sasl.oauthbearer.expected.audience = null
92.         sasl.oauthbearer.expected.issuer = null
93.         sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000
94.         sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000
95.         sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100
96.         sasl.oauthbearer.jwks.endpoint.url = null
97.         sasl.oauthbearer.scope.claim.name = scope
98.         sasl.oauthbearer.sub.claim.name = sub
99.         sasl.oauthbearer.token.endpoint.url = null
100.         security.protocol = PLAINTEXT
101.         security.providers = null
102.         send.buffer.bytes = 131072
103.         session.timeout.ms = 45000
104.         socket.connection.setup.timeout.max.ms = 30000
105.         socket.connection.setup.timeout.ms = 10000
106.         ssl.cipher.suites = null
107.         ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
108.         ssl.endpoint.identification.algorithm = https
109.         ssl.engine.factory.class = null
110.         ssl.key.password = null
111.         ssl.keymanager.algorithm = SunX509
112.         ssl.keystore.certificate.chain = null
113.         ssl.keystore.key = null
114.         ssl.keystore.location = null
115.         ssl.keystore.password = null
116.         ssl.keystore.type = JKS
117.         ssl.protocol = TLSv1.3
118.         ssl.provider = null
119.         ssl.secure.random.implementation = null
120.         ssl.trustmanager.algorithm = PKIX
121.         ssl.truststore.certificates = null
122.         ssl.truststore.location = null
123.         ssl.truststore.password = null
124.         ssl.truststore.type = JKS
125.         value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
126.  
127. 2024-04-20T21:49:01.886+05:30  INFO 22272 --- [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka version: 3.2.0
128. 2024-04-20T21:49:01.887+05:30  INFO 22272 --- [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka commitId: 38103ffaa962ef50        
129. 2024-04-20T21:49:01.888+05:30  INFO 22272 --- [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka startTimeMs: 1713629941878        
130. 2024-04-20T21:49:01.916+05:30  INFO 22272 --- [on(1)-127.0.0.1] o.a.c.c.C.[Tomcat].[localhost].[/]       : Initializing Spring DispatcherServlet 'dispatcherServlet'
131. 2024-04-20T21:49:01.919+05:30  INFO 22272 --- [on(1)-127.0.0.1] o.s.web.servlet.DispatcherServlet        : Initializing Servlet 'dispatcherServlet'
132. 2024-04-20T21:49:01.929+05:30  INFO 22272 --- [on(1)-127.0.0.1] o.s.web.servlet.DispatcherServlet        : Completed initialization in 5 ms
133. 2024-04-20T21:49:01.955+05:30  INFO 22272 --- [           main] o.a.k.clients.consumer.KafkaConsumer     : [Consumer clientId=consumer-stock-1, groupId=stock] Subscribed to topic(s): order_topics
134. 2024-04-20T21:49:02.052+05:30  INFO 22272 --- [           main] o.s.b.w.embedded.tomcat.TomcatWebServer  : Tomcat started on port(s): 8080 (http) with context path ''
135. 2024-04-20T21:49:02.065+05:30  INFO 22272 --- [           main] c.a.s.StockServicesApplication           : Started StockServicesApplication in 10.179 seconds (process running for 10.534)
136. 2024-04-20T21:49:03.019+05:30  INFO 22272 --- [ntainer#0-0-C-1] org.apache.kafka.clients.Metadata        : [Consumer clientId=consumer-stock-1, groupId=stock] Resetting the last seen epoch of partition order_topics-0 to 0 since the associated topicId changed from null to 9C5x5YI3T1OXWrkON0g02w
137. 2024-04-20T21:49:03.027+05:30  INFO 22272 --- [ntainer#0-0-C-1] org.apache.kafka.clients.Metadata        : [Consumer clientId=consumer-stock-1, groupId=stock] Cluster ID: Some(5L6g3nShT-eMCtK--X86sw)
138. 2024-04-20T21:49:03.105+05:30  INFO 22272 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-stock-1, groupId=stock] Discovered group coordinator localhost:9092 (id: 2147483646 rack: null)
139. 2024-04-20T21:49:03.113+05:30  INFO 22272 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-stock-1, groupId=stock] (Re-)joining group
140. 2024-04-20T21:49:03.336+05:30  INFO 22272 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-stock-1, groupId=stock] Request joining group due to: need to re-join with the given member-id: consumer-stock-1-b0cbacab-db26-4bab-ab3a-5d7b02539543
141. 2024-04-20T21:49:03.338+05:30  INFO 22272 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-stock-1, groupId=stock] (Re-)joining group
142. 2024-04-20T21:49:10.535+05:30  INFO 22272 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-stock-1, groupId=stock] Successfully joined group with generation Generation{generationId=19, memberId='consumer-stock-1-b0cbacab-db26-4bab-ab3a-5d7b02539543', protocol='range'}
143. 2024-04-20T21:49:10.543+05:30  INFO 22272 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-stock-1, groupId=stock] Finished assignment for group at generation 19: {consumer-stock-1-b0cbacab-db26-4bab-ab3a-5d7b02539543=Assignment(partitions=[order_topics-0])}
144. 2024-04-20T21:49:10.627+05:30  INFO 22272 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-stock-1, groupId=stock] Successfully synced group in generation Generation{generationId=19, memberId='consumer-stock-1-b0cbacab-db26-4bab-ab3a-5d7b02539543', protocol='range'}
145. 2024-04-20T21:49:10.629+05:30  INFO 22272 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-stock-1, groupId=stock] Notifying assignor about the new Assignment(partitions=[order_topics-0])
146. 2024-04-20T21:49:10.632+05:30  INFO 22272 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-stock-1, groupId=stock] Adding newly assigned partitions: order_topics-0
147. 2024-04-20T21:49:10.702+05:30  INFO 22272 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-stock-1, groupId=stock] Setting offset for partition order_topics-0 to the committed offset FetchPosition{offset=18, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[localhost:9092 (id: 1 rack: null)], epoch=0}}
148. 2024-04-20T21:49:10.706+05:30  INFO 22272 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer    : stock: partitions assigned: [order_topics-0]
149. 2024-04-20T21:49:13.917+05:30 ERROR 22272 --- [ntainer#0-0-C-1] o.s.kafka.listener.DefaultErrorHandler   : Backoff FixedBackOff{interval=0, currentAttempts=1, maxAttempts=0} exhausted for order_topics-0@18
150.  
151. org.springframework.kafka.listener.ListenerExecutionFailedException: Listener method could not be invoked with the incoming message
152. Endpoint handler details:
153. Method [public void com.aacprojects.stockservices.kafka.OrderConsumer.consume(com.aacprojects.stockservices.vo.OrderEventVO)]
154. Bean [com.aacprojects.stockservices.kafka.OrderConsumer@4d90d91f]; nested exception is org.springframework.messaging.converter.MessageConversionException: Cannot handle message; nested exception is org.springframework.messaging.converter.MessageConversionException: Cannot convert from [java.lang.String] to [com.aacprojects.stockservices.vo.OrderEventVO] for GenericMessage [payload={"message":"order is in pending state","status":"PENDING","order":{"name":"Anwar phone","qty":100,"price":45000.0}}, headers={kafka_offset=18, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsumer@54855655, kafka_timestampType=CREATE_TIME, kafka_receivedPartitionId=0, kafka_receivedTopic=order_topics, kafka_receivedTimestamp=1713629953397, __TypeId__=[B@7e12fe81, kafka_groupId=stock}], failedMessage=GenericMessage [payload={"message":"order is in pending state","status":"PENDING","order":{"name":"Anwar phone","qty":100,"price":45000.0}}, headers={kafka_offset=18, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsumer@54855655, kafka_timestampType=CREATE_TIME, kafka_receivedPartitionId=0, kafka_receivedTopic=order_topics, kafka_receivedTimestamp=1713629953397, __TypeId__=[B@7e12fe81, kafka_groupId=stock}]; nested exception is org.springframework.messaging.converter.MessageConversionException: Cannot handle message; nested exception is org.springframework.messaging.converter.MessageConversionException: Cannot convert from [java.lang.String] to [com.aacprojects.stockservices.vo.OrderEventVO] for GenericMessage [payload={"message":"order is in pending state","status":"PENDING","order":{"name":"Anwar phone","qty":100,"price":45000.0}}, headers={kafka_offset=18, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsumer@54855655, kafka_timestampType=CREATE_TIME, kafka_receivedPartitionId=0, kafka_receivedTopic=order_topics, kafka_receivedTimestamp=1713629953397, __TypeId__=[B@7e12fe81, kafka_groupId=stock}], failedMessage=GenericMessage [payload={"message":"order is in pending state","status":"PENDING","order":{"name":"Anwar phone","qty":100,"price":45000.0}}, headers={kafka_offset=18, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsumer@54855655, kafka_timestampType=CREATE_TIME, kafka_receivedPartitionId=0, kafka_receivedTopic=order_topics, kafka_receivedTimestamp=1713629953397, __TypeId__=[B@7e12fe81, kafka_groupId=stock}]
155.         at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.decorateException(KafkaMessageListenerContainer.java:2709) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
156.         at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2667) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
157.         at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:2628) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
158.         at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2552) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
159.         at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:2434) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
160.         at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:2322) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
161.         at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:1978) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
162.         at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeIfHaveRecords(KafkaMessageListenerContainer.java:1355) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
163.         at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1340) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
164.         at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1239) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
165.         at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) ~[na:na]
166.         at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[na:na]
167.         at java.base/java.lang.Thread.run(Thread.java:840) ~[na:na]
168.         Suppressed: org.springframework.kafka.listener.ListenerExecutionFailedException: Restored Stack Trace
169.                 at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.checkAckArg(MessagingMessageListenerAdapter.java:374) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
170.                 at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:352) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
171.                 at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:92) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
172.                 at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:53) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
173.                 at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2647) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
174. Caused by: org.springframework.messaging.converter.MessageConversionException: Cannot handle message; nested exception is org.springframework.messaging.converter.MessageConversionException: Cannot convert from [java.lang.String] to [com.aacprojects.stockservices.vo.OrderEventVO] for GenericMessage [payload={"message":"order is in pending state","status":"PENDING","order":{"name":"Anwar phone","qty":100,"price":45000.0}}, headers={kafka_offset=18, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsumer@54855655, kafka_timestampType=CREATE_TIME, kafka_receivedPartitionId=0, kafka_receivedTopic=order_topics, kafka_receivedTimestamp=1713629953397, __TypeId__=[B@7e12fe81, kafka_groupId=stock}], failedMessage=GenericMessage [payload={"message":"order is in pending state","status":"PENDING","order":{"name":"Anwar phone","qty":100,"price":45000.0}}, headers={kafka_offset=18, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsumer@54855655, kafka_timestampType=CREATE_TIME, kafka_receivedPartitionId=0, kafka_receivedTopic=order_topics, kafka_receivedTimestamp=1713629953397, __TypeId__=[B@7e12fe81, kafka_groupId=stock}]
175.         at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:352) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
176.         at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:92) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
177.         at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:53) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
178.         at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2647) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
179.         ... 11 common frames omitted
180. Caused by: org.springframework.messaging.converter.MessageConversionException: Cannot convert from [java.lang.String] to [com.aacprojects.stockservices.vo.OrderEventVO] for GenericMessage [payload={"message":"order is in pending state","status":"PENDING","order":{"name":"Anwar phone","qty":100,"price":45000.0}}, headers={kafka_offset=18, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsumer@54855655, kafka_timestampType=CREATE_TIME, kafka_receivedPartitionId=0, kafka_receivedTopic=order_topics, kafka_receivedTimestamp=1713629953397, __TypeId__=[B@7e12fe81, kafka_groupId=stock}]
181.         at org.springframework.messaging.handler.annotation.support.PayloadMethodArgumentResolver.resolveArgument(PayloadMethodArgumentResolver.java:144) ~[spring-messaging-6.0.0-M4.jar:6.0.0-M4]
182.         at org.springframework.kafka.annotation.KafkaNullAwarePayloadArgumentResolver.resolveArgument(KafkaNullAwarePayloadArgumentResolver.java:46) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
183.         at org.springframework.messaging.handler.invocation.HandlerMethodArgumentResolverComposite.resolveArgument(HandlerMethodArgumentResolverComposite.java:118) ~[spring-messaging-6.0.0-M4.jar:6.0.0-M4]
184.         at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.getMethodArgumentValues(InvocableHandlerMethod.java:147) ~[spring-messaging-6.0.0-M4.jar:6.0.0-M4]
185.         at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:115) ~[spring-messaging-6.0.0-M4.jar:6.0.0-M4]
186.         at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:56) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
187.         at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:347) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
188.         ... 14 common frames omitted
189.  
190. 2024-04-20T21:51:41.565+05:30 ERROR 22272 --- [ntainer#0-0-C-1] o.s.kafka.listener.DefaultErrorHandler   : Backoff FixedBackOff{interval=0, currentAttempts=1, maxAttempts=0} exhausted for order_topics-0@19
191.  
192. org.springframework.kafka.listener.ListenerExecutionFailedException: Listener method could not be invoked with the incoming message
193. Endpoint handler details:
194. Method [public void com.aacprojects.stockservices.kafka.OrderConsumer.consume(com.aacprojects.stockservices.vo.OrderEventVO)]
195. Bean [com.aacprojects.stockservices.kafka.OrderConsumer@4d90d91f]; nested exception is org.springframework.messaging.converter.MessageConversionException: Cannot handle message; nested exception is org.springframework.messaging.converter.MessageConversionException: Cannot convert from [java.lang.String] to [com.aacprojects.stockservices.vo.OrderEventVO] for GenericMessage [payload={"message":"order is in pending state","status":"PENDING","order":{"name":"Anwar phone","qty":100,"price":45000.0}}, headers={kafka_offset=19, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsumer@54855655, kafka_timestampType=CREATE_TIME, kafka_receivedPartitionId=0, kafka_receivedTopic=order_topics, kafka_receivedTimestamp=1713630101014, __TypeId__=[B@687d12a5, kafka_groupId=stock}], failedMessage=GenericMessage [payload={"message":"order is in pending state","status":"PENDING","order":{"name":"Anwar phone","qty":100,"price":45000.0}}, headers={kafka_offset=19, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsumer@54855655, kafka_timestampType=CREATE_TIME, kafka_receivedPartitionId=0, kafka_receivedTopic=order_topics, kafka_receivedTimestamp=1713630101014, __TypeId__=[B@687d12a5, kafka_groupId=stock}]; nested exception is org.springframework.messaging.converter.MessageConversionException: Cannot handle message; nested exception is org.springframework.messaging.converter.MessageConversionException: Cannot convert from [java.lang.String] to [com.aacprojects.stockservices.vo.OrderEventVO] for GenericMessage [payload={"message":"order is in pending state","status":"PENDING","order":{"name":"Anwar phone","qty":100,"price":45000.0}}, headers={kafka_offset=19, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsumer@54855655, kafka_timestampType=CREATE_TIME, kafka_receivedPartitionId=0, kafka_receivedTopic=order_topics, kafka_receivedTimestamp=1713630101014, __TypeId__=[B@687d12a5, kafka_groupId=stock}], failedMessage=GenericMessage [payload={"message":"order is in pending state","status":"PENDING","order":{"name":"Anwar phone","qty":100,"price":45000.0}}, headers={kafka_offset=19, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsumer@54855655, kafka_timestampType=CREATE_TIME, kafka_receivedPartitionId=0, kafka_receivedTopic=order_topics, kafka_receivedTimestamp=1713630101014, __TypeId__=[B@687d12a5, kafka_groupId=stock}]
196.         at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.decorateException(KafkaMessageListenerContainer.java:2709) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
197.         at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2667) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
198.         at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:2628) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
199.         at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2552) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
200.         at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:2434) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
201.         at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:2322) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
202.         at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:1978) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
203.         at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeIfHaveRecords(KafkaMessageListenerContainer.java:1355) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
204.         at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1340) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
205.         at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1239) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
206.         at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) ~[na:na]
207.         at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[na:na]
208.         at java.base/java.lang.Thread.run(Thread.java:840) ~[na:na]
209.         Suppressed: org.springframework.kafka.listener.ListenerExecutionFailedException: Restored Stack Trace
210.                 at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.checkAckArg(MessagingMessageListenerAdapter.java:374) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
211.                 at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:352) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
212.                 at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:92) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
213.                 at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:53) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
214.                 at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2647) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
215. Caused by: org.springframework.messaging.converter.MessageConversionException: Cannot handle message; nested exception is org.springframework.messaging.converter.MessageConversionException: Cannot convert from [java.lang.String] to [com.aacprojects.stockservices.vo.OrderEventVO] for GenericMessage [payload={"message":"order is in pending state","status":"PENDING","order":{"name":"Anwar phone","qty":100,"price":45000.0}}, headers={kafka_offset=19, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsumer@54855655, kafka_timestampType=CREATE_TIME, kafka_receivedPartitionId=0, kafka_receivedTopic=order_topics, kafka_receivedTimestamp=1713630101014, __TypeId__=[B@687d12a5, kafka_groupId=stock}], failedMessage=GenericMessage [payload={"message":"order is in pending state","status":"PENDING","order":{"name":"Anwar phone","qty":100,"price":45000.0}}, headers={kafka_offset=19, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsumer@54855655, kafka_timestampType=CREATE_TIME, kafka_receivedPartitionId=0, kafka_receivedTopic=order_topics, kafka_receivedTimestamp=1713630101014, __TypeId__=[B@687d12a5, kafka_groupId=stock}]
216.         at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:352) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
217.         at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:92) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
218.         at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:53) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
219.         at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2647) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
220.         ... 11 common frames omitted
221. Caused by: org.springframework.messaging.converter.MessageConversionException: Cannot convert from [java.lang.String] to [com.aacprojects.stockservices.vo.OrderEventVO] for GenericMessage [payload={"message":"order is in pending state","status":"PENDING","order":{"name":"Anwar phone","qty":100,"price":45000.0}}, headers={kafka_offset=19, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsumer@54855655, kafka_timestampType=CREATE_TIME, kafka_receivedPartitionId=0, kafka_receivedTopic=order_topics, kafka_receivedTimestamp=1713630101014, __TypeId__=[B@687d12a5, kafka_groupId=stock}]
222.         at org.springframework.messaging.handler.annotation.support.PayloadMethodArgumentResolver.resolveArgument(PayloadMethodArgumentResolver.java:144) ~[spring-messaging-6.0.0-M4.jar:6.0.0-M4]
223.         at org.springframework.kafka.annotation.KafkaNullAwarePayloadArgumentResolver.resolveArgument(KafkaNullAwarePayloadArgumentResolver.java:46) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
224.         at org.springframework.messaging.handler.invocation.HandlerMethodArgumentResolverComposite.resolveArgument(HandlerMethodArgumentResolverComposite.java:118) ~[spring-messaging-6.0.0-M4.jar:6.0.0-M4]
225.         at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.getMethodArgumentValues(InvocableHandlerMethod.java:147) ~[spring-messaging-6.0.0-M4.jar:6.0.0-M4]
226.         at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:115) ~[spring-messaging-6.0.0-M4.jar:6.0.0-M4]
227.         at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:56) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
228.         at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:347) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
229.         ... 14 common frames omitted
230.  
231. 2024-04-20T21:52:25.248+05:30 ERROR 22272 --- [ntainer#0-0-C-1] o.s.kafka.listener.DefaultErrorHandler   : Backoff FixedBackOff{interval=0, currentAttempts=1, maxAttempts=0} exhausted for order_topics-0@20
232.  
233. org.springframework.kafka.listener.ListenerExecutionFailedException: Listener method could not be invoked with the incoming message
234. Endpoint handler details:
235. Method [public void com.aacprojects.stockservices.kafka.OrderConsumer.consume(com.aacprojects.stockservices.vo.OrderEventVO)]
236. Bean [com.aacprojects.stockservices.kafka.OrderConsumer@4d90d91f]; nested exception is org.springframework.messaging.converter.MessageConversionException: Cannot handle message; nested exception is org.springframework.messaging.converter.MessageConversionException: Cannot convert from [java.lang.String] to [com.aacprojects.stockservices.vo.OrderEventVO] for GenericMessage [payload={"message":"order is in pending state","status":"PENDING","order":{"name":"Asif phone","qty":100,"price":45000.0}}, headers={kafka_offset=20, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsumer@54855655, kafka_timestampType=CREATE_TIME, kafka_receivedPartitionId=0, kafka_receivedTopic=order_topics, kafka_receivedTimestamp=1713630145213, __TypeId__=[B@3009b153, kafka_groupId=stock}], failedMessage=GenericMessage [payload={"message":"order is in pending state","status":"PENDING","order":{"name":"Asif phone","qty":100,"price":45000.0}}, headers={kafka_offset=20, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsumer@54855655, kafka_timestampType=CREATE_TIME, kafka_receivedPartitionId=0, kafka_receivedTopic=order_topics, kafka_receivedTimestamp=1713630145213, __TypeId__=[B@3009b153, kafka_groupId=stock}]; nested exception is org.springframework.messaging.converter.MessageConversionException: Cannot handle message; nested exception is org.springframework.messaging.converter.MessageConversionException: Cannot convert from [java.lang.String] to [com.aacprojects.stockservices.vo.OrderEventVO] for GenericMessage [payload={"message":"order is in pending state","status":"PENDING","order":{"name":"Asif phone","qty":100,"price":45000.0}}, headers={kafka_offset=20, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsumer@54855655, kafka_timestampType=CREATE_TIME, kafka_receivedPartitionId=0, kafka_receivedTopic=order_topics, kafka_receivedTimestamp=1713630145213, __TypeId__=[B@3009b153, kafka_groupId=stock}], failedMessage=GenericMessage [payload={"message":"order is in pending state","status":"PENDING","order":{"name":"Asif phone","qty":100,"price":45000.0}}, headers={kafka_offset=20, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsumer@54855655, kafka_timestampType=CREATE_TIME, kafka_receivedPartitionId=0, kafka_receivedTopic=order_topics, kafka_receivedTimestamp=1713630145213, __TypeId__=[B@3009b153, kafka_groupId=stock}]
237.         at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.decorateException(KafkaMessageListenerContainer.java:2709) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
238.         at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2667) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
239.         at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:2628) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
240.         at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2552) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
241.         at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:2434) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
242.         at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:2322) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
243.         at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:1978) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
244.         at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeIfHaveRecords(KafkaMessageListenerContainer.java:1355) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
245.         at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1340) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
246.         at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1239) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
247.         at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) ~[na:na]
248.         at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[na:na]
249.         at java.base/java.lang.Thread.run(Thread.java:840) ~[na:na]
250.         Suppressed: org.springframework.kafka.listener.ListenerExecutionFailedException: Restored Stack Trace
251.                 at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.checkAckArg(MessagingMessageListenerAdapter.java:374) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
252.                 at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:352) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
253.                 at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:92) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
254.                 at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:53) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
255.                 at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2647) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
256. Caused by: org.springframework.messaging.converter.MessageConversionException: Cannot handle message; nested exception is org.springframework.messaging.converter.MessageConversionException: Cannot convert from [java.lang.String] to [com.aacprojects.stockservices.vo.OrderEventVO] for GenericMessage [payload={"message":"order is in pending state","status":"PENDING","order":{"name":"Asif phone","qty":100,"price":45000.0}}, headers={kafka_offset=20, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsumer@54855655, kafka_timestampType=CREATE_TIME, kafka_receivedPartitionId=0, kafka_receivedTopic=order_topics, kafka_receivedTimestamp=1713630145213, __TypeId__=[B@3009b153, kafka_groupId=stock}], failedMessage=GenericMessage [payload={"message":"order is in pending state","status":"PENDING","order":{"name":"Asif phone","qty":100,"price":45000.0}}, headers={kafka_offset=20, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsumer@54855655, kafka_timestampType=CREATE_TIME, kafka_receivedPartitionId=0, kafka_receivedTopic=order_topics, kafka_receivedTimestamp=1713630145213, __TypeId__=[B@3009b153, kafka_groupId=stock}]
257.         at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:352) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
258.         at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:92) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
259.         at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:53) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
260.         at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2647) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
261.         ... 11 common frames omitted
262. Caused by: org.springframework.messaging.converter.MessageConversionException: Cannot convert from [java.lang.String] to [com.aacprojects.stockservices.vo.OrderEventVO] for GenericMessage [payload={"message":"order is in pending state","status":"PENDING","order":{"name":"Asif phone","qty":100,"price":45000.0}}, headers={kafka_offset=20, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsumer@54855655, kafka_timestampType=CREATE_TIME, kafka_receivedPartitionId=0, kafka_receivedTopic=order_topics, kafka_receivedTimestamp=1713630145213, __TypeId__=[B@3009b153, kafka_groupId=stock}]
263.         at org.springframework.messaging.handler.annotation.support.PayloadMethodArgumentResolver.resolveArgument(PayloadMethodArgumentResolver.java:144) ~[spring-messaging-6.0.0-M4.jar:6.0.0-M4]
264.         at org.springframework.kafka.annotation.KafkaNullAwarePayloadArgumentResolver.resolveArgument(KafkaNullAwarePayloadArgumentResolver.java:46) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
265.         at org.springframework.messaging.handler.invocation.HandlerMethodArgumentResolverComposite.resolveArgument(HandlerMethodArgumentResolverComposite.java:118) ~[spring-messaging-6.0.0-M4.jar:6.0.0-M4]
266.         at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.getMethodArgumentValues(InvocableHandlerMethod.java:147) ~[spring-messaging-6.0.0-M4.jar:6.0.0-M4]
267.         at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:115) ~[spring-messaging-6.0.0-M4.jar:6.0.0-M4]
268.         at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:56) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
269.         at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:347) ~[spring-kafka-3.0.0-M4.jar:3.0.0-M4]
270.         ... 14 common frames omitted