spring-projects/spring-kafka

Issues

• Align default behavior of `@RetryableTopic` and `RetryTopicConfigurationBuilder` with documentation

  #3706 opened a day ago by bky373
  1

• Events skipped in group rebalancing

  #3703 opened 3 days ago by ejba
  13

• Documentation typo - Class names clashing - @EmbeddedKafka Annotation

  #3701 opened 3 days ago by gcoppex
  1

• Configure if message goes to DLQ after retries conditionally, based on MessageHeaders and thrown Exception

  #3700 opened 4 days ago by santunioni
  5

• Kafka and Spring Boot JDK 23 - Caused by: java.lang.UnsupportedOperationException: getSubject is supported only if a security manager is allowed

  #3619 opened 2 months ago by drakgoku
  4

• The trace IDs are not being propagated.

  #3698 opened 7 days ago by fleszarnatalia
  2

• Need a way to specify properties like retention.ms which must be Long and not a String

  #3667 opened 6 days ago by johnament
  2

• Acknowledge+commit always issued in AckMode.MANUAL

  #3695 opened 6 days ago by Ermintar
  5

• Optimize a `MessagingMessageListenerAdapter` returning `null` from the `DelegatingInvocableHandler.invoke()`

  #3697 opened 12 days ago by artembilan
  0

• Memory leak on a Kafka Observation due to the metric "spring.kafka.listener.active"

  #3690 opened 20 days ago by vivi2701
  1

• Outdated DLT Topic Suffix in `DeadLetterPublishingRecoverer` Method Documentation

  #3693 opened 20 days ago by fcappi
  1

• KafkaMessageListenerContainer Observation Scope seems to be setup incorrectly

  #3686 opened a month ago by leaf-upper
  10

• EmbeddedKafkaBroker consume with seekToEnd does not reliably seek to the end

  #3660 opened a month ago by coekie
  0

• Confusing warning in batch listener: No batch message converter is set. because record message converter is null.

  #3687 opened a month ago by tom-mi
  1

• Change "synchronized" to reentrant lock for virtual-threads

  #3669 opened a month ago by spring-builds
  1

• EmbeddedKafkaBroker consume with seekToEnd does not reliably seek to the end

  #3668 opened a month ago by spring-builds
  1

• DefaultErrorHandler doesn't work with suspend methods

  #3618 opened 2 months ago by igloo12
  8

• Getting org.apache.kafka.common.errors.TimeoutException after upgrading to spring 3.4.0

  #3649 opened a month ago by Casper-dss
  4

• Allow kafka-clients 3.9.x with Spring-Kafka 3.3.x

  #3662 opened a month ago by bgK
  3

• EmbeddedKafkaCustomizer ignores adminTimeout in EmbeddedKafka annotation

  #3666 opened a month ago by spring-builds
  1

• EmbeddedKafkaCustomizer ignores adminTimeout in EmbeddedKafka annotation

  #3658 opened a month ago by markxj
  1

• Value parameters in ReactiveKafkaProducerTemplate should be nullable

  #3659 opened a month ago by spring-builds
  1

• Value parameters in ReactiveKafkaProducerTemplate should be nullable

  #3617 opened a month ago by aelfric
  5

• If the concurrency value of ConcurrentMessageListenerContainer is greater than the number of allocated partitions, isContainerPaused will always return false, even after pause has been called.

  #3650 opened a month ago by jongseok-oh
  6

• Provide a sample with webflux to develop http rest api

  #3657 opened a month ago by gianluca-sabena
  3

• Kafkaconsumer is not safe for multi-threading access

  #3655 opened a month ago by ayush11-96
  3

• addRetryableExceptions has no effect when called on the DefaultErrorHandler

  #3621 opened 2 months ago by devjeff
  8

• Potential Bug: Missing Failed Records During Async Operation

  #3638 opened 2 months ago by chickenchickenlove
  0

• Log conversion failures in batch listeners

  #3555 opened 2 months ago by schmidti159
  3

• Add a way to pass objects as values for @KafkaListerner properties

  #3580 opened 3 months ago by geertvb
  0

• Adds the ability to add record interceptors instead of override them

  #3542 opened 3 months ago by Nyamiou
  5

• Documentation on DLT strategies with batch mode listeners

  #3554 opened 3 months ago by StephenFlavin
  0

• Spring Boot Kafka Issue With Transactionality When Using ReplyingKafkaTemplate

  #3560 opened 3 months ago by periplanomenos
  0

• Example in Producer/Consumer Interceptors section of Spring Framework documentation need to be fixed

  #3587 opened 2 months ago by jourteen
  3

• Duplicate header processing in `BatchMessagingMessageConverter#processRecord()`

  #3589 opened 2 months ago by borahm-lee
  1

• Use Locale.ROOT for locale neutral, case insensitive comparisons

  #3610 opened 2 months ago by spring-builds
  1

• Use Locale.ROOT for locale neutral, case insensitive comparisons

  #3608 opened 2 months ago by artembilan
  0

• Use Locale.ROOT for locale neutral, case insensitive comparisons

  #3609 opened 2 months ago by spring-builds
  1

• Lower the replication factor for transactions topic when using embedded Kafka broker for tests

  #3557 opened 2 months ago by dlyash
  4

• Autowired does not support EmbeddedKafkaZKBroker

  #3585 opened 3 months ago by TheMagicNacho
  9

• NullPointerException in AbstractKafkaHeaderMapper

  #3584 opened 3 months ago by spring-builds
  1

• NullPointerException in AbstractKafkaHeaderMapper

  #3581 opened 3 months ago by ITman1
  1

• NullPointerException in AbstractKafkaHeaderMapper

  #3583 opened 3 months ago by spring-builds
  1

• Add an option to only commit consumer offsets for records that are not filtered out using RecordFilterStrategy

  #3562 opened 3 months ago by geertvb
  2

• Improving Observability in Asynchronous Processing (`CompletableFuture`, `Mono`)

  #3528 opened 3 months ago by chickenchickenlove
  5

• @KafkaListener containerPostProcessor SpEL expression is not being evaluated

  #3553 opened 3 months ago by spring-builds
  1

• @KafkaListener containerPostProcessor SpEL expression is not being evaluated

  #3544 opened 3 months ago by moiMeme
  0

• @KafkaListener containerPostProcessor SpEL expression is not being evaluated

  #3552 opened 3 months ago by spring-builds
  1

• Docs say `defaultRetryTopicKafkaTemplate` is the default template bean name. `@RetryableTopic` javadoc says `retryTopicDefaultKafkaTemplate`

  #3547 opened 3 months ago by spring-builds
  1

• Docs say `defaultRetryTopicKafkaTemplate` is the default template bean name. `@RetryableTopic` javadoc says `retryTopicDefaultKafkaTemplate`

  #3546 opened 3 months ago by spring-builds
  1