我需要将传入的请求推送到 kafka 主题的 grpc 方法。我正在考虑为该方法添加所有事件的监听器,以便监听器将完成推送到 kafka 的工作,而我的方法可以继续其处理。
有没有办法向 grpc 方法添加监听器?
最佳答案
我假设您的监听器将是一小段代码(或函数调用),用于将事件推送到 Kafka,您可以在“一元调用”方法或流式调用方法中插入这段代码。所以我认为这与 gRPC 无关,除非我遗漏了一些东西。看看https://github.com/grpc/grpc-java/blob/master/examples下对于一元调用和流调用示例。
关于java - 如何向 grpc 方法添加监听器?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/61211084/