spring-cloud-stream-binder-kafka

spring-cloud-stream-binder-kafka copied to clipboard

I am using spring cloud streams with Kafka Streams binder. Is it possible to retrieve the header of the received message, and in particular its timestamp?

antonio-milkman

Hi, I'm using the dependency ```xml org.springframework.cloud spring-cloud-stream-binder-kafka 3.2.6 ``` I require the use of the `destination-is-prefix` feature for my consumers, but I've noticed that it disables the DLQs. During...

acoboh

See https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-stream-binder-kafka-streams/3.2.3 and https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-stream-binder-kafka-streams/3.2.4 and you will clearly see that spring-kafka-test is listed as a compile dependency The cause seems to be that the scope was unspecified in the spring-cloud-stream-binder-kafka-stream...

simontankersley

A Topic lost a subscription node during run time

2

Spring boot Version : 2.5.0 Spring Cloud Version ： 2020.0.3 I used Spring-Cloud-stream-binder - Kafka and Spring-cloud-stream-binder - Kafka-Streams for kafka production and consumption in the project. In one project,...

hero-zhanghao

Hello I am looking for if we can Publish / Consume to AWS MSK which has a IAM based authentication enabled. Looking for sample or documentation for the same. Sorry...

ashevade1

Spring boot Version : 2.5.0 Spring Cloud Version ： 2020.0.3 I used Spring-Cloud-stream-binder - Kafka and Spring-cloud-stream-binder - Kafka-Streams for kafka production and consumption in the project. I found in...

hero-zhanghao

Dynamic routing by KafkaBinder

2

Hi, I am trying to create a simple application that will consume records from one topic and route them to multiple topics. I have an expression that resolves the destination...

uladzislau-belykh

Cannot convert from [[B] to [com.example.DummyMessage] for GenericMessage

13

**Describe the issue** After upgrade from spring-cloud-starter-parent from Hoxton.SR1 to Hoxton.SR2 we received following error when consuming kafka messages avro encoded from legacy microservices used springboot 1.5.x: ``` Caused by:...

metalpalo

cannot fully disable kafka binder and cloud stack for testing

7

hi, we are using ```xml org.springframework.cloud spring-cloud-starter-stream-kafka ${spring-cloud-stream-binder-kafka.version} //3.1.3 ``` When running tests the **AdminClient** (and the larger cloud stack) attempts to init on every test. We do have an...

JohnnyXavier

See this comment: https://github.com/spring-cloud/spring-cloud-stream-binder-kafka/pull/1023#pullrequestreview-581824259

sobychacko