Top "Spring-cloud-stream" questions

Spring boot Test fails saying, Unable to start ServletWebServerApplicationContext due to missing ServletWebServerFactory bean

Test Class:- @RunWith(SpringRunner.class) @SpringBootTest(classes = { WebsocketSourceConfiguration.class, WebSocketSourceIntegrationTests.class }, webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT, properties = { "websocket.path=/…

java spring spring-boot spring-cloud-stream

Kafka INVALID_FETCH_SESSION_EPOCH

We are using a kafka broker setup with a kafka streams application that runs using Spring cloud stream kafka. Although …

apache-kafka apache-kafka-streams spring-cloud-stream

Error to serialize message when sending to kafka topic

i need to test a message, which contains headers, so i need to use MessageBuilder, but I can not serialize. …

apache-kafka kafka-producer-api spring-cloud-stream spring-kafka

spring cloud stream 'bindingService' error

I am trying to implement Turbine AMQP to consolidate all the stream from multiple services to Hystrix Dashboard. So I …

spring-boot spring-cloud hystrix turbine spring-cloud-stream

A default binder has been requested, but there are no binders available for 'org.springframework.cloud.stream.messaging.DirectWithAttributesChannel'

I am trying to create the simplest as possible hello world with Spring Cloud + Kafka Streams + Spring Boot 2. I realize …

spring-boot apache-kafka apache-kafka-streams spring-cloud-stream

How to create unit test with kafka embedded in the spring cloud stream

Sorry for the question being too generic, but someone has some tutorial or guide on how to perform producer and …

junit apache-kafka spring-cloud spring-kafka spring-cloud-stream

Spring-Kafka vs. Spring-Cloud-Stream (Kafka)

Using Kafka as a messaging system in a microservice architecture what are the benefits of using spring-kafka vs. spring-cloud-stream + spring-cloud-starter-stream-kafka ? …

spring spring-integration spring-cloud-stream spring-kafka

Deserialize JSON date format to ZonedDateTime using objectMapper

Background I have the following JSON (message from Kafka) { "markdownPercentage": 20, "currency": "SEK", "startDate": "2019-07-25" } I have the following (JSON …

java json spring-boot jackson spring-cloud-stream

Kafka producer JSON serialization

I'm trying to use Spring Cloud Stream to integrate with Kafka. The message being written is a Java POJO and …

spring apache-kafka spring-cloud-stream spring-kafka

Spring Cloud Stream message from/to JSON conversion configuration

I am using Spring Cloud Stream, with RabbitMQ binder. It works great with byte[] payload and Java native serialization, but …

json spring-cloud spring-rabbit spring-cloud-stream