Search code examples
CompletableFuture with Kafka's callback methods?...


javaspring-bootspring-kafkacompletable-future

Read More
Can't connect to Kafka broker using spring.kafka.boostrap-servers...


apache-kafkaspring-kafka

Read More
Consumer not receiving Kafka SpringBoot messages...


javaspring-bootapache-kafkaspring-kafka

Read More
what is controlledShutdown in embeddedKafka...


spring-kafka

Read More
How to convert GenericData to JsonNode...


javaspring-kafka

Read More
How does Spring Kafka consider a record or batch as processed?...


spring-kafka

Read More
Sporadic ConcurrentModificationException when num.stream.threads > 1...


apache-kafkaspring-kafkaapache-kafka-streamsspring-cloud-stream-binder-kafka

Read More
java.lang.NoSuchMethodError on Kafka Consumer with spring-kafka 2.1.0 and SpringBoot 1.5.9...


spring-kafka

Read More
Access Exception thrown during NonBlocking retry in DltHandler...


javaapache-kafkaspring-kafka

Read More
Accessing ConsumerRecord value after ErrorHandlingDeserializer Spring Boot Kafka...


springspring-bootapache-kafkadeserializationspring-kafka

Read More
Is there any example of Spring Schedule that reads Kafka topic?...


apache-kafkakafka-consumer-apispring-kafkaspring-scheduled

Read More
SpringBoot Kafka + openjdk 17: org.xerial.snappy.SnappyError: [UNSUPPORTED_PLATFORM] pure-java snapp...


javaapache-kafkaspring-kafkajava-17snappy

Read More
Spring kafka setErrorHandler deprecated replacement (boot 2.6.4)...


apache-kafkaspring-kafka

Read More
Spring Boot Kafka - Kafka metrics not available in /actuator/prometheus...


spring-bootprometheusspring-kafkaspring-actuatorreactor-kafka

Read More
Spring Example HTTP Polling with Apache Kafka Request/Reply...


spring-bootapache-kafkaspring-kafka

Read More
Advantage of using JsonSerializer kafka over manually parsing String...


javajacksonspring-kafka

Read More
Can we use single spring kafka producer, consumer bean for different topics (same serializers)...


springspring-bootspring-kafka

Read More
Kafka RecordMetadata use?...


javaapache-kafkaspring-kafka

Read More
How to check Kafka cluster connectivity and topic availability status using Spring Boot...


javaspring-bootapache-kafkaspring-kafka

Read More
spring cloud stream kafka binder can not publish and consume message by functional programming...


functional-programmingspring-kafkaspring-cloud-stream

Read More
Wait for Kafka consumer in request/reply semantics to initialise offsets...


apache-kafkaspring-kafka

Read More
How to deal properly with CommitFailedException: "... it is likely that the consumer was kicked...


javaspringapache-kafkaspring-kafka

Read More
missing metriks spring kafka listener...


javaspringprometheusspring-kafka

Read More
How do I remove the header in a Kafka (Spring-boot)?...


javaapache-kafkaspring-kafka

Read More
Spring KafkaTemplate not handling errors on partition number...


javaapache-kafkaspring-kafka

Read More
@KafkaListener setting properties using SpEL expression...


spring-bootapache-kafkaspring-kafkaspring-el

Read More
How can I create a KafkaConsumer during runtime? (In Spring Boot)...


javaspring-bootapache-kafkaspring-kafka

Read More
Spring Kafka listener to consume JSON and infer the domain object...


jsonspring-bootapache-kafkaspring-kafkajson-deserialization

Read More
How to write Unit test case for adding callback for ListenableFuture...


unit-testingjunitconcurrencymockitospring-kafka

Read More
Kafka Consumer not retrying a message that has been failed to process...


javaapache-kafkaspring-kafka

Read More
BackNext