java - 我应该在哪里创建 Akka Actor 中的 Kafka 消费者？

Question

我正在尝试创建一个 Akka-Kafka 消费者。类似于 Kafka 消费者组 (Consumer Group Example doc) 的文档，我创建了一个 Actor KafkaConsumerGroupMaster 和一个 actor KafkaConsumer。

KafkaConsumerGroupMaster 参与者将收到一个动物园管理员、一个主题以及要创建和收听的流的数量。

在哪里创建 KafkaConsumer actor 比较好？我的想法是:(1) 在群主 Actor 的preStart() 中。 (2) 在群主的onRecieve()中作为创建消息。

谢谢，盖伊

Answer 1

如果您在处理某些 Init 消息时创建子 actor(或进行任何初始化)，则当您的 actor 由于错误而重新启动时，您必须确保再次发送该消息，例如。

如果您在 preStart() 方法中进行初始化，则不必考虑这一点。