spring-kafka Examples and Free Source Code

Can we directly use the protobuf in spring-kafka?...

java apache-kafka protocol-buffers spring-kafka

Spring Kafka batch within time window...

spring-kafka spring-cloud-stream-binder-kafka

Spring Cloud Stream FencedInstanceIdException...

spring-kafka spring-cloud-stream

Synchronization of multiple Kafka consumers...

apache-kafka kafka-consumer-api spring-kafka

Any example available for creating GlobalKTable using Spring cloud stream kafka-streams?...

spring-cloud-stream spring-kafka

Two consumers with non-blocking retry listening to one kafka topic...

java apache-kafka spring-kafka

CompletableFuture with Kafka's callback methods?...

java spring-boot spring-kafka completable-future

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

apache-kafka spring-kafka

Consumer not receiving Kafka SpringBoot messages...

java spring-boot apache-kafka spring-kafka

what is controlledShutdown in embeddedKafka...

spring-kafka

How to convert GenericData to JsonNode...

java spring-kafka

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

spring-kafka

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

apache-kafka spring-kafka apache-kafka-streams spring-cloud-stream-binder-kafka

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

spring-kafka

Access Exception thrown during NonBlocking retry in DltHandler...

java apache-kafka spring-kafka

Accessing ConsumerRecord value after ErrorHandlingDeserializer Spring Boot Kafka...

spring spring-boot apache-kafka deserialization spring-kafka

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

apache-kafka kafka-consumer-api spring-kafka spring-scheduled

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

java apache-kafka spring-kafka java-17 snappy

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

apache-kafka spring-kafka

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

spring-boot prometheus spring-kafka spring-actuator reactor-kafka

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

spring-boot apache-kafka spring-kafka

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

java jackson spring-kafka

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

spring spring-boot spring-kafka

Kafka RecordMetadata use?...

java apache-kafka spring-kafka

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

java spring-boot apache-kafka spring-kafka

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

functional-programming spring-kafka spring-cloud-stream

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

apache-kafka spring-kafka

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

java spring apache-kafka spring-kafka

missing metriks spring kafka listener...

java spring prometheus spring-kafka

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

java apache-kafka spring-kafka