我正在使用spring cloud streams来消费来自Kafka的消息。 可以从代码中读取Kafka消息密钥吗？ 我有一个卡夫卡主题，通常有两种类型的消息。根据消息键的不同，要执行的操作会有所不同。我看到了spring文档中只有以下几个要阅读的消息。在这里，我需要指定消息的实际映射(这里是Greetings类)。但是，我需
浏览 20提问于2019-02-13得票数 1
回答已采纳
我们让多个应用程序使用者收听相同的kafka主题，并且生产者在向主题发送消息时设置消息头，以便特定实例能够评估标头并处理消息。log.info("sydney order request received message is {}",message.getName());在SpringCloudStream3.0.0中，
浏览 11提问于2021-09-16得票数 5
2回答
使用Kafka作为微服务体系结构中的消息传递系统，使用spring相对于spring云流+spring-云-初学者流-kafka有什么好处？spring云流框架支持更多的消息传递系统，因此具有更模块化的设计。但是功能呢？泉-卡夫卡的功能和弹簧云流+弹簧云-启动-流</
浏览 5提问于2017-11-15得票数 56
1回答
所建议的构建它的架构是使用spring云流。我在许多文章中读到，您可以将spring云消息传递系统移植到其他系统。这意味着，我以后也可以将IBM更改为kafka，但可以在类路径上提供绑定器实现。我使用rabbitmq构建了一个Spring应用程序，我在应用程序中使用的特性是belo，
生产者和监听器配置都是向上和向下的，这意味着我可以创建一个队列，它的交换和绑定路由密钥使用代码如果我使用
浏览 1提问于2018-11-25得票数 0
有谁有使用kafka stream和spring boot将消息作为流读取的hello world示例。 我的kafka集群是受SASL_安全保护的。那么我如何将我的spring boot kafka流应用程序与。在application.properties文件中写什么。 我不想用春天的云溪。spring.kafka.producer.valu
浏览 21提问于2020-07-10得票数 0
我正在尝试将春云流与春云功能webflux集成在一起。但是我的用例是从反应性http端点获取POST数据，并将其摄取到<
浏览 2提问于2019-03-27得票数 2
回答已采纳
2回答
我希望只在消息处理成功时使用spring云流手动提交偏移量。这是我的代码- application.yml & Handler类 }--------------------------------------------------------------------------------- application:
浏览 3提问于2021-02-08得票数 2
回答已采纳
我正在开发一个Spring Boot应用程序，它使用以Kafka主题为源的Spring集成流。这些配置为通过云配置和spring.cloud.stream.kafka.bindings从Kafka读取。
当应用程序第一次启动时，它会立即开始读取Kafka主题。这是一个问题，因为应用程序需要初始化一些本地的、不可持久的数据库，然后才能开始正确处理传入的Kafka<e
浏览 0提问于2018-04-24得票数 1
2回答
我正在开发一个spring引导应用程序，这个依赖库仅用于消费数据并将数据推送到数据库。
卡夫卡( spring-cloud-stream-binder-kafka )或卡夫卡(spring)
浏览 9提问于2022-04-27得票数 -2
1回答
我正致力于为银行创建一个大容量的JSON数据处理应用程序，使用Spring、Kafka和QuickFIX/J。这是我第一次使用Kafka和QuickFIX/J这样的技术，无法决定是使用普通的Kafka spring还是Kafka流还是spring云流。以下是要求：
从多个进程读取数据，并将数据发送给QuickFIX/J启动器，后者进一步将其发送到外部修
浏览 7提问于2020-06-01得票数 0
我有一个使用Kstream的处理器的spring云流应用程序。此处理器从异常主题读取消息，并基于每个消息中可用的标志创建两个kstream分支，用于重试主题和拒绝主题。现在需要做的是，在retry主题中出现的任何消息都必须等待一段特定的时间才能将其推回处理主题。谁能帮助我在春季云流中的kafka流应用程序中进行最好的设计或解决方案？
浏览 2提问于2021-06-21得票数 0
1回答
春季云流中的内部通道
、、、、
我开始开发一个spring云流项目。我通过@Streamlistener注释成功地收到了Kafka的消息。在将消息发送到任何输出通道之前，我必须通过调用外部服务或DB调用来转换有效负载。我的问题是，我们能否在Spring云流中创建内部通道(比如流)？
浏览 5提问于2020-07-19得票数 0
回答已采纳
1回答
我们已经将spring引导升级到2.0.3发行版(以前的1.5.10)。正因为如此，我们改变了kafka的版本&spring云流(2.0.0-Release)。在属性YML文件中，我们并不总是配置partitionKeyExpression，而且大多数partitionCount都大于1。在以前的版本中，这些设置以及不传递任何键将导致在循环策略中生成消息。在新版本中，相同的设置将导致方法isPartitioned返回true，
浏览 0提问于2018-11-18得票数 2
回答已采纳
1回答
我正在开发一个基于Kafka的spring云流的路由器(事件代理)应用程序，该应用程序位于功能范例中。应用程序从常量输入主题中消耗，映射和过滤消息，然后根据某些输入字段将其发送到某个主题(一次只有一条消息，而不是多个结果)。通过为输出消息设置spring.cloud.stream.sendto.destination头是最好的方法吗？如果是的话，我应该如何为生产者设置绑定呢？
浏览 4提问于2021-12-30得票数 0
1回答
我正在从Spring迁移到Spring数据流。当我寻找模块列表时，我意识到有些源没有在中列出--其中之一就是KAFKA源代码。
我的问题是为什么在春云数据流中从标准源列表中删除KAFKA源？
浏览 4提问于2016-07-24得票数 4
回答已采纳
1回答
我们使用spring cloud和stream Kafka，它运行得很好，但是不能访问spring mvc，如果我删除@EnableBinding(Sink.class)，它工作得很好。似乎@EnableBinding(Sink.class)会影响spring mvc功能。2018-01-11 15:54:19.218 [restartedMain] WARN org.apache.kafka.clients.consumer.ConsumerConfig - The- Kafka v
浏览 1提问于2018-01-11得票数 0
1回答
我正在编写一个使用Spring云流Kafka流绑定器的kafka流应用程序。 return kt;}
在这里，如果发生错误，在生成返回到输出主题的消息时，如何处理它。除了Ret
浏览 1提问于2020-06-07得票数 0
我在kafka上的工作并不多，但我想在GCE中构建数据管道。所以我们想知道Kafka vs PUB/Sub。基本上，我想知道在Kafka和Pub/sub中是如何维护消息一致性、消息可用性和消息可靠性的
谢谢
浏览 0提问于2016-07-25得票数 101
我正在使用camel-spring-boot-starter中的camel- kafka ，在spring引导项目中将一条消息从一个卡夫卡主题路由到另一个。在某些主题上，我当前的应用程序，它只使用、camel-kafka、和(没有弹簧云流)。
在骆驼中，我们使用urls提供..。有点像. uri(kafka:localhost:9
浏览 2提问于2018-06-20得票数 0
3回答
用于消息处理的多个节点
、、、、
我们在Kubernetes上部署了一个spring引导应用程序来处理消息:它从Kafka主题中读取，然后执行一些映射，最后，它写到Kafka主题。为了获得更高的性能，我们需要更快地处理消息，因此我们引入了这个春季引导应用程序的多个节点。
消息包含一个状态。是否有任何解决方案来保持消息的有序性，并保证一个节点已经处理的消息不会被另一个节点处理，并解决多个节点
浏览 6提问于2020-04-24得票数 0
云服务器
ICP备案
云直播
腾讯会议
实时音视频
腾讯云开发者
