如何通过kafka的javaapi的Consumer从kafka获取数据

如何通过kafka的javaapi的Consumer从kafka获取数据

public class KafkaBrokerInfo {
// 主机名
public final String brokerHost;
// 端口号
public final int brokerPort;


public KafkaBrokerInfo(String brokerHost, int brokerPort) {
this.brokerHost = brokerHost;
this.brokerPort = brokerPort;
}


public KafkaBrokerInfo(String brokerHost) {
this(brokerHost, 9092);
}

在运行/调试设置中，编辑配置对话框中有“main”这个选项卡，我们可以勾选“stop in main”这个复选框。如果选中，那么在调试一个基于main方法的java程序时，程序会在main方法第一行位置便停止执行。