python (65.1k questions)
javascript (44.2k questions)
reactjs (22.7k questions)
java (20.8k questions)
c# (17.4k questions)
html (16.3k questions)
r (13.7k questions)
android (12.9k questions)
@RetryableTopic showing weird behaviour when using with topicPartitions to reset offset - spring kafka
I am trying to use @RetryableTopic for unblocking retries and topicPartitions in order to read messages from beginning.
Below is my listener (I have only one partition):
@Slf4j
@Component
public class...
Ashish Singh
Votes: 0
Answers: 1
Spring boot 2.6.6 defect with Kafka appender
I want to upgrade my app in order to use the updated version of spring boot. Also, i am using log4j2 with a Kafka appender.
Although, when i upgrated to 2.6.6. version from 2.6.4 i had the following e...
Pantelisy
Votes: 0
Answers: 0
How to configure CommonErrorHandler and ContainerProperties through application.properties in spring boot?
As we know, we do not require to define ConcurrentKafkaListenerContainerFactory bean definition in spring boot with kafka instead we could configure them by these properties. But I could not find any ...
Arun Sai Mustyala
Votes: 0
Answers: 1
How to enable DELIVERY_ATTEMPT header from consumer side in KAFKA?
I have an spring boot kafka consumer application. So as per the documentation added factory.getContainerProperties().setDeliveryAttemptHeader(true); in below and still not able to receive the delivery...
Arun Sai Mustyala
Votes: 0
Answers: 1