spring-kafka

spring-kafka copied to clipboard

Handling connection errors with KafkaTemplate when cluster not available

4

### Discussed in https://github.com/spring-projects/spring-kafka/discussions/2250 Originally posted by **Walnussbaer** May 3, 2022 Hi everyone, I'm really strunggeling with some basic functionality that I would like to achieve using KafkaTemplate and I...

garyrussell

Consumer committed offsets not tracking LSO with FixTxOffsets and rollbacked transactions

8

**In what version(s) of Spring for Apache Kafka are you seeing this issue?** 2.8.11 **Describe the bug** With a `MessageListenerContainer` configured with `FixTxOffsets` set to `true`, when all the available...

bgK

kafkaAdmin auto configuration when creating KafkaTemplate

12

**Expected Behavior** When using multiple kafkaTemplates with observations, the kafkaAdmin made automatically can connect to kafka with SSL. **Current Behavior** When using multiple kafkaTemplates with observations, the properties for sasl,...

ChangguHan

Native build fails with java.lang.NoSuchMethodException: org.apache.kafka.common.security.authenticator.SaslClientCallbackHandler

9

**In what version(s) of Spring for Apache Kafka are you seeing this issue?** spring-kafka:3.0.4 kafka-clients:3.3.2 **Describe the bug** Tryied to create a native springboot with kafka using microsoft azure eventhub...

weltonrodrigo

Add annotation for id class mapping

8

### Feature request **PROBLEM** Currently, mapping id's to classes is, for example, done through configuration beans. There a `TypePrecedence`, `mapping` and `TypeMapper` can be configured. For any additional message, you...

markbanierink

Spring Kafka with GraalVM - org.apache.kafka.common.errors.SaslAuthenticationException: Failed to create SaslClient with mechanism PLAIN

6

**In what version(s) of Spring for Apache Kafka are you seeing this issue?** 3.0.1 **Describe the bug** I am still new to Spring boot 3 aot. Best I can describe...

Richardmbs12

Kafka Streams tracing no longer working after upgrading to Spring Boot 3 + Micrometer Tracing

15

**Context** At the moment I'm migrating some Spring Boot 2.7.x, Spring for Apache Kafka applications to Spring Boot 3. I followed the migration guide and Spring Kafka documentation regarding migrating...

j-tim

Support for external store for checkpoint.

3

**Expected Behavior** Azure Event hubs provide Kafka API compatibility and provides sdk for blob storage. https://learn.microsoft.com/en-us/java/api/overview/azure/messaging-eventhubs-checkpointstore-blob-readme?view=azure-java-stable Can spring-kafka has similar offering so that we can plugin server details and checkpoints...

nageshs28

Spring Kafka Listener trying to convert String Payload to int

1

### Discussed in https://github.com/spring-projects/spring-kafka/discussions/2205 https://github.com/spring-projects/spring-kafka/discussions/2205#discussioncomment-4302539

garyrussell

Have one consumer for retry topics

3

### Discussed in https://github.com/spring-projects/spring-kafka/discussions/2146 Originally posted by **psh05** March 4, 2022 Currently there is one consumer per topic. If an app consumes from multiple topics which will implement multiple retries...

garyrussell