# \#spring-cloud-stream **URL:** https://community.solace.com/tag/spring-cloud-stream/37.md [Latest](https://community.solace.com/latest.md) · [Categories](https://community.solace.com/categories.md) · [Tags](https://community.solace.com/tags.md) --- ## [Spring Cloud Stream Solace binder: consumer fails deserializing inbound headers after upgrade — how to disable/skip header deserialization?](https://community.solace.com/t/spring-cloud-stream-solace-binder-consumer-fails-deserializing-inbound-headers-after-upgrade-how-to-disable-skip-header-deserialization/4787)
**Author:** [@himanshu007](https://community.solace.com/u/himanshu007)\ **Replies:** 5\ **Last updated:** [March 12, 2026, 7:30am UTC](https://community.solace.com/t/spring-cloud-stream-solace-binder-consumer-fails-deserializing-inbound-headers-after-upgrade-how-to-disable-skip-header-deserialization/4787 "2026-03-12T07:30:20Z")
Hi Solace Community, After upgrading a Spring Cloud Stream consumer (Solace binder), the consumer fails before my handler runs with a header deserialization error like: Failed to deserialize object / InvalidClassExcept… --- ## [In-memory keystore/truststore for Solace SCSt](https://community.solace.com/t/in-memory-keystore-truststore-for-solace-scst/4506)
**Author:** [@baldpate](https://community.solace.com/u/baldpate)\ **Replies:** 5\ **Last updated:** [August 19, 2025, 6:53am UTC](https://community.solace.com/t/in-memory-keystore-truststore-for-solace-scst/4506 "2025-08-19T06:53:40Z")
Hi, Per requirements, we have to use client authentication for our java app connection to Solace. The cert may be self-signed so we need to add cert to both key store and trust store. May I know if in-memory keystore/… --- ## [JPA Databases micro-integration plugin problems](https://community.solace.com/t/jpa-databases-micro-integration-plugin-problems/4404)
**Author:** [@pjarema](https://community.solace.com/u/pjarema)\ **Replies:** 1\ **Last updated:** [June 21, 2025, 7:47am UTC](https://community.solace.com/t/jpa-databases-micro-integration-plugin-problems/4404 "2025-06-21T07:47:01Z")
Hello, As this is my first post - welcome to the group . We are struggling with running https://solace.com/integration-hub/databases-jpa/ - (version 2.0.1) micro integration plugin. I did not have any problems with r… --- ## [OAuth2 with spring-cloud-stream + reactive web?](https://community.solace.com/t/oauth2-with-spring-cloud-stream-reactive-web/4280)
**Author:** [@user16](https://community.solace.com/u/user16)\ **Replies:** 1\ **Last updated:** [May 17, 2025, 2:27am UTC](https://community.solace.com/t/oauth2-with-spring-cloud-stream-reactive-web/4280 "2025-05-17T02:27:42Z")
Hello, can someone let me know if the following combination is supported? Spring Boot 3.4.x spring-boot-starter-oauth2-client using OAuth2 client credentials flow Spring WebFlux (i.e., reactive stack — no spring-boot-s… --- ## [Debezium - Solace connector with AUTHENTICATION\_SCHEME\_CLIENT\_CERTIFICATE](https://community.solace.com/t/debezium-solace-connector-with-authentication-scheme-client-certificate/4217)
**Author:** [@skylinek](https://community.solace.com/u/skylinek)\ **Replies:** 1\ **Last updated:** [May 3, 2025, 9:32am UTC](https://community.solace.com/t/debezium-solace-connector-with-authentication-scheme-client-certificate/4217 "2025-05-03T09:32:17Z")
Hello, i would like to use solace-debezium connector (running in container - https://hub.docker.com/r/solace/solace-pubsub-connector-debezium) with our company solace. I would like to use authentication with certificat… --- ## [Problem with new Snowflake connector](https://community.solace.com/t/problem-with-new-snowflake-connector/4083)
**Author:** [@MartinCairns](https://community.solace.com/u/MartinCairns)\ **Replies:** 4\ **Last updated:** [April 26, 2025, 2:27am UTC](https://community.solace.com/t/problem-with-new-snowflake-connector/4083 "2025-04-26T02:27:11Z")
Hi, When testing the v3 snowflake connector from Solace Snowflake Docker all the json messages are being delivered as a base64 encoded string to the record\_content column, the record\_metadata column is unchanged as json… --- ## [Subject: Issue with Mismatched Topic and QoS in SUBACK Response](https://community.solace.com/t/subject-issue-with-mismatched-topic-and-qos-in-suback-response/4131)
**Author:** [@Srikanth\_bethi](https://community.solace.com/u/Srikanth_bethi)\ **Replies:** 1\ **Last updated:** [April 15, 2025, 9:23am UTC](https://community.solace.com/t/subject-issue-with-mismatched-topic-and-qos-in-suback-response/4131 "2025-04-15T09:23:05Z")
I am encountering an issue while using MQTT over WebSockets. Specifically, when I attempt to subscribe a message using a topic, the “granted QoS” field in the SUBACK response is always empty. The issue arises in the foll… --- ## [Solace MQ Connector - Solace Connector is broken when Failover/Failback occurs in Solace HA](https://community.solace.com/t/solace-mq-connector-solace-connector-is-broken-when-failover-failback-occurs-in-solace-ha/3991)
**Author:** [@Farzin](https://community.solace.com/u/Farzin)\ **Replies:** 1\ **Last updated:** [March 17, 2025, 1:40pm UTC](https://community.solace.com/t/solace-mq-connector-solace-connector-is-broken-when-failover-failback-occurs-in-solace-ha/3991 "2025-03-17T13:40:31Z")
Hi all, We are currently validating Solace MQ Connector in staging environment for future deployment in production environment. Solace MQ Connector instances (deployed on OCP4 platform in mode active/standby) are instal… --- ## [Solace Spring Cloud processor app issues after the upgrade of the Spring libraries](https://community.solace.com/t/solace-spring-cloud-processor-app-issues-after-the-upgrade-of-the-spring-libraries/2107)
**Author:** [@MickeyZ](https://community.solace.com/u/MickeyZ)\ **Replies:** 6\ **Last updated:** [January 14, 2025, 9:11am UTC](https://community.solace.com/t/solace-spring-cloud-processor-app-issues-after-the-upgrade-of-the-spring-libraries/2107 "2025-01-14T09:11:02Z")
Previously, before the upgrade of Spring libraries we used: org.springframework.boot:spring-boot-gradle-plugin:3.3.5 org.springframework.integration:spring-integration-core:6.3.2 org.springframework.cloud:spring-cloud-… --- ## [Implement a custom function that will be triggered when the application connects back to Solace](https://community.solace.com/t/implement-a-custom-function-that-will-be-triggered-when-the-application-connects-back-to-solace/2096)
**Author:** [@himanshu007](https://community.solace.com/u/himanshu007)\ **Replies:** 1\ **Last updated:** [January 3, 2025, 4:33pm UTC](https://community.solace.com/t/implement-a-custom-function-that-will-be-triggered-when-the-application-connects-back-to-solace/2096 "2025-01-03T16:33:42Z")
Hello Community, I am using solace spring stream for our application. We came across an issue where the connection gets broken to Solace. We need to check live site when solace gets connected, only then we start the bind… --- ## [Spring Cloud Stream exception: "doesn't support message NACK" after upgrading Solace Binder to v5.x](https://community.solace.com/t/spring-cloud-stream-exception-doesnt-support-message-nack-after-upgrading-solace-binder-to-v5-x/2058)
**Author:** [@JamilAhmed](https://community.solace.com/u/JamilAhmed)\ **Replies:** 1\ **Last updated:** [October 21, 2024, 3:24pm UTC](https://community.solace.com/t/spring-cloud-stream-exception-doesnt-support-message-nack-after-upgrading-solace-binder-to-v5-x/2058 "2024-10-21T15:24:15Z")
Are you seeing this exception from your Spring Cloud Stream application? Caused by: org.springframework.messaging.MessagingException: The Solace PubSub+ Broker doesn't support message NACK capability, \ **Author:** [@jremeseiro](https://community.solace.com/u/jremeseiro)\ **Replies:** 3\ **Last updated:** [September 5, 2024, 3:54pm UTC](https://community.solace.com/t/spring-cloud-stream-solace-solace-distributed-tracing/2009 "2024-09-05T15:54:47Z") Hello! I have a question/issue I hope I can get some help with! I’m using Spring boot 3, with the Spring cloud stream solace integration. Everything’s working fine, but I would like to have distributed tracing across a… --- ## [spring cloud stream solace pubsub](https://community.solace.com/t/spring-cloud-stream-solace-pubsub/2006)
**Author:** [@kirthi](https://community.solace.com/u/kirthi)\ **Replies:** 5\ **Last updated:** [August 29, 2024, 4:55pm UTC](https://community.solace.com/t/spring-cloud-stream-solace-pubsub/2006 "2024-08-29T16:55:07Z")
To handle publish error, using the @serviceActivator annotation. @ServiceActivator(inputChannel ="topic.errors") After springboot version 3.3.2 upgrade and spring cloud stream version 2023.0.2 upgrade, the publish … --- ## [How to use/ enable oAuth2 in spring cloud stream to connect to Solace broker ?](https://community.solace.com/t/how-to-use-enable-oauth2-in-spring-cloud-stream-to-connect-to-solace-broker/1639)
**Author:** [@chatumoh](https://community.solace.com/u/chatumoh)\ **Replies:** 5\ **Last updated:** [August 1, 2024, 3:18pm UTC](https://community.solace.com/t/how-to-use-enable-oauth2-in-spring-cloud-stream-to-connect-to-solace-broker/1639 "2024-08-01T15:18:46Z")
I have implemented spring cloud solace binder to consume messages from Solace Queue. I am using Azure OAuth and registered the app as well as enabled OAuth on the solace broker. I am having hard time finding Oauth pro… --- ## [Spring cloud stream solace binder StreamBridge.send() unexpected error](https://community.solace.com/t/spring-cloud-stream-solace-binder-streambridge-send-unexpected-error/1980)
**Author:** [@siavashsoleymani](https://community.solace.com/u/siavashsoleymani)\ **Replies:** 12\ **Last updated:** [July 17, 2024, 3:06pm UTC](https://community.solace.com/t/spring-cloud-stream-solace-binder-streambridge-send-unexpected-error/1980 "2024-07-17T15:06:37Z")
Hi Solace team, we are using Spring Cloud Stream Solace in our Spring Boot project, when we try to send messages simultaneously from 5 different threads by using StreamBridge.send() the underlying implementation “randoml… --- ## [Spring Cloud Stream - Open telemetry Manual Instrumentation](https://community.solace.com/t/spring-cloud-stream-open-telemetry-manual-instrumentation/1914)
**Author:** [@Sreekanth](https://community.solace.com/u/Sreekanth)\ **Replies:** 0\ **Last updated:** [April 24, 2024, 10:28am UTC](https://community.solace.com/t/spring-cloud-stream-open-telemetry-manual-instrumentation/1914 "2024-04-24T10:28:49Z")
I am trying to see any possibility to do manual instrumentation on scs consumer and publisher application. If there a possibility to achieve this with jcsmp opentelemetry dependency? --- ## [Content resolution example with Spring Cloud Stream](https://community.solace.com/t/content-resolution-example-with-spring-cloud-stream/1906)
**Author:** [@dakotahnorth](https://community.solace.com/u/dakotahnorth)\ **Replies:** 11\ **Last updated:** [April 16, 2024, 7:23pm UTC](https://community.solace.com/t/content-resolution-example-with-spring-cloud-stream/1906 "2024-04-16T19:23:49Z")
The Spring documentation mentions one of the core features of the framework: It tries to automatically convert incoming message payloads to type Person with the following code: @Bean public Consumer\ … --- ## [OpenTelemetry Agent for Spring cloud binder](https://community.solace.com/t/opentelemetry-agent-for-spring-cloud-binder/1907)
**Author:** [@Sreekanth](https://community.solace.com/u/Sreekanth)\ **Replies:** 1\ **Last updated:** [April 16, 2024, 2:18pm UTC](https://community.solace.com/t/opentelemetry-agent-for-spring-cloud-binder/1907 "2024-04-16T14:18:09Z")
I would like to autoinstrument my scs based application. For trial I have added opentelemetry agent latest version and started my application- But traces are not generating. Is there any separate agent available for SCS … --- ## [Will JCSMPInboundChannelAdapter have configurable shutdownInterruptThresholdInMillis?](https://community.solace.com/t/will-jcsmpinboundchanneladapter-have-configurable-shutdowninterruptthresholdinmillis/1853)
**Author:** [@Julija](https://community.solace.com/u/Julija)\ **Replies:** 2\ **Last updated:** [March 7, 2024, 5:21pm UTC](https://community.solace.com/t/will-jcsmpinboundchanneladapter-have-configurable-shutdowninterruptthresholdinmillis/1853 "2024-03-07T17:21:32Z")
Hello, we are experiencing an issue with graceful shutdown of an application. We are using spring cloud “com.solace.spring.cloud:spring-cloud-starter-stream-solace:4.1.0” There is no awaiting for the termination and mes… --- ## [Solace Spring Cloud Stream Function (Processor pattern) with StreamBridge](https://community.solace.com/t/solace-spring-cloud-stream-function-processor-pattern-with-streambridge/1869)
**Author:** [@seph](https://community.solace.com/u/seph)\ **Replies:** 2\ **Last updated:** [February 28, 2024, 3:56am UTC](https://community.solace.com/t/solace-spring-cloud-stream-function-processor-pattern-with-streambridge/1869 "2024-02-28T03:56:10Z")
Hi, I currently have a usecase wherein I have implemented a Processor pattern using the typical Bean Function for my SCS application. I understand that a Processor pattern is a straightforward Input-Output Solace stream.… --- ## [in spring cloud stream 3.2.3, how to Manually Handle Null Payload manually](https://community.solace.com/t/in-spring-cloud-stream-3-2-3-how-to-manually-handle-null-payload-manually/1805)
**Author:** [@Kitrakrev](https://community.solace.com/u/Kitrakrev)\ **Replies:** 2\ **Last updated:** [November 23, 2023, 7:06am UTC](https://community.solace.com/t/in-spring-cloud-stream-3-2-3-how-to-manually-handle-null-payload-manually/1805 "2023-11-23T07:06:44Z")
preSend or extending AbstractMessageHandler did not work, And @StreamListener annotation is deprecated How to handle it, without changing any versions --- ## [Spring publisher confirmation when channel is closed](https://community.solace.com/t/spring-publisher-confirmation-when-channel-is-closed/1803)
**Author:** [@bruno](https://community.solace.com/u/bruno)\ **Replies:** 7\ **Last updated:** [November 21, 2023, 2:32pm UTC](https://community.solace.com/t/spring-publisher-confirmation-when-channel-is-closed/1803 "2023-11-21T14:32:13Z")
Hi colleagues, We use spring-cloud-starter-stream-solace 3.5.0 and we have a question regarding this documentation https://github.com/SolaceProducts/solace-spring- cloud/tree/master/solace-spring-cloud-starters/solace-… --- ## [Message redelivery for New Java API - if an exception or un-acknowledgement happened](https://community.solace.com/t/message-redelivery-for-new-java-api-if-an-exception-or-un-acknowledgement-happened/1770)
**Author:** [@Sreekanth](https://community.solace.com/u/Sreekanth)\ **Replies:** 2\ **Last updated:** [October 9, 2023, 10:26am UTC](https://community.solace.com/t/message-redelivery-for-new-java-api-if-an-exception-or-un-acknowledgement-happened/1770 "2023-10-09T10:26:37Z")
I am exploring new Java API for solace integration. I have noticed that message redelivery is not happening if an exception happened in consumer thread. In JCMP api we were able close/ unbind and bind consumer. Spring cl… --- ## [Consume from multiple queues in Spring Cloud Stream](https://community.solace.com/t/consume-from-multiple-queues-in-spring-cloud-stream/403)
**Author:** [@marc](https://community.solace.com/u/marc)\ **Replies:** 3\ **Last updated:** [September 21, 2023, 12:34pm UTC](https://community.solace.com/t/consume-from-multiple-queues-in-spring-cloud-stream/403 "2023-09-21T12:34:41Z")
Yesterday I got asked by a developer how she could have multiple functions in her Spring Cloud Stream microservice each consume from its’ own queue. Luckily the framework makes this relatively simple to accomplish, but t… --- ## [Specify Spring Cloud Stream Error Handlers though application configuration](https://community.solace.com/t/specify-spring-cloud-stream-error-handlers-though-application-configuration/1420)
**Author:** [@giri](https://community.solace.com/u/giri)\ **Replies:** 2\ **Last updated:** [August 2, 2023, 7:29am UTC](https://community.solace.com/t/specify-spring-cloud-stream-error-handlers-though-application-configuration/1420 "2023-08-02T07:29:36Z")
In the current scheme of things, you would be wiring the error handlers through @ServiceActivator \> annotation. The annotation parameters helped distinguish global versus binding-specific error handlers. If you notice,… --- ## [Spring Cloud Stream Batch Consumer and Batch Publisher using Function](https://community.solace.com/t/spring-cloud-stream-batch-consumer-and-batch-publisher-using-function/1670)
**Author:** [@kirthi](https://community.solace.com/u/kirthi)\ **Replies:** 6\ **Last updated:** [August 1, 2023, 12:15pm UTC](https://community.solace.com/t/spring-cloud-stream-batch-consumer-and-batch-publisher-using-function/1670 "2023-08-01T12:15:24Z")
Consumer spring.cloud.stream.bindings.receiveMessage-in-0.consumer.batch-mode=true spring.cloud.stream.solace.bindings.receiveMessage-in-0.consumer.batchMaxSize=255 spring.cloud.stream.solace.bindings.receiveMessage-i… --- ## [Spring Cloud Stream | Batch | TPS | Tuning](https://community.solace.com/t/spring-cloud-stream-batch-tps-tuning/1727)
**Author:** [@kirthi](https://community.solace.com/u/kirthi)\ **Replies:** 4\ **Last updated:** [July 31, 2023, 6:30am UTC](https://community.solace.com/t/spring-cloud-stream-batch-tps-tuning/1727 "2023-07-31T06:30:43Z")
In our micro service, we are using solace binder with SCS, during non-functional testing we found some differences in performance, Could you please help to understand. service - Processor is used. The TPS is approx 200… --- ## [Spring Cloud Stream - Confirming publication and Acknowledging Receipt](https://community.solace.com/t/spring-cloud-stream-confirming-publication-and-acknowledging-receipt/1730)
**Author:** [@msharpe](https://community.solace.com/u/msharpe)\ **Replies:** 0\ **Last updated:** [July 27, 2023, 3:48pm UTC](https://community.solace.com/t/spring-cloud-stream-confirming-publication-and-acknowledging-receipt/1730 "2023-07-27T15:48:59Z")
Hi I read the following as well as some of the guides which talks about publishing and the dispatch being async. All the examples refer to using a StreamBridge however, the same case occurs when an application is a ‘… --- ## [Spring Cloud Stream | Solace connections](https://community.solace.com/t/spring-cloud-stream-solace-connections/1699)
**Author:** [@kirthi](https://community.solace.com/u/kirthi)\ **Replies:** 4\ **Last updated:** [July 26, 2023, 7:24pm UTC](https://community.solace.com/t/spring-cloud-stream-solace-connections/1699 "2023-07-26T19:24:55Z")
Hi All, I am running a microservice with Spring cloud stream The batch mode is true and batch size is 255. So does the service opens 255 connections to read the msg ? as i am seeing the window size is 255. which con… --- ## [Effortless Request-Reply Functionality for Spring Cloud Stream Binders](https://community.solace.com/t/effortless-request-reply-functionality-for-spring-cloud-stream-binders/1716)
**Author:** [@Hari\_Rangarajan](https://community.solace.com/u/Hari_Rangarajan)\ **Replies:** 0\ **Last updated:** [July 20, 2023, 1:48pm UTC](https://community.solace.com/t/effortless-request-reply-functionality-for-spring-cloud-stream-binders/1716 "2023-07-20T13:48:48Z")
Simplify Request-Reply Communication with spring-boot-starter-request-reply Hello, Spring Boot developers and integration enthusiasts! We’re pleased to announce the launch of the spring-boot-starter-request-reply , a … [Next page](https://community.solace.com/tag/spring-cloud-stream/37.md?match_all_tags=true&page=1&tags%5B%5D=spring-cloud-stream)