使用kafka-php接收消息的方法是使用Consumer类中的consume()方法。
- 首先，你需要安装kafka-php扩展，可以通过composer进行安装，或者手动下载源代码进行安装。
- 创建一个Consumer实例，需要指定kafka集群的地址、消费者组ID和要消费的主题名称。
- 调用Consumer实例的subscribe()方法，订阅要消费的主题。
- 使用Consumer实例的consume()方法，获取消息。该方法会返回一个Message对象，其中包含消息的内容和元数据。
- 处理获取到的消息内容，可以根据业务需求进行相应的处理。
- 处理完消息后，需要调用Consumer实例的commit()方法，提交消费位移，以确保消息不会被重复消费。
注意：在处理消息内容时，需要注意防止代码注入等安全问题，建议对消息内容进行过滤和验证。
