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

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

Spring Cloud Stream binders for Apache Kafka and Kafka Streams

Apache License 2.0

330 stars 301 forks source link

issues

Newest

Newest Most commented Recently updated Oldest Least commented Least recently updated

Fix typo

#1236 berry120 closed 3 weeks ago
1
Health Check for Binders Always Shows 'UNKNOWN' Status Due to Empty binderHealthContributors Map (Missing Bean Configuration for ReactorKafkaBinderHealthIndicator?)

#1235 hb12devtn closed 2 months ago
2
Fetch message timestamp

#1234 antonio-milkman opened 3 months ago
0
Fixed broken links in doc

#1232 Claudio-code closed 1 year ago
3
Correct configuration for AckMode in the tips document

#1229 jskim1991 closed 1 year ago
0
Enable DLQ with destinations as pattern

#1226 acoboh opened 1 year ago
0
Spring Cloud stream binder kafka DLQ Handling for Batching doesn't work

#1225 Sachin111us closed 1 year ago
2
Unknown Autoconfigured KafkaAvroSerializer and KafkaAvroDeSerializers

#1224 bjeSSAdev closed 1 year ago
2
fix(dependency): set "spring-kafka-test" scope to "test"

#1223 pinguet62 closed 1 year ago
1
Batch mode is not working

#1221 avramakrishna closed 1 year ago
1
GH-1217: Enable multiple customziers for binder and provisioner

#1220 yiliuTo closed 2 years ago
3
spring-kafka-test is compile (not test) dependency of spring-cloud-stream-binder-kafka-streams:3.2.3 and 3.2.4

#1219 simontankersley opened 2 years ago
0
Fixes typo for kafka-streams documentation

#1218 RachanaDevi closed 2 years ago
1
[Feature Request] Allow to accept a list of customizers instead of a unique one for KafkaMessageChannelBinder

#1217 yiliuTo closed 1 year ago
1
Looking for a sample with AWS MSK IAM

#1214 ashevade1 opened 2 years ago
0
GH-1203: Clean up resources on close. Allow terminating an applicatio…

#1213 tszmytka closed 2 years ago
3
Update documentation for ListenerContainerWithDlqAndRetryCustomizer

#1209 sidsamant closed 2 years ago
4
ListenerContainerWithDlqAndRetryCustomizer template points to localhost:9092

#1208 sidsamant closed 2 years ago
5
spring.cloud.stream.bindings.process-in-0.consumer.concurrency not working in case of UpperCase letter in process name

#1207 wouterTj closed 2 years ago
1
Support for DLQ in batch mode

#1206 snussbaumer closed 2 years ago
1
Kafka Streams Serdes having nested generic doesn't work

#1205 AnandMandhre closed 2 years ago
3
Kafka bindings from previous test class remains active in the next test class

#1204 ofirgrm closed 2 years ago
2
KafkaBinderMetrics prevent JVM shutdown due to not shutting down scheduler thread pool!

#1203 tschaper69 closed 2 years ago
8
NOT_ENOUGH_REPLICAS Errors After Upgrading The Spring Boot And Spring Cloud Version

#1202 omercelikceng closed 2 years ago
5
ClassCastException in pipeline: Kafka Streams Function -> Kafka Function -> Kafka Streams Consumer

#1201 aliaksandr-pleski closed 2 years ago
5
DefaultErrorHandler not exists

#1200 dulm closed 2 years ago
4
How to wait for future inside Kafka Stream map()?

#1199 alkazap closed 2 years ago
2
Live producer threads and dynamic-destination-cache-size property

#1198 ferblaca closed 2 years ago
2
GH-1195: Fix Pause/Resume Documentation

#1197 garyrussell closed 2 years ago
1
@EmbeddedKafka not working properly with GlobalKTable and transformer

#1196 ghost closed 2 years ago
1
Fix Pause/Resume Documentation

#1195 xabe closed 2 years ago
6
2 Consumers of same topic

#1194 chrismpalmer closed 2 years ago
5
Update documented version of kafka-clients

#1193 jaylindquist closed 2 years ago
4
Use of @EmbeddedKafka with Kafka Streams binder

#1192 ghost closed 2 years ago
8
Inbound KTable (and possibly GlobalKTable) ignoring nativeDecoding=false

#1191 JoseLora closed 2 years ago
1
Kafka creating more partitions than hardcoded in the properties file

#1190 rshmvarma closed 2 years ago
3
Fixed invalid java code snippet

#1189 Recks11 closed 2 years ago
1
Enable custom binder health check impelementation

#1188 sobychacko closed 2 years ago
0
Wrong type header information when using Function

#1187 ghost closed 2 years ago
2
Topic and header will be omitted when using event type based routing

#1186 andrashatvani closed 2 years ago
1
Spring Boot web endpoints are queryable before HostInfo becomes available

#1185 TiewKH closed 2 years ago
1
Repeated consumption of a previous successful consumption every 5 minutes for half an hour

#1184 hero-zhanghao opened 2 years ago
0
A Topic lost a subscription node during run time

#1183 hero-zhanghao opened 2 years ago
2
Cannot disable nativeEncoding/nativeDecoding in general for Kafka Streams binder

#1182 ferblaca closed 2 years ago
4
publishing to incorrect partition in DLQ

#1181 karthik86 closed 2 years ago
2
Spring Cloud Stream binder

#1180 abdulshaikh76 closed 2 years ago
2
Fix: KeySerde setup not using expected key type headers

#1179 yanayita closed 2 years ago
1
AdminClient / KafkaAdmin with merged standard kafka and binder properties

#1178 skomarica closed 2 years ago
2
Use extended properties when initializing Consumer and Producer Serde

#1177 yanayita closed 2 years ago
5
KeyValueSerdeResolver uses streamConfigGlobalProperties and ignores extended consumer/producer properties

#1176 yanayita closed 2 years ago
0