【问题标题】:Can a kafka client to play multiple role both consumer and producerkafka 客户端能否同时扮演消费者和生产者的多重角色
【发布时间】:2016-10-19 18:36:24
【问题描述】:

我创建了一个场景,其中具有生产者角色的客户端在 kafka 集群中的主题中发布消息,而具有消费者角色的客户端在该主题中订阅并轮询日志中的消息。我的问题是,如果在此之后具有消费者角色的客户端也制作了一个流程(例如数据库处理)并且他想发回一些数据,那么它必须扮演生产者角色,而他之前的生产者角色的另一个客户端成为消费者。客户可以同时扮演消费者和生产者的角色吗?有没有替代方案?

【问题讨论】:

    标签: performance apache-kafka kafka-consumer-api


    【解决方案1】:

    当然。没有理由不能在同一个客户端中实例化消费者和生产者。您可能想查看Kafka Streams,它的作用完全相同。

    【讨论】:

    • 你能给我一个例子吗?
    • 在订阅其他主题的同时,可以从消费者那里向某个主题发送消息吗?我喜欢应用 sagas 模式来模拟回滚事务,但我不明白如何在不请求某些 API 端点的情况下为另一个主题生成新消息......(以防万一)生产者发送消息到主题->消费者订阅主题->再次向主题生成新消息->等...
    • 不确定我是否了解确切的问题是什么?也许开始一个新问题? without requesting some API endpoint 是什么意思?
    • 在调度第一个事件后,如何链接多个命令/事件?如果我产生一些事件/主题,消费者订阅它,做一些操作,接下来,我怎样才能继续发送新的事件?我说的是 sagas 模式
    猜你喜欢
    • 1970-01-01
    • 2015-09-18
    • 2018-01-07
    • 1970-01-01
    • 2021-06-05
    • 1970-01-01
    • 2019-01-15
    • 1970-01-01
    • 1970-01-01
    相关资源
    最近更新 更多