I’m trying to use the downloaded files for kafka_2.13-3.8.0, but I’m running into this error VM option ‘UseG1GC” is experimental and must be enabled via -XX:+UnlockExperimentalVMOptions.

I’m trying to use the downloaded files for kafka_2.13-3.8.0, but I’m running into this error VM option ‘UseG1GC” is experimental and must be enabled via -XX:+UnlockExperimentalVMOptions.

I am having issue related to producer sending messages to kafka. With my message being sent around ~100kb it was working but recently it is having issue like below

I just upgraded few dependencies for spring boot upgrade for my app. Post that, when the app starts up I keep getting this exception for all kafka listeners.

I’m running 8 threads in parallel. Each thread is given a list of partitions to process and will process all messages between a given start and end timestamp.

`So I have a KStream that that gets deserialized into a POJO like so –

I need your help because i want to configure a custom StatelessBackOffPolicy but i can’t figure how.
I checked on internet but the samples are all using retryTemplate and retryTemplate is now deprecated so i can’t use it. Can you help me?