Soby Chacko

Results 81 comments of Soby Chacko

@sdeleuze We added the native support only for the regular Kafka binder, but not for Kafka Streams binder. There is [this issue](https://github.com/spring-cloud/spring-cloud-stream-binder-kafka/issues/1064). I've seen this error from Kafka Streams binder...

@metalpalo Spring Cloud Schema Registry is now deprecated and is already disconnected from Spring Cloud Stream. We recommend not using that at this point with Spring Cloud Stream. We suggest...

@metalpalo When using native encoding, Spring Cloud Stream does not use content type but relies on native serializers. Why do you need to copy that? Any particular use case?

I think that might be the default content type set by Spring Cloud Stream. What value does it set? `applcation/json`? Does it cause any issues to your use case? If...

Hi everyone @ghahramani @UgiR @roger751 @lynch19 @kairurooj @thepaep @ipanimnim @fluxstirngchanle @rancherz @devlap2 The initial version of a reactive binder for Kafka is now merged upstream to the main branch. Please...

@devlap2 @ipanimnim Did you get a chance to try out the reactive Kafka binder based on the `4.0.0-M1` (or `SNAPSHOT`)? We would love to receive some feedback on this as...

@markusherbert Sure, we will add a sample there. But in the meantime, please take a look at this [test](https://github.com/spring-cloud/spring-cloud-stream/blob/main/binders/kafka-binder/spring-cloud-stream-binder-kafka-reactive/src/test/java/org/springframework/cloud/stream/binder/reactorkafka/ReactorKafkaBinderIntegrationTests.java#L128) to get a basic idea.

More context: https://stackoverflow.com/questions/72545627/access-spring-cloud-stream-kafka-materialized-view-with-external-client

@ncheema When you have dynamic destinations, the destination itself becomes an output binding at runtime. Therefore, in the case of multi binders, you have to specify which binder to attach...