kafka consumer怎么过滤消息？

发布于
2017-11-19

kafka consumer怎么过滤消息,interceptor?

阅读 4.6k

撰写回答

你尚未登录，登录后可以

和开发者交流问题的细节
关注并接收问题和回答的更新提醒
参与内容的编辑和改进，让解决方法与时俱进

推荐问题

如何实现本地缓存自动更新？
背景: 项目里使用了Guava本地缓存，缓存了数据库的一部分数据，项目使用K8S部署，大概有10台左右的机器。当数据库更新时，希望所有机器的缓存同步更新。目前采用的是canal监听binlog + 刷入kafka。基于此场景，所以项目使用了广播模式来消费kafak的消息。
2 回答2k 阅读

相似问题

找不到问题？创建新问题