2020欧洲杯时间表

Dark mode beta

You’ve been asking for dark mode for years.
The is finally here.

Change your preferences any time.

Questions tagged [spring-cloud-stream]

Spring Cloud Stream allows a user to develop and run messaging microservices using Spring Integration and run them locally, or in the cloud, or even on Spring Cloud Data Flow. Just add @EnableBinding and run your app as a Spring Boot app (single application context). You just need to connect to the physical broker for the bus, which is automatic if the relevant bus implementation is available on the classpath.

Filter by
Sorted by
Tagged with
0
votes
0answers
38 views

How Spring Cloud Stream reactive processing works?

How to achieve reactive message processing in Spring Cloud Stream? I read about Spring Cloud Function and that I should use them for reactive processing so I created sample one: @Bean public Consumer&...
0
votes
0answers
37 views

Spring cloud stream rabbitmq - consumer retries 3 times for all exception

I am trying to stop the retires for my spring boot cloud application completely or retry for only specific exceptions I have tried several ways to completely stop it from retrying 3 times I set the ...
0
votes
0answers
27 views

Spring Cloud Data Flow: deploy stream defined with Java DSL

I'm using Spring Cloud Data Flow. Is there any way to deploy a stream defined with the Java DSL providing the .jar uri instead of executing it as a client? I want to threat it like the applications ...
1
vote
1answer
31 views

Getting ClassCastException when sending error message to kafka dlq

I'm using kafka with spring cloud streams. My listener code looks like this @Bean public Consumer<List<Map<String, Object>>> receive() throws MyException { return ...
0
votes
1answer
28 views

how to set concurrency (or other configurations) for ConcurrentKafkaListenerContainerFactory per StreamListener

We have scenario where our application(spring boot, spring-cloud-stream based) listens to multiple Kafka topics (TOPIC_A with 3 partitions, TOPIC_B with 1 partition,TOPIC_C with 10 partitions) i.e. 3 @...
3
votes
2answers
62 views

Serde error in Kafka Streams process with Spring Cloud Stream

I´m trying to process some Kafka records using Spring Cloud Stream 3.0.3.RELEASE, but I´m having trouble with Serdes configuration getting an error as soon as a record enters the stream pipeline. ...
0
votes
1answer
26 views

How do I access header information in kafka materialized views?

how do I access custom headers in a materialized view? I'm trying to build some custom dlq logic in my application and want to build a retry mechanism based on header information. The actual retry is ...
0
votes
1answer
44 views

How to wait for a finite stream bulk result

I have a stream processing application built with spring cloud streams & kafka streams, this system takes logs from an application and compares them to observations made by another stream ...
0
votes
1answer
50 views

Spring Cloud Stream topic per message for different consumers (in one Comsumer app)

This question is similar to Spring Cloud Stream topic per message for different consumers but the difference is that I want multiple Sinks in one consumer springboot application and I want to do this ...
0
votes
0answers
10 views

How to configure different aws credentials for Kinesis streams with Spring Cloud Stream

I have two Kinesis streams that I need to consume but they have different credentials. In issue http://github.com/spring-cloud/spring-cloud-stream-binder-aws-kinesis/issues/74 it says: "...The ...
0
votes
1answer
44 views

Spring cloud function to create a GlobalKTable from strem

Is there an example of how to create a GlobalKTable to keep count from a KStream using Spring Cloud stream and using Functional approach?
0
votes
0answers
33 views

Error creating bean with name 'compositeMessageChannelConfigurer' defined in org.springframework.cloud.stream.config.BinderFactoryAutoConfiguration

enter image description here Micro service 1: artefact id - microservice1 Defined KafkaStreams.java interface where in defined the binder properties like below. public interface KafkaStreams { ...
0
votes
1answer
32 views

Spring Cloud Kafka stream DefaultPollableMessageSource not available

Hello I'm testing spring cloud & kafka stream and got error. Error Log: org.springframework.context.ApplicationContextException: Failed to start bean 'inputBindingLifecycle'; nested exception is ...
1
vote
1answer
41 views

Spring cloud stream: multiple binder for Kafka Producer and Consumer with separate jaas configuration doesn't work together

I am trying to implement Kafka consumer and Kafka producer within same Spring boot application using spring cloud and binder. Both run successfully if executed separately, but if executed together ...
-1
votes
1answer
20 views

Bean not found for topic name when using BinderAwareChannelResolver

I am using BinderAwareChannelResolver to publish messages to dynamic topics. Its throwing Failed to find MessageChannel bean with name 'topic-name'.

15 30 50 per page
1
2 3 4 5
96