spring-cloud-stream-samples

spring-cloud-stream-samples copied to clipboard

Right now we can programmatically select destination using following spring.cloud.stream.sendto.destination and StreamBridge like we have for functions we can do conditional selecting of message using spring.cloud.function.routing-expression It will be better...

vishalrijhwani

I am running the `kafka-streams-interactive-query-basic` example in standalone and giving me some issues. Any quick help? Error: ```java java.lang.IllegalStateException: Error retrieving state store: prod-id-count-store at org.springframework.cloud.stream.binder.kafka.streams.InteractiveQueryService.lambda$getQueryableStore$0(InteractiveQueryService.java:115) ~[spring-cloud-stream-binder-kafka-streams-3.2.5.jar!/:3.2.5] at org.springframework.retry.support.RetryTemplate.doExecute(RetryTemplate.java:329) ~[spring-retry-1.3.4.jar!/:na]...

javaHelper

schema-registry-vanilla-kafka-binder: Field customSerde in sample.consumer.CountVersionApplication required a single bean, but 2 were found:

3

Hi, As a user, i am testing samples from schema-registry-vanilla-kafka-binder- Schema registry starts ok ``` [ec2-user@k8s-master tmp]$ java -jar schema-registry-server.jar . ____ _ __ _ _ /\\ / ___'_ __...

eskuai

Would be great if you can add sample data to test kafka-streams-samples examples I am getting clear on how to test the app

javaHelper

set default clientId throws InstanceAlreadyExistsException

9

Hi Team I'm using **Greenwich.RC2** spring cloud version for my project. I try to set client.id specification for the kafka binder and gets below exception. How to set the client.id...

PrabaharanK

org.springframework.cloud spring-cloud-starter-stream-rocketmq 0.9.0.RELEASE  1、I found that I could not configure synchronous sending messages, resulting in the return code always being true.  so, How to configure synchronous sending messages?

CC-PP

```sh user@Shrutikas-MacBook-Pro ~ % kcat -b localhost:9092 -t words -P ``` Not working

javaHelper

Since now we have the support for it via https://github.com/spring-cloud/spring-cloud-stream-binder-rabbit/commit/d95a1c1a95a60493355bf50c88c3c5d226c49f6a, it'd be good to add a sample to highlight the functionality.

sabbyanandan

'void org.springframework.cloud.stream.binder.kafka.streams.function.KafkaStreamsBindableProxyFactory.populateBindingTargetFactories

2

I am getting below error when I tried to run the code for kafka-stream-table-join example. ```java Error starting ApplicationContext. To display the conditions report re-run your application with 'debug' enabled....

javaHelper

Hello, I am creating a simple "Hello World" Kafka Streaming application. My Producer is producing protobuf serialize messages to one topic and I'm using that topic in Kafka Streaming application...

vishaldhanani