python (12.9k questions)

javascript (9.2k questions)

reactjs (4.7k questions)

java (4.2k questions)

java (4.2k questions)

c# (3.5k questions)

c# (3.5k questions)

html (3.3k questions)

Questions - spring-cloud-stream-binder-kafka

Using Spring Cloud Stream Kafka Streams with Avro input/output with nativeEncoding/decoding=false

We're testing the use of Kafka Streams via Spring Cloud Stream function support with Avro input/output records, but setting nativeEncoding=false and nativeDecoding=false in order to use a custom Messa...
test-img

José María Lora

spring-boot

apache-kafka

apache-kafka-streams

spring-cloud-stream

spring-cloud-stream-binder-kafka

Votes: 0

Answers: 1

Latest Answer

For Kafka Streams binder in Spring Cloud Stream, we recommend using native decoding/encoding with Serdes unless you have strong reasoning for relying on the message conversion approach. What is the us...
test-img

sobychacko

Spring Cloud Stream Kafka - "Failed to create topics" error for consumer

I am running JDK 11, Spring Boot 2.5.5 and Spring Cloud 2020.0,5 and Kafka 2.7.2. When I have this consumer code with a Message Type of my business object: @Bean public Consumer<Message<MyOb...
test-img

sgsd

spring-cloud-stream-binder-kafka

Votes: 0

Answers: 1

Latest Answer

This issue is due to carelessness on my part. The method signature should be: public Consumer<Message<MyObjectType>> consumer()
test-img

sgsd

Spring cloud stream routing on payload

I want to use spring cloud stream for my microservice to handle event from kafka. I read from one topic that can hold several JSON payloads (I have one topic since its all messages arrived to it are f...
test-img

user1409534

apache-kafka

spring-cloud-stream

spring-cloud-stream-binder-kafka

Votes: 0

Answers: 1

Latest Answer

It is not clear from the question whether you are using the message channel-based Kafka binder or Kafka Streams binder. The comments above imply some reference to KStream. Assuming that you are using ...
test-img

sobychacko

How to set Key in Stream cloud function

I'm using stream cloud stream in order to receive and publish events to kafka I also use the functional programing model. Say I have this bean definition: @Bean public Function<InputMsg,OutputMsg&g...
test-img

user1409534

apache-kafka

spring-cloud-stream

spring-cloud-stream-binder-kafka

Votes: 0

Answers: 1

Latest Answer

Use Function<Message<InputMsg>, Message<OutputMsg>> instead. In the inbound message, the key is in msg.getHeaders().get(KafkaHeaders.RECEIVED_MESSAGE_KEY); to set the key in the outb...
test-img

Gary Russell

Posts

Questions

Blogs

Jobs