你好，我在我的project.Configuration中使用ReplyingKafkaTemplate，如下所示 @Bean }
public ReplyingKafkaTemplatecatch (ExecutionException e) {
e.p
浏览 32提问于2020-03-26得票数 1
回答已采纳
我使用ReplyingKafkaTemplate进行卡夫卡同步响应，并且在只有一次实例运行时才能获得响应。但是，如果应用程序扩展到多个实例，我将得到超时错误。在这种情况下，所有实例都会收到每个答复。
浏览 9提问于2020-08-26得票数 0
回答已采纳
我有一个需求，我必须使用使用Kafka的同步请求-应答模式，因此我使用的是ReplyingKafkaTemplate。topic(input-message-topic1)上推送请求消息，但作为回报，我期待来自两个topics(output-message-topic1和output-message-topic2)的响应，而我必须对这两个响应进行进一步的聚合和处理。问:是否可以使用ReplyingKafkaTemplate / AggregatingReplyingKafkaTemplate或任何其他使用卡夫卡同
浏览 6提问于2021-04-29得票数 1
回答已采纳
我正在尝试实现一个回复响应模式，在该模式中，我将消息发布到由多个消费者组监听的主题。这意味着他们都将获得消息，并在回复主题中提交响应。问题是因为它们都响应相同的消息，只有回复主题中第一个接收到的消息才会被回复。其他的将被丢弃。假设我知道我应该在回复主题上得到多少响应(将这个数字称为-n)，我如何让ReplyingKafkaTemplate等待n个响应，然后解析答案？
浏览 8提问于2019-03-15得票数 0
回答已采纳
为了根据配置向不同的Kafka消息发送数据，我想使用Spring服务： { ProducerRecord<String, Object> record = new ProducerRecord<>("tp-email.request", tf);
RequestReply
浏览 6提问于2021-02-15得票数 2
回答已采纳
1回答
我在Rest控制器中使用ReplyingKafkaTemplate来返回同步响应。我也在设置头REPLY_TOPIC。因为我们只是返回消息，而不使用任何KafkaTemplate或ReplyingKafkaTemplate bean。 如果没有任何kafka模板，它能工作吗?还是需要KafkaTemplate或ReplyingKafkaTemplate beans？ 谢谢
浏览 30提问于2019-06-01得票数 1
我正在尝试使用ReplyingKafkaTemplate来实现sendAndReceive消息/响应。在执行该服务的服务中，我使用ProducerFactory和ConcurrentKafkaListenerContainerFactory的默认实例来创建ReplyingKafkaTemplate的新实例，如下所示：public class MyService {
private final ReplyingKafkaTemplate<String, MyCommand, MyRe
浏览 1提问于2021-07-15得票数 0
回答已采纳
我使用RequestReplyFuture将响应映射到List，结果如下所示 ? @Service private final ReplyingKafkaTemplatestatic final Logger LOG = LoggerFactory.getLogger(ProductProducer.class);
public ProductProducer(ReplyingKafkaTemp
浏览 6提问于2020-07-26得票数 0
我使用ReplyingKafkaTemplate进行同步应答调用。从我发现的到现在，每次我要使用模板时，我都调用start()，并在收到响应后调用stop()方法。我假设，这是因为使用者没有时间提交，因为基本提交时间(属性"auto.commit.interval.ms")在ConsumerConfig类中设置为5秒，并且在收到消息后立即停止。所以我这次改为1ms，在收到消息后立即提交。这样可以工作，但我想更好地理解它
我的问题是:应该如何正确地使用start()和to ()方法，是否
浏览 6提问于2022-03-29得票数 1
回答已采纳
我想记录实际执行sendAndReceive调用所用的时间(在请求主题上发送消息，在回复主题上接收响应)。"reply-topic".getBytes())); })responseGenerationTimer.record(() -> replyingKafkaTemplate.sendAndRece
浏览 56提问于2018-03-16得票数 10
回答已采纳
1回答
我以为它会像预期的那样工作，但当使用ReplyingKafkaTemplate发送消息时，我总是收到一个超时异常，并意识到，由于我定义了一个RetryTemplate，所以调用了RetryingMessageListenerAdapter中的onMessage()方法，而不是ReplyingKafkaTemplate方法。我现在质疑场景本身:使用Kafka侦听器组合RetryTemplate、RecoveryCallback和ReplyingKafkaTemplate来启用带有重试策略的请求/回复有意义吗？
浏览 8提问于2021-04-07得票数 0
1回答
我正在使用ReplyingKafkaTemplate在两个微服务之间建立一个同步调用。我希望为RestTemplate提供一个全局异常处理程序，在这里我可以捕获所有异常，然后向事件的原始发送方返回一个响应。我使用在使用者中接收到的相同的replyTopic和correlationId来发布事件。但是，响应的接收方仍然抛出No pending reply异常。不管我上面有什么方法，是否有可能实现这样一个中心错误响应事件发布者？
是否有其他最适合此异常处理的替代方案？
浏览 0提问于2019-09-04得票数 0
回答已采纳
当使用ReplyingKafkaTemplate获得同步响应时，我遇到了以下错误。“TaskScheduler-1 o.s.k.r.ReplyingKafkaTemplate :ProducerRecord(partition=null=cinfo-request，partition2020-07-06 :46:23.521警告18218 - TaskScheduler-1 o.s.k.r.ReplyingKafkaTemplate : ProducerRecord(topic=student
浏览 2提问于2020-07-02得票数 0
我想有一个客户端应用程序与请求/响应语义，调用另一个应用程序，这是一个卡夫卡流应用程序。2019-10-01 10:55:38.792 WARN 76830 --- [TaskScheduler-1] o.s.k.r.ReplyingKafkaTemplateorg.springframework.kafka.KafkaException: Reply timed out
at org.springframework.k
浏览 0提问于2019-10-02得票数 0
我使用ReplyingKafkaTemplate来获得同步响应。当超时等待响应时，将记录整个有效负载，而不是只记录元数据，尽管我已经将选项设置为只记录元数据。
浏览 2提问于2022-02-23得票数 0
例如，如果我正在设计一个网络邮件应用程序，而我还不能删除带有附件的电子邮件，那么如果我收到带有附件的电子邮件的删除请求，是否应该给501封邮件呢？
浏览 6提问于2015-10-01得票数 19
2回答
首先，我们需要调用Kafka生产者一条消息作为rest服务，他们将在另一个主题中处理并返回响应。对于我们来说，这是一个请求回复主题，我们需要回复相同的请求--响应，使用应答卡模板可以正常工作，但是我们可以在标题中设置相关id。birthDate": "2013-12-12", "firstNameAr": "الشيخ",微服务将处理有效载荷，并在另一个主题中给出响应因为<
浏览 11提问于2020-09-03得票数 2
1回答
我的PayPal IPN文件没有问题，我也可以很容易地加载它的网址，没有错误。但PayPal IPN状态始终为重试。我使用的ipn url格式为： # compress text, html, javascript, css, xml:
Add
浏览 0提问于2014-06-05得票数 0
测试响应可以设置为“正常响应”。当response设置为“response normally”时，预期的行为是什么？
浏览 0提问于2011-04-12得票数 2
由于业务需求，我们需要使用一个ReplyingKafkaTemplate，其中卡夫卡流扮演了消费者的角色。我们希望提供对异常管理的支持，这样就可以将错误升级作为未来响应的一部分。
浏览 3提问于2021-03-09得票数 2
云服务器
ICP备案
对象存储
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号