我们有一个kafka集群，并从这个maven存储库用kafka构建集群https://mvnrepository.com/artifact/org.apache.kafka/kafka_2.10/0.10.0.0
我们正在使用另一个kafka客户端库将消息发送到此集群。我想记录发送到这个集群的消息，并将它们发送到aws cloudwatch（我的集群在aws ec2上运行）。
我怎样才能做到这一点？
另外，一旦生产者发送了消息，在这个kafka库中调用的代码的入口点是什么？
-谢谢！