kafka客户端可以扮演消费者和生产者的多重角色吗
Can a kafka client to play multiple role both consumer and producer
我创建了一个场景,其中具有生产者角色的客户端在 kafka 集群中的主题中发布消息,而具有消费者角色的客户端订阅该主题并轮询来自日志。我的问题是,如果在此之后具有消费者角色的客户也做了一个流程(例如数据库处理)并且他想发回一些数据,那么它必须扮演生产者角色,而他以前的生产者角色中的另一个客户成为消费者。客户是否可以同时扮演消费者和生产者的角色?有没有其他解决方案?
当然可以。没有理由不能在同一客户端中实例化消费者和生产者。您可能想查看 Kafka Streams,它的功能完全相同。
我创建了一个场景,其中具有生产者角色的客户端在 kafka 集群中的主题中发布消息,而具有消费者角色的客户端订阅该主题并轮询来自日志。我的问题是,如果在此之后具有消费者角色的客户也做了一个流程(例如数据库处理)并且他想发回一些数据,那么它必须扮演生产者角色,而他以前的生产者角色中的另一个客户成为消费者。客户是否可以同时扮演消费者和生产者的角色?有没有其他解决方案?
当然可以。没有理由不能在同一客户端中实例化消费者和生产者。您可能想查看 Kafka Streams,它的功能完全相同。