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

Issues

• Enable DLQ with destinations as pattern

  #1226 opened 2 months ago by acoboh
  0

• Unable to start spring boot application when using KTable as output , KStream as output and KTable as Input

  #1237 opened 4 months ago by rameshmandri
  0

• Health Check for Binders Always Shows 'UNKNOWN' Status Due to Empty binderHealthContributors Map (Missing Bean Configuration for ReactorKafkaBinderHealthIndicator?)

  #1235 opened 7 months ago by hb12devtn
  2

• Fetch message timestamp

  #1234 opened 8 months ago by antonio-milkman
  0

• Classpath reference doesn't work for arbitrary consumerProperties

  #1170 opened 3 years ago by eduardolbueno
  9

• Spring Cloud stream binder kafka DLQ Handling for Batching doesn't work

  #1225 opened 2 years ago by Sachin111us
  2

• Unknown Autoconfigured KafkaAvroSerializer and KafkaAvroDeSerializers

  #1224 opened a year ago by bjeSSAdev
  2

• [Feature Request] Allow to accept a list of customizers instead of a unique one for KafkaMessageChannelBinder

  #1217 opened 2 years ago by yiliuTo
  1

• Batch mode is not working

  #1221 opened 2 years ago by avramakrishna
  1

• Can't convert value of class java.lang.String to class org.apache.kafka.common.serialization.ByteArraySerializer specified in value.serializer, failedMessage=GenericMessage

  #1154 opened 3 years ago by clay-f
  3

• spring-kafka-test is compile (not test) dependency of spring-cloud-stream-binder-kafka-streams:3.2.3 and 3.2.4

  #1219 opened 3 years ago by simontankersley
  0

• A Topic lost a subscription node during run time

  #1183 opened 3 years ago by hero-zhanghao
  2

• Looking for a sample with AWS MSK IAM

  #1214 opened 3 years ago by ashevade1
  0

• DefaultErrorHandler not exists

  #1200 opened 3 years ago by dulm
  4

• Kafka Streams Serdes having nested generic doesn't work

  #1205 opened 3 years ago by AnandMandhre
  3

• ListenerContainerWithDlqAndRetryCustomizer template points to localhost:9092

  #1208 opened 3 years ago by sidsamant
  5

• Kafka streams application not able to pickup the custom serde provided

  #1168 opened 3 years ago by nehasewda
  8

• AdminClient / KafkaAdmin with merged standard kafka and binder properties

  #1178 opened 3 years ago by skomarica
  2

• Cannot disable nativeEncoding/nativeDecoding in general for Kafka Streams binder

  #1182 opened 3 years ago by ferblaca
  4

• Inbound KTable (and possibly GlobalKTable) ignoring nativeDecoding=false

  #1191 opened 3 years ago by JoseLora
  1

• @EmbeddedKafka not working properly with GlobalKTable and transformer

  #1196 opened 3 years ago by ecristobal
  1

• Support for DLQ in batch mode

  #1206 opened 3 years ago by snussbaumer
  1

• spring.cloud.stream.bindings.process-in-0.consumer.concurrency not working in case of UpperCase letter in process name

  #1207 opened 3 years ago by wouterTj
  1

• KafkaBinderMetrics prevent JVM shutdown due to not shutting down scheduler thread pool!

  #1203 opened 3 years ago by tschaper69
  8

• publishing to incorrect partition in DLQ

  #1181 opened 3 years ago by karthik86
  2

• Kafka bindings from previous test class remains active in the next test class

  #1204 opened 3 years ago by ofirgrm
  2

• Live producer threads and dynamic-destination-cache-size property

  #1198 opened 3 years ago by ferblaca
  2

• NOT_ENOUGH_REPLICAS Errors After Upgrading The Spring Boot And Spring Cloud Version

  #1202 opened 3 years ago by omercelikceng
  5

• ClassCastException in pipeline: Kafka Streams Function -> Kafka Function -> Kafka Streams Consumer

  #1201 opened 3 years ago by aliaksandr-pleski
  5

• How to wait for future inside Kafka Stream map()?

  #1199 opened 3 years ago by alkazap
  2

• Fix Pause/Resume Documentation

  #1195 opened 3 years ago by xabe
  6

• Use of @EmbeddedKafka with Kafka Streams binder

  #1192 opened 3 years ago by ecristobal
  8

• Kafka creating more partitions than hardcoded in the properties file

  #1190 opened 3 years ago by rshmvarma
  3

• 2 Consumers of same topic

  #1194 opened 3 years ago by chrismpalmer
  5

• Spring Cloud Stream binder

  #1180 opened 3 years ago by abdulshaikh76
  2

• Wrong type header information when using Function

  #1187 opened 3 years ago by ecristobal
  2

• Spring Boot web endpoints are queryable before HostInfo becomes available

  #1185 opened 3 years ago by TiewKH
  1

• Topic and header will be omitted when using event type based routing

  #1186 opened 3 years ago by andrashatvani
  1

• Repeated consumption of a previous successful consumption every 5 minutes for half an hour

  #1184 opened 3 years ago by hero-zhanghao
  0

• KeyValueSerdeResolver uses streamConfigGlobalProperties and ignores extended consumer/producer properties

  #1176 opened 3 years ago by yanayita
  0

• Cannot invoke "org.springframework.core.ResolvableType.getType()" because "types[0]" is null

  #1156 opened 3 years ago by andrashatvani
  9

• InteractiveQueryService breaks Streams Application Isolation if mutliple Stream Apps using same Store Name

  #1161 opened 3 years ago by nico-javadev
  4

• Make health indicator configurable by the users

  #1165 opened 3 years ago by magnusLechner
  3

• Migrate recipes from samples repo to the main docs

  #1173 opened 3 years ago by sobychacko
  0

• Setting own bootstrap.server/Kafka cluster for the DLT of a binding

  #1160 opened 3 years ago by orvyl
  7

• Error creating bean with name 'functionBindingRegistrar' defined in class path resource

  #1163 opened 3 years ago by duskox
  2

• Question: how to send messages to multiple topics?

  #1167 opened 3 years ago by benkeil
  2

• Dynamic routing by KafkaBinder

  #1164 opened 3 years ago by uladzislau-belykh
  2

• Getting NPE for binding bean creation with multiple binding functions (one of them isn't streams app)

  #1159 opened 3 years ago by AttitudeL
  3

• Producer callback in Spring Cloud Stream with reactor core publisher

  #1155 opened 3 years ago by aniket0788
  1