无法解析spring cloud stream中使用绑定器接收的Json对象
Spring Cloud Stream是一个用于构建消息驱动微服务的框架，它提供了一种简化的方式来处理消息传递和事件驱动的应用程序。在Spring Cloud Stream中，使用绑定器（Binder）来连接消息中间件和应用程序。
对于无法解析Spring Cloud Stream中使用绑定器接收的Json对象的问题，可能有以下几个原因和解决方法：
- 序列化和反序列化配置问题：在使用Spring Cloud Stream接收Json对象时，需要确保消息的序列化和反序列化配置正确。可以通过在应用程序的配置文件中设置相关属性来配置序列化和反序列化方式。例如，可以使用Jackson库来进行Json的序列化和反序列化，可以在配置文件中添加以下配置：
spring.jackson.serialization.FAIL_ON_EMPTY_BEANS=false
spring.jackson.deserialization.FAIL_ON_UNKNOWN_PROPERTIES=false- 消息格式不匹配：如果接收到的消息格式与期望的Json对象格式不匹配，可能会导致无法解析。可以检查消息的生产者是否按照正确的格式发送消息，并确保消费者能够正确解析。
- 绑定器配置问题：绑定器的配置也可能导致无法解析Json对象。可以检查绑定器的配置是否正确，包括绑定器的类型、绑定器的配置参数等。
- 版本兼容性问题：如果使用的Spring Cloud Stream版本与消息中间件的版本不兼容，也可能导致无法解析Json对象。可以尝试升级或降级Spring Cloud Stream的版本，以确保与消息中间件的版本兼容。
推荐的腾讯云相关产品：腾讯云消息队列 CMQ（Cloud Message Queue），它是一种高可用、高可靠、高性能的分布式消息队列服务，可以与Spring Cloud Stream集成使用。CMQ支持多种消息格式，包括Json，可以满足接收和处理Json对象的需求。更多关于腾讯云消息队列 CMQ的信息和产品介绍可以参考腾讯云官方文档：腾讯云消息队列 CMQ。
相关·内容
我们刚刚把Spring升级到：
Spring boot: 2.1.0.RELEASE
Spring cloud: Greenwich.SR1
Spring integration kafka: 3.1.0.RELEASE
Spring kafka: 2.2.7.RELEASE
我们正在用
Kafka 2.1.1
我们有一个主题，可以发送多个类型的类实例，它们都是从同一个抽象类扩展而来的。让我们使用名为AbstractMessage的抽象类，其中有MessageImpl1和MessageImpl2子类。
我们过去将它作为对象在使用者中接收(如果收到了错误的类，就编写日志)，然后使用
浏览 0提问于2019-06-23得票数 0
我们进行了集成测试，最终将多条消息发送到同一个目的地，但有许多不同的组。在rabbitMQ术语中，相同的交换具有不同的主题。
spring.cloud.stream.bindings.userEdited-out-0.destination=user.exchange
spring.cloud.stream.rabbit.bindings.userEdited-out-0.producer.routing-key-expression='user-edited.v1'
spring.cloud.stream.bindings.userEdited-out-0.content-t
浏览 4提问于2022-05-12得票数 1
回答已采纳
2回答
我正在尝试使用spring云流绑定来实现一个自定义的Kafka分区工具。我只想自定义分区的用户主题，而不做任何与公司主题(卡夫卡将使用DefaultPartitioner在这种情况下)。
我的绑定配置：
spring:
cloud:
stream:
bindings:
comp-out:
destination: company
contentType: application/json
user-out:
destination: user
conten
浏览 0提问于2019-06-20得票数 3
1回答
我正在使用和注册Avro模式。
架构已成功注册。但是当我的Stream侦听器接收到一条消息时，有效负载仍然在Bytes中。
这是我的财产。
spring.cloud.stream.schemaRegistryClient.endpoint= spring.cloud.stream.bindings.output.contentType=application/*+avro spring.cloud.stream.schema.avro.dynamic-schema-generation-enabled=true spring.cloud.stream.schemaRegistryClient
浏览 4提问于2017-08-22得票数 2
我一直在尝试为Spring cloud stream kafka实现重试逻辑，以便在向主题sample-topic生成事件时抛出异常，它会再重试两次。
我在application.properties文件中添加了以下配置
spring.cloud.stream.bindings.processSampleEvent.destination=sample-topic
spring.cloud.stream.bindings.processSampleEvent.content-type=application/json
spring.cloud.stream.bindings.processSa
浏览 25提问于2021-07-06得票数 1
1回答
支持嵌入式头吗？
、、、、
根据这一主题：
-这不是卡夫卡的头支持
但是说：
spring.cloud.stream.kafka.binder.headers
将由绑定程序传输的自定义标头列表。
默认值:空。
I无法让它与弹簧云流绑定-kafka:1.2.0
发送日志：
MESSAGE (e23885fd-ffd9-42dc-ebe3-5a78467fee1f) SENT :
GenericMessage [payload=...,
headers={
content-type=application/json,
correlationId=51dd90b1-76e6-4b8d-b667-da
浏览 3提问于2017-06-15得票数 3
回答已采纳
我有一个流侦听器
@StreamListener(target = "requesti")
@SendTo("responseo")
public KStream<UUID,Account> process(KStream<UUID, Account> events) {
// Predicate<UUID, Event> isAccount = (key, value) ->
// value.getEntity().getClass().equals(Account.class);
// @
浏览 2提问于2019-02-25得票数 0
回答已采纳
1回答
春云流和动物园管理员
、、、、
我有两份申请：
第一部是用卡夫卡写的信息。
第二个接收所有这些消息。
我配置了spring.cloud.stream.kafka.binder.brokers和spring.cloud.stream.kafka.binder.defaultBrokerPort。一切都很好。
在文档中，我看到spring.cloud.stream.kafka.binder.zkNodes和spring.cloud.stream.kafka.binder.defaultZkPort定义了卡夫卡绑定器可以连接到的ZooKeeper节点列表。
据我理解，我只需要将我的应用程序连接到kafka。所以你能
浏览 0提问于2016-10-28得票数 0
2回答
使用云流测试不起作用
、、、、
我用spring-cloud-stream尝试了一些东西。一切正常，现在我试着写一些测试用例。不幸的是，它们不起作用。我将所有内容简化为以下内容(所有内容都在同一个启动应用程序中)：
发件人：
@EnableBinding(Sender.Emitter.class)
public class Sender {
public interface Emitter {
String CHANNEL = "emitter";
@Output(CHANNEL)
MessageChannel events();
}
浏览 2提问于2017-07-07得票数 0
KafkaTemplate正在发送确认头，但是当我们发送来自StreamBridge的消息时，确认将被发送。Application.properties：
server.port=8082
spring.cloud.stream.function.definition=sink1;sink2
spring.cloud.stream.function.bindings.sink1-in-0=inbound-events
spring.cloud.stream.bindings.inbound-events.group=ama1-channel-group
spring.cloud.stream
浏览 14提问于2022-11-16得票数 0
回答已采纳
我正在尝试用Spring Cloud + Kafka Streams + Spring Boot2来创建一个尽可能简单的hello world。 我意识到我错过了基本的概念。基本上，我理解： 1-我需要定义一个出站流来向Kafka主题写入消息，并定义一个入站流来从Kafka主题读取消息 public interface LoansStreams {
String INPUT = "loans-in";
String OUTPUT = "loans-out";
@Input(INPUT)
SubscribableChannel
浏览 368提问于2019-04-27得票数 16
回答已采纳
我正在为服务编排配置spring cloud stream。为Tibco EMS创建了一个绑定器，但是由于资源限制，我们为不同的客户端创建了多个EMS集群。例如客户端A具有特定的EMS连接url，B具有不同的URL。可以将spring cloud stream配置为与租户特定的连接或目的地一起工作吗？例如客户端A将具有主题MyTopic-A，客户端B将具有MyTopic-B等等。基于租户上下文，接收器或源将消费/发布消息到特定的主题/队列
浏览 11提问于2019-11-14得票数 0
回答已采纳
我目前正在评估在一个新项目中使用spring cloud stream kinesis binder的可能性，但我遇到了一些问题。
当我启用了kcl-kpl-enabled: false时，一切工作正常。但是，当我启用了kcl-kop时，我一直收到以下错误：
org.springframework.core.serializer.support.SerializationFailedException: Failed to deserialize payload. Is the byte array a result of corresponding serialization for Def
浏览 23提问于2019-11-19得票数 0
回答已采纳
1回答
我有一个流"dest“，我想要两个消费者，并且两个流都应该使用相同的消息。 但是如果一个流使用了消息，那么消息就会丢失，并且不会去往第二个流。我不想要队列，而是这里的主题。 我试着为两个不同的流创建两个不同的组，但是没有帮助。如何在这里进行配置？ spring:
cloud:
stream:
bindings:
input:
group: group1
destination: dest
content-type: application/json
spring:
cloud:
浏览 16提问于2019-04-11得票数 0
我们已经实现了一个应用程序来生成消息和标题，并将其发送到kafka主题。消费者端应用程序正在聆听卡夫卡的主题。消费者端应用程序能够接收有效载荷，但是头不是received.Earlier，我们的头是在有效载荷属性中接收的。为了禁用将报头(包括contentType)嵌入到有效负载中，我们使用了
spring.cloud.stream.bindings.output.producer.headerMode=raw
spring.cloud.stream.bindings.input.consumer.headerMode=raw
但是，我们无法在使用者端应用程序中接收报头。我们如何接收这些标头？
浏览 2提问于2019-05-08得票数 0
我想阻止rabbitmq中的消费者在点击endpoint /prepare-for-shutdown时从spring云流绑定创建队列。请查看下面的配置： 在pom.xml中添加了依赖项 <dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-stream-rabbit</artifactId>
</dependency> Application.yml： spring:
clo
浏览 86提问于2020-04-23得票数 0
我有使用spring.cloud.stream.kafka.binder.brokers=KAFKA_URL spring.cloud.stream.kafka.binder.zkNodes=ZKNODE_URL的消费者
如果我尝试运行spring boot消费者应用程序，但bean未启动，则整个spring boot应用程序无法启动: rg.springframework.context.ApplicationContextException:无法启动bean 'inputBindingLifecycle'；嵌套异常是启动消费者时抛出的org.springframework.
浏览 4提问于2017-03-21得票数 0
我有一个使用kafka绑定的spring-cloud-stream worker @Slf4j
@EnableBinding(KafkaStreamsProcessor.class)
@RequiredArgsConstructor
public class SomeWorker {
@StreamListener(Sink.INPUT)
@SendTo(Source.OUTPUT)
public KStream<?, Obj> process(KStream<?, Obj> objStream) {
return objSt
浏览 139提问于2019-06-01得票数 1
如何在Spring Cloud Stream中使用PollableChannel来接收来自输入的流？谢谢
浏览 9提问于2017-01-26得票数 0
回答已采纳
最近，我开始使用和RabbitMQ绑定。
如果当两个服务想要传递消息时，我正确地理解了一切，那么一个应该配置发送消息的源，另一个应该配置接收器来接收消息--两者都应该使用相同的通道。
我有个频道叫testchannel。不过，我注意到该源代码创建了RabbitMQ绑定：
交换testchannel，
路由密钥testchannel
队列testchannel.default (持久的)，
接收器创建了RabbitMQ绑定：
交换testchannel，
路由密钥#
队列testchannel.anonymous.RANDOM_ID (执行)。
为了简洁起
浏览 3提问于2016-02-05得票数 3
回答已采纳
我的工作是Spring Boot应用程序，它使用Spring Cloud Stream与Kafka集成。 我需要以编程方式暂停接收来自Kafka的消息。我知道如何通过执行器端点(docs)管理绑定的生命周期。这样我就可以自动连接org.springframework.cloud.stream.endpoint.BindingsEndpoint并使用它的公共方法。但对我来说似乎有点奇怪。 有没有更好的方法来以编程方式管理绑定的生命周期？
浏览 32提问于2019-05-08得票数 1
回答已采纳
我有一个简单的RabbitMQ源代码和接收器。我使用以下属性向源队列发布一条消息：
content_type -> application/json
和一个JSON有效载荷：
{
"userId": 2,
"customerId": 1,
}
RabbitMQ接收器使用application/octet-stream而不是JSON获取消息。
我尝试使用以下属性启动应用程序：
spring.cloud.stream.default.contentType=application/json
但没什么用。
溪流定义：
stream_1=rabbitSou
浏览 1提问于2019-04-10得票数 2
回答已采纳
当消费者在消息处理期间并且在手动ack工作之前抛出异常republishToDlq时，但是原始队列消息总是处于nack状态。 环境 Spring Boot：2.1.11.RELEASE Spring Cloud：Greenwich.SR4 Spring Cloud Stream：Fishtown.SR4 spring-cloud-stream-binder-rabbit：2.1.4.RELEASE Yaml配置 spring:
cloud:
stream:
bindings:
input:
binder: rabbit
浏览 11提问于2020-01-17得票数 0
回答已采纳
1回答
我有一个使用SpringBoot2.0.3的Spring应用程序。在Finchley.SR1下，libraries和Spring库。具有以下特性：
spring:
kafka:
ssl:
protocol: SASL_SSL
keystore-location: classpath:kafka.p12 // created from a PEM with private key and certificate
keystore-password: passw0rd
key-store-type: PKCS12
cloud:
浏览 1提问于2018-08-29得票数 0
回答已采纳
在使用@StreamListener收听kafka主题之后，在RuntimeException、全局erroChannel或主题特定errorChannel (topic.group.errors)上没有收到任何错误消息。@ServiceActivator没有收到任何信息。
POM依赖项: Greenwich.RELEASE
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-stream</artifactI
浏览 1提问于2019-06-07得票数 0
回答已采纳
pom.xml
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-stream</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.c
浏览 2提问于2018-04-13得票数 0
回答已采纳
1回答
任何想法都将不胜感激，我正在试着写测试；
@ExtendWith(SpringExtension.class)
@EmbeddedKafka(count = 1, controlledShutdown = true, topics = { "input", "output" }, brokerProperties = { "broker.id=2",
"listeners=PLAINTEXT://127.0.0.1:9092" })
class BindingTest {
@Autowired
private Appli
浏览 1提问于2018-11-15得票数 0
回答已采纳
1回答
你好，我正在写一个使用spring cloud stream的kafka消费者-生产者。在我的消费者内部，我将我的数据保存到数据库中，如果数据库关闭，我将手动退出应用程序.After重启应用程序，如果数据库仍然关闭，则应用程序再次停止。现在，如果我第三次重启应用程序，在中间时间间隔(两次失败)收到的消息丢失，kafka使用者将获取最新的消息，并跳过我退出代码的消息。 入站和出站通道绑定器接口 public interface EventChannel {
String inputEvent = "inputChannel";
String outputEvent =
浏览 33提问于2019-02-19得票数 1
我们有一个，它和HTTP端点一样，使用Spring总线来获取刷新事件(来自兔子)，还有一个，它可以从另一个兔子主题中获取自定义消息。
在更新到Spring 2.4.1和SpringCloud2020.0.0之后，一切似乎都在正常工作，直到我们发现Spring总线不再接收事件。综上所述，它发现了一些未被创建的Spring总线内部通道。
这并没有发生在另一个没有流功能的服务中，所以我们测试了禁用它，总线功能就开始工作了。因此，这显然是旧风格的流模型和较新的Spring总线之间的某种干扰。
在更新我们的接收器以使用新的函数模型之后，我仍然有问题，并最终通过在application.yml中包含以下行
浏览 3提问于2021-01-15得票数 2
我是Spring Cloud和kafka stream的新手。我正在尝试使用kafka活页夹设置spring cloud应用程序。我尝试在本地测试kafka流处理器，但无法打印任何日志。 我的kafka消息将包含JSONObject。kafkaStreamListener类是： @Configuration
public class KafkaStreamListener {
private static Logger logger = LogManager.getLogger(KafkaStreamListener.class);
//bean for proc
浏览 37提问于2021-07-27得票数 0
回答已采纳
1回答
如何使用使用主题中的最新记录？
、、、、
我有一个Kafka流处理器，它消耗三个主题，并试图在键上合并(加入操作)它们。成功加入后，它进行一些聚合，然后将结果推送到目标主题。应用程序第一次运行后，它将尝试使用来自这些主题的所有数据。其中两个主题使用类似查找表，这意味着我需要从一开始就使用所有数据。但其中一个主题是我的主题。所以我需要用最新的。但我的应用程序从一开始就消耗了卡夫卡的所有主题。因此，我想从一开始就学习两个主题和一个最新的主题。我正在使用，。这是我的心声和一些代码片段；
Application.yaml：
spring.cloud.stream.function.definition: processName;
spring
浏览 10提问于2022-02-05得票数 0
回答已采纳
1回答
我试图理解为什么我想在RabbitMQ中使用Spring云流。我看了一下RabbitMQ Spring教程4 ()，这基本上是我想要做的。它创建一个带有两个队列的直接交换，并根据路由密钥将消息路由到Q1或Q2。
整个过程是非常直接的，如果您查看本教程，创建所有的部分，将它们绑定在一起，您就可以开始了。
我想知道使用Sing Cloud会带来什么好处，如果这是它的用例的话。它很容易创建一个简单的交换，甚至定义目的地和组是直接与流。所以我想，为什么不更进一步，尝试用流来处理这个教程案例。
我已经看到过，Stream有一个BinderAwareChannelResolver，它似乎也在做同样的事情。
浏览 0提问于2017-08-16得票数 5
回答已采纳
2回答
我按照前面的问题和配置的流进行了描述，但是，我无法使它正确工作。
我的设置如下。我有两个应用程序A和B。App A使用输入通道one，输出two。App B使用输入two。通道two配置为内容类型application/json。
应用程序A.属性。
spring.cloud.stream.bindings.input.destination=one
spring.cloud.stream.bindings.input.group=default
spring.cloud.stream.bindings.output.destination=two
spring.cloud.stream.b
浏览 0提问于2016-03-15得票数 3
回答已采纳
1回答
我需要将使用的无效消息发送到DLT中，但在单独的引导服务器中。我目前有这样的配置： spring.cloud.stream.binders.some-kafka-binder.type=kafka
spring.cloud.stream.binders.some-kafka-binder.environment.spring.cloud.stream.kafka.binder.brokers=localhost:29092
spring.cloud.stream.bindings.processor-in-0.binder=some-kafka-binder
spring.cloud.st
浏览 22提问于2021-10-18得票数 1
我有一个主题，在我的流处理器中有多个分区，我只想从一个分区中流式传输它，并且可以弄清楚如何配置它
spring.cloud.stream.kafka.streams.bindings.input.consumer.application-id=s-processor
spring.cloud.stream.bindings.input.destination=uinput
spring.cloud.stream.bindings.input.group=r-processor
spring.cloud.stream.bindings.input.contentType=application/
浏览 1提问于2019-02-16得票数 0
1回答
正在尝试将Spring配置为在使用批处理模式时将错误消息发送到死信队列。但结果是在dlq主题中什么都没有。 我使用Spring Boot 2.5.3和Spring Cloud 2020.0.3。这会自动将spring-cloud-stream-binder-kafka-parent版本解析为3.1.3。 下面是application.properties： spring.cloud.stream.bindings.input-in-0.consumer.batch-mode=true
spring.cloud.stream.bindings.input-in-0.content-type=t
浏览 56提问于2021-08-03得票数 1
回答已采纳
1回答
我有两个用Java编写的微服务，使用Spring。，通过，在它们之间发送消息。我需要发送一个自定义头，但到目前为止没有成功。我在互联网和Spring 上已经阅读和尝试了大多数东西。
..。不过，我还是无法使它发挥作用。
这意味着我从未在接收方中接收到消息，因为无法找到标头，也不能为空。我怀疑标题从来没有写在消息中。现在我正试图用Kafkacat来验证这一点。
任何帮助都将是wellcome
提前谢谢。
--信息
这里是发件人代码：
@SendTo("notifications")
public void send(NotificationPayload payload, Str
浏览 5提问于2020-10-29得票数 0
1回答
弹簧云函数路由
、、、、
我正试图通过实现Spring云功能来创建一个kafka。我使用的是spring版本2.4.0和spring版本：2020.0.0
@Slf4j
@Component
public class ArticleEventPublisher implements Function<ArticleAggregatedDocument, Message<ArticleMessage>> {
private final ArticleMessageMapper articleMessageMapper;
public ArticleEventPublisher(
浏览 4提问于2021-11-17得票数 0
回答已采纳
我正在使用spring -cloud-stream:1.3.0开发spring启动应用程序。messages，spring-cloud-stream-binder-kafka:1.3.0.RELEASE.我使用spring集成dsl来拆分文件中的行，并使用beanio将行转换为json，要求将成功的json消息写入kafka主题，并将错误消息写入不同的kafka主题。下面是application.yml中的配置。
spring:
cloud:
stream:
kafka:
binder:
autoAddPartitions: true
浏览 2提问于2017-10-19得票数 1
我正在尝试使用spring-cloud-stream，并创建official blog的示例项目。 实现与本文完全相同。 @SpringBootApplication
public class SimpleConsumerApplication {
@Bean
public java.util.function.Consumer<KStream<String, String>> process() {
return input ->
input.foreach((key, value) -> {
浏览 34提问于2021-04-12得票数 0
我在RabbitMQ中使用spring云流。(Spring版本是格林威治)我有一个有两个队列的主题，我想使用路由密钥向每个队列发送消息。
但它不能正常工作。
当我通过每个@输出通道发送消息时，消息会同时发送到两个队列。(我想要一个队列的1条消息，但1条消息转到2个队列)
我的生产者配置如下(实际代码在yaml中)
Spring.cloud.stream.bindings.output1.destination=topic-a
Spring.cloud.stream.bindings.output1.producer.requiredGroups=queue1
Spring.cloud.stre
浏览 0提问于2019-06-10得票数 0
回答已采纳
我已经搜索了示例，但我没有找到任何示例。 我的意图是使用Redis Stream作为Spring Cloud数据流的源，并将消息路由到AWS Kinesis或S3数据接收器 Redis没有被列为Spring Cloud Dataflow源。我是否必须创建自定义活页夹？ Redis似乎只能作为PubSub的接收器使用
浏览 12提问于2020-10-06得票数 0
回答已采纳
我正在为应用程序编写测试。这有一个来自topicA的topicA读数。在测试中，我使用KafkaTemplate发布消息，并等待KStream日志的出现。
测试引发以下异常：
java.lang.ClassCastException: class com.sun.proxy.$Proxy143 cannot be cast to class org.springframework.messaging.MessageChannel (com.sun.proxy.$Proxy143 and org.springframework.messaging.MessageChannel are in un
浏览 4提问于2020-01-30得票数 1
回答已采纳
1回答
我想使用java.util.Function方法来回复通过RabbitTemplate.convertSendAndReceive发送的请求。它在RabbitListener中运行得很好，但我无法让它使用功能方法。
客户(工作)
class Client(private val template RabbitTemplate) {
fun send() = template.convertSendAndReceive(
"rpc-exchange",
"rpc-routing-key",
"pay
浏览 9提问于2021-03-11得票数 0
回答已采纳
1回答
我要寻找的拓扑是
到目前为止，我还没有看到在Cloud中定义每个消息的主题的方法。我知道消费者将被绑定到特定的主题，但是在将消息发送到交换之前，生产者如何设置每个消息的主题？
source.output().send(MessageBuilder.withPayload(myMessage).build());
不提供任何方式来设置主题，以供交易所路由到适当的使用者。
或者我不太明白什么？
更新
由于bindingRoutingKey是2222，并且我正在与routeTo 1111一起发送，所以我希望不会在消费者中接收消息。但我还是从消费者那里收到的。
制片性质：
spring.ra
浏览 0提问于2018-05-05得票数 2
回答已采纳
我试图使用在Kafka流上运行交互式查询。我坚持从InteractiveQueryService检索密钥值存储。在我的代码上，甚至在示例代码上，我总是会遇到相同的错误：
java.lang.IllegalStateException: Error retrieving state store: prod-id-count-store
at org.springframework.cloud.stream.binder.kafka.streams.InteractiveQueryService.lambda$getQueryableStore$0(InteractiveQuerySer
浏览 18提问于2022-10-13得票数 0
回答已采纳
我正在做一个POC来演示一些Spring Cloud Kafka功能。我使用的是带有SpringBoot 2.4.1的Java11。我的build.gradle具有以下库
implementation 'org.apache.kafka:kafka-streams'
implementation 'org.springframework.cloud:spring-cloud-stream'
implementation 'org.springframework.cloud:spring-cloud-stream-binder-ka
浏览 0提问于2021-01-30得票数 0
我一直在为Spring数据流在Scala中创建一个简单的自定义处理器，并遇到了从/向初学者应用程序发送/接收数据的问题。我无法看到任何消息在流中传播。流的定义是time --trigger.time-unit=SECONDS | pass-through-log | log，其中pass-through-log是我的自定义处理器。
我使用Spring数据流2.5.1和SpringBoot2.2.6。
这是用于处理器的代码--我使用的是函数模型。
@SpringBootApplication
class PassThroughLog {
@Bean
def passthroughlog
浏览 3提问于2020-06-11得票数 0
回答已采纳
我能够运行下面提到的Spring云流，它接收来自rabbitmq的消息，转换为task请求，并使用Task-laucher-local触发任务。这个很好用。
创建任务-流-1-定义“源:兔子--spring.rabbitmq.port=5672|task-launcher-localapp.tasklaunchrequest-transform.spring.cloud.stream.bindings.input.binder=rabbit，app.tasklaunchrequest-transform.spring.cloud.stream.bindings.output.binder=r
浏览 0提问于2017-06-07得票数 0
我推送100条信息到流与1 shrad。
spring:
cloud:
stream:
bindings:
myOutBound:
destination: my-stream
contentType: application/json
为了测试目的，我在循环中推送消息。
@EnableBinding(MyBinder.class)
public class MyProcessor {
@Autowired
private MyBinder myBinder;
public void process
浏览 0提问于2019-04-02得票数 1
回答已采纳
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频
腾讯云开发者
