spring-cloud-stream-samples

spring-cloud-stream-samples copied to clipboard

Bumps [org.springframework:spring-core](https://github.com/spring-projects/spring-framework) from 5.2.24.RELEASE to 6.0.15. Release notes Sourced from org.springframework:spring-core's releases. v6.0.15 :star: New Features Skip buffer allocation in StreamUtils.copy(String) #31631 :lady_beetle: Bug Fixes <replaced-method /> unnecessarily requires explicit...

dependabot[bot]

Misspelling of letters

1

project : Spring Cloud Stream version : 3.2.4 Reference Doc. Spring Cloud Stream binder reference for Apache Kafka & Spring Cloud Stream binder reference for Apache Kafka Streams chapter 3.9.2...

Shelley-China

Consider adding Reactor Kafka binder sample app

1

@onobc @olegz @sobychacko I think it would be useful to add sample project, and to clarify how to acknowledge manually. Also - document error handling with DLQ. _Originally posted by...

onobc

We are using spring cloud stream kafka binder, org.springframework.cloud spring-cloud-stream-binder-kafka We are trying to override detault consumer properties mostly for below properties. spring: cloud: stream: kafka: #https://docs.spring.io/spring-cloud-stream/docs/current/reference/html/spring-cloud-stream-binder-kafka.html#_problem_statement bindings: process-in-0: consumer:...

voodemsanthosh

Since EmitterProcessor is deprecated, could you please update dependency?

javaHelper

schema-registry-confluent-avro-serializer: org.apache.avro.AvroRuntimeException: Not an enum:

8

As a user, deploying the `` schema-registry-confluent-avro-serializer`` demo i got a exception by `` curl -X POST http://localhost:9010/messages `` ``` Caused by: org.apache.avro.AvroRuntimeException: Not an enum: {"type":"record","name":"Sensor","namespace":"com.example","fields":[{"name":"id","type":"string"},{"name":"internalTemperature","type":"float","default":0.0,"aliases":["temperature"]},{"name":"externalTemperature","type":"float","default":0.0},{"name":"acceleration","type":"float","default":0.0},{"name":"velocity","type":"float","default":0.0},{"name":"accelerometer","type":["null",{"type":"array","items":"float"}]},{"name":"magneticField","type":["null",{"type":"array","items":"float"}]}]} at org.apache.avro.Schema.getEnumSymbols(Schema.java:233) at...

eskuai

Hi there We are migrating to Spring Boot 3.x. We have Spring Cloud Stream in use, specifically the SCS Binder from Solace. We have done experiments with micrometer-tracing-bridge-otel and micrometer-tracing-bridge-brave....

MikeR13

To run SpringCloudStream junits tests successfully always we need to enable @EnableAutoConfiguration and @ComponentScan annotations, but if we enable this we can't run application in real time and also mockito...

srajesh15

No sample for the Reactive Kafka binder

1

I haven't seen any example here for Project Reactor Kafka. Making the usage very hard.

rolkhas2

Reactor kafka samples

1

After the reactive kafka feature will get released I think it would be nice to see some samples here

markusherbert