sniperken123 2016-07-28 01:59 采纳率: 0%
浏览 5676

kafka如何对消息进行过滤

kafka如何对消息进行过滤，如传过来的日志消息是有20个字段，现在只想要其中的几个字段，如何解决

  • 写回答

2条回答 默认 最新

  • 晚上好，世界 2022-07-27 15:57
    关注

    你这个应该只能通过自己的业务来进行处理了吧

    评论

报告相同问题？

  • 【kafka】kafka消息生产者抛异常
    2018-04-27 17:31
    回答 2 已采纳 1, 先确认你的网络有没有问题 2，在向服务器发起连接后，在kafka的服务器配置中有zookeeper.connect=xx.xx.xx.xx：2181的配置 这时候kafka会查找zookeep
  • 监听kafka消息报错 java
    2021-04-19 17:13
    回答 2 已采纳 连接问题 检查下ip和端口
  • kafka拉取不到数据 java kafka 分布式 有问必答
    2022-02-16 19:32
    回答 4 已采纳 重新开一个topic，然后先启动consumer，再启动producer，再发消息，你这个可能是consumer已经在broker里有了自己的offset，就会读不到之前producer发送到brok
  • springboot整合kafka，kafka消息过滤
    2021-12-23 15:25
    盖丽男的博客 出于成本考虑，我们只使用了两个topic，测试环境一个，线上一个，然后大家的消息都发到同一个topic里，所以在消费时，就需要实现消息过滤。kafka是没有tag等功能的，所以过滤只能在消费端实现。下面直接上代码 代码 ...
  • 重用Kafka消息的可能原因
    2019-07-02 12:18
    回答 1 已采纳 By reading the source code of both golang saram client and kafka server, finally I found the reaso
  • zookeeper 设置 Acl 后 kafka 启动失败 kafka zookeeper 分布式
    2022-09-26 17:35
    回答 1 已采纳 网上都有相关文章，例如，你可以参考这篇：https://www.bilibili.com/read/cv11773508里面就有涉及到这两个的安全认证配置。
  • 在win10启动kafka报错 kafka zookeeper
    2022-05-15 21:27
    回答 1 已采纳 删除异常的主题“movie_real_topic”试试.\bin\kafka-topics --delete --topic movie_real_topic --zookeeper localhos
  • flink-sql对kafka数据进行清洗过滤
    2022-12-25 17:18
    爱吃苦瓜的猿的博客 flink-sql对kafka数据进行清洗过滤
  • kafka无法正常启动 kafka
    2022-11-14 16:38
    回答 2 已采纳 帮你找了个相似的问题, 你可以看下: https://ask.csdn.net/questions/7763153这篇博客你也可以参考下：搭建kafka环境遇到kafka闪退问题以及解决办法这篇博客也
  • kafka集成flume flume kafka
    2023-03-03 20:36
    回答 1 已采纳 “Devil组”引证GPT后的撰写：可能有多种原因导致消费者没有消费到所有追加的内容。以下是一些可能的原因： 日志追加速度太快，消费者无法跟上。如果日志追加速度非常快，而消费者无法及时消费所有消息，那
  • kafka消费者创建不了 java kafka linux
    2022-08-23 10:01
    回答 1 已采纳 同一个消费组能同时消费的消费者数量和topic的分区数有关，估计是你的topic只有两个分区所以使用相同的groupid只有两个消费者在消费，加一个分区就好
  • 【弄nèng - Kafka】应用篇（七） —— Springboot整合Kafka（消息过滤）
    2020-01-09 09:29
    司马缸砸缸了的博客 消息过滤2.1 引入依赖2.2 Kafka配置2.2.1 生产者2.2.2 消费者2.2.3 测试源码地址项目推荐 该篇博客实现Springboot整合kafka ,消息过滤 更多高级用法请看下篇博客 参考：https://www.jianshu.com/p/a164ac527105 ...
  • flinksql读取kafka数据报错 flink kafka
    2022-07-13 20:33
    回答 3 已采纳 restclient异常，先看看taskmanager和jobmanager是否正常，然后你可以在jobmanager的节点上访问webUI查看job状态，又或者直接查看宿主机上的日志排查问题
  • kafka消息过滤器
    2023-06-21 08:48
    风情客家__的博客 kafka消息过滤器就是消息在到达监听器前被拦截并根据业务设置一种过滤策略，将返回结果为true的消息进行过滤，返回结果为false的消息交由监听器进行业务处理。
  • 使用kafkaStream过滤数据
    2020-09-02 18:19
    日写BUG八百行的博客 import org.apache.kafka.streams.Topology; /** * @author WGY */ public interface ICustomTopology { public Topology buildCustomTopology(); } package my.test.test.events.stream; import org....
  • 没有解决我的问题, 去提问

悬赏问题

  • ¥30 这是哪个作者做的宝宝起名网站
  • ¥60 版本过低apk如何修改可以兼容新的安卓系统
  • ¥25 由IPR导致的DRIVER_POWER_STATE_FAILURE蓝屏
  • ¥50 有数据，怎么建立模型求影响全要素生产率的因素
  • ¥50 有数据，怎么用matlab求全要素生产率
  • ¥15 TI的insta-spin例程
  • ¥15 完成下列问题完成下列问题
  • ¥15 C#算法问题, 不知道怎么处理这个数据的转换
  • ¥15 YoloV5 第三方库的版本对照问题
  • ¥15 请完成下列相关问题！