spring-cloud-stream-binder-kafka Questions
1
Solved
There are so few examples of different methods of error-handling in spring cloud streams, and the few that are provided partially via the documentation don't seem to work either.
I have a test repo...
Surreptitious asked 15/7, 2023 at 23:47
2
Solved
I think it's related to the below links, but I don't understand.
https://issues.apache.org/jira/browse/KAFKA-6535
https://issues.apache.org/jira/browse/KAFKA-6150
Kafka Streams deleting consumed r...
Rapprochement asked 30/1, 2021 at 18:59
2
I have a spring boot application which has two functionalities Http requests and kafka Messages handling. I want this application to run in mode which is enabled from application.yml i.e if the use...
Eardrop asked 12/5, 2020 at 5:26
2
Solved
I am using Spring Cloud Streams with the Kafka Streams Binder, the functional
style processor API and also multiple processors.
It's really cool to configure a processing application with multiple ...
Cozenage asked 29/9, 2021 at 17:16
1
Solved
I am using Spring Cloud Stream 3.1.2 for KafkaStreams. The programming models are:
Functional Programming
Imperative Programming
The latter one uses annotations as all the other annotations that ...
Mencher asked 2/4, 2021 at 20:38
2
Solved
I am trying to do a simple POC with Kafka Streams. However I am getting exception while starting the application. I am using Spring-Kafka, Kafka-Streams 2.5.1 with Spring boot 2.3.5
Kafka stream co...
Congregational asked 19/1, 2021 at 13:47
0
I am using Spring Cloud Stream Kafka binder to consume messages from Kafka. I am able to make my sample work with a single Kafka Binder as below
spring:
cloud:
stream:
kafka:
binder:
consumer-...
Futtock asked 28/6, 2020 at 10:16
1
Solved
I have a Spring Cloud Stream project using the Kafka binder and I'm trying to understand and eventually customize the RetryTemplate used by Cloud Stream.
I'm not finding a lot of documentation on ...
Shieh asked 8/6, 2020 at 20:49
1
Extremely slow startup of a Spring Cloud Stream Kafka application when using enable.idempotence true
My Scs application has two Kafka producers with this configuration:
spring:
cloud:
function:
definition: myProducer1;myProducer2
stream:
bindings:
myproducer1-out-0:
destination: topic1
pr...
Solothurn asked 14/4, 2020 at 10:33
1
Solved
I have create a spring-boot-2 gradle project, also in build.gradle file i have added Kafka related dependency which given below.
dependencies {
implementation 'org.springframework.cloud:spring-cl...
Joplin asked 20/8, 2019 at 8:40
1
© 2022 - 2024 — McMap. All rights reserved.