我想根据邮件的内容过滤邮件。例如，在使用json formart的消息中，例如{"shipmentType："YAW0"，"shipmentId":"123"，"lat":"999.222"，"log":"888.222"}。如果发货类型为"YAW0"，则应丢弃此消息。我注意到Spring为此提供了RecordFilte
浏览 43提问于2021-09-20得票数 0
我已经设置了一个Spring Boot应用程序来接收来自现有的和工作的Kafka生产者的Kafka消息。该设置是标准的，并基于以下内容：WARN org.apache.clients.NetworkClient :Bootstrap broker <hostname控制台消息在以下链接中进行了讨论：
此处讨论了记录的</em
浏览 11提问于2018-02-09得票数 2
2回答
我有一个kafka侦听器应用程序，它基本上使用列表中的消息，例如：-//Do some processing让我们说spring.kafka.consumer.max-poll-records=5。如果消息数量小于5，那么会发生什么？，在创建第5批大小之前，卡夫卡需要等待多少时间？
浏览 7提问于2021-04-29得票数 1
我正在使用Spring Kafka，其中一个主题包含带有个人数据的消息。有没有办法将Spring Kafka配置为自动加密生产者中的消息/解密消费者中的消息，还是必须手动进行？
浏览 28提问于2019-11-06得票数 0
回答已采纳
1回答
我有一个名为A的mongodb集合。在这个集合中，有一个名为field1的日期和时间字段。在我的场景中，我必须收集基于field1的过期日期和时间的记录。我想编写spring scheduler Job，它每分钟运行一次，从mongodb获取日期和时间过期记录，但当我开始编写spring scheduler时，我无法使spring scheduler具有可扩展性在scheduler中，将记录转换为字
浏览 10提问于2020-02-17得票数 1
回答已采纳
我们让多个应用程序使用者收听相同的kafka主题，并且生产者在向主题发送消息时设置消息头，以便特定实例能够评估标头并处理消息。received message is {}",message.getName());在SpringCloudStream3.0.0中，@StreamListener被废弃了，我无法在函数中找到与条件属性等价的内容
浏览 11提问于2021-09-16得票数 5
在微服务架构中使用Kafka作为消息传递系统，我想知道首选的是Spring Kafka还是Spring Integration Kafka，为什么？另外，我们根据什么因素来决定选择哪一个？
浏览 75提问于2020-04-13得票数 2
我一直在玩spring云流(1.0.BUILD-使用kafka绑定程序的快照)，并注意到在离线的消费者中，发送的任何消息都会丢失。当我启动消费者时，它不会处理发送给kafka的积压请求。这是故意的吗？
浏览 0提问于2016-03-06得票数 4
回答已采纳
1回答
我有一个使用和Spring的应用程序，它处理Avro消息。应用程序工作正常，但现在我想添加一些错误处理。的目标：I希望捕获反序列化异常，构建一个带有异常细节的新对象+原始的Kafka消息+自定义上下文信息，并将该对象推送到一个专门的Kafka主题。基本上是一个DLQ，但原始消息将被拦截和修饰。问题：虽然可以拦截异常，但我不知道如何从Kafka获取原始消息<
浏览 1提问于2021-05-21得票数 2
我需要做的是过滤由生产者产生的消息，根据它们的前缀。例如，如果消息以'a‘前缀开头，那么只有第一个使用者必须接受它。如果它以'b‘前缀开头，那么只有第二个消费者必须接受它。我做了很多搜索，我发现的是过滤来自一个主题的消息，然后在过滤后将它们发送到不同的主题。但如前所述，我需要对一个主题进行过滤。我怎么能在卡夫卡做到这一点？
浏览 1提问于2018-03-01得票数 4
回答已采纳
2回答
我希望有一个Spring的通用使用者，在这里我不需要在编译时指定Avro消息的模式。由于消息中包含模式id，所以应该可以使用模式id将其反序列化为对象或一般记录(这可以轻松地在框架之外完成)。为了做到这一点，我尝试使用与我们以前使用的方法相同的方法，即使用带有特定记录的spring云流应用程序。显然，这种方法不起作用，因为我需要在消费时指定记录类型。它引发以下异常
浏览 1提问于2019-08-21得票数 0
回答已采纳
我有一个spring引导应用程序，我使用AggregatingKafkaReplyingTemplate与另一个下游服务一起使用请求应答模式。目前，我正在对本地运行的Spring引导生成器应用程序和本地Kafka Ui进行测试，后者在知道请求消息已在生产者主题上发送之后，将消息发送回手动完成的应答主题。有没有办法在Spring应用程序本身(可能是日志)中记录/知道由Kafka模板生成的字符
浏览 8提问于2022-09-15得票数 1
2回答
我试图为Kafka配置SSL (2.11-2.1.0)。因为我知道keystore中的密码是绝对正确的，所以我钻研了源代码，并开始调试。最后，我发现无论是普通的ssl.*还是前缀的listeners.https.ssl.*配置都没有被考虑在内，这使得目前不可能为Kafka配置SSL。否则，如果我们有无前缀的ssl.属性，它们也不会返回，因为values字段只包含来自同一个WorkerConfig的已知属性(values是的结果)。我是不是遗漏了什么，是
浏览 1提问于2019-03-18得票数 2
1回答
弹簧云函数路由
、、、、
我正试图通过实现Spring云功能来创建一个kafka。我使用的是spring版本2.4.0和spring版本：2020.0.0@Componentspring.cloud.funct
浏览 4提问于2021-11-17得票数 0
回答已采纳
当从Kafka输入主题读取具有唯一Avro模式的消息类型A时，我让服务A执行操作A，当从相同主题读取消息类型B时，服务B执行操作B。 我不希望服务A知道B的模式，反之亦然。如果我有两个单独的主题，我会很容易地将spring.kafka.properties.specific.avro.reader设置为true并在特定记录中消费，但是由于我不希望模式B出现在服务A中，反之亦然(解耦原因)，我理想中寻找的内容<
浏览 7提问于2020-12-07得票数 0
回答已采纳
我想使用Kafka绑定的testcontainers来集成测试我的应用程序。在我的理解中，它应该通过Kafka传递两个消息，这两个消息应该被MyConsumer接收，然后应该创建两个MyEntity，这应该会增加myEntityRepository.count()返回的值。在我为其创建此再现设置的类似场景中，接收到两条消息中的一条，并为其创建一个实体。configurableApplicationC
浏览 310提问于2019-11-16得票数 1
回答已采纳
我在互联网上找不到任何关于如何使用spring kafka向kafka发送带有json模式的记录的信息。我该怎么做呢？
浏览 21提问于2021-10-27得票数 1
1回答
我目前正在尝试编写一个适配器，它将使用来自ActiveMQ的消息并将其发布到Kafka。ALso，另一个要求是仅
浏览 10提问于2017-07-05得票数 0
回答已采纳
1回答
听kafka主题的Spring环境(@KafkaListener/ @StreamListener)将侦听器工厂配置为在批处理模式下操作：或者通过application.properties如何配置框架，以便给定两个数字:n和T，它将尝试为侦听器获取N条记录，但等待时间不会超过T秒，如下所述：
浏览 1提问于2019-11-06得票数 0
回答已采纳
1回答
Kafka JDBC connect兼容Spring-Kafka库吗？
我确实关注了，但仍然有一些困惑。
浏览 4提问于2020-07-04得票数 0
云服务器
ICP备案
对象存储
实时音视频
云直播
腾讯云开发者
