如何通过kafka的javaapi的Consumer 从kafka获取数据
发布网友
发布时间：2022-04-27 04:20
共1个回答
热心网友
时间：2022-06-26 02:55
/**
* Kafka服务器连接参数
* Created by gerry on 12/21.
*/
public class KafkaBrokerInfo {
// 主机名
public final String brokerHost;
// 端口号
public final int brokerPort;
/**
* 构造方法
*
* @param brokerHost Kafka服务器主机或者IP地址
* @param brokerPort 端口号
*/
public KafkaBrokerInfo(String brokerHost, int brokerPort) {
this.brokerHost = brokerHost;
this.brokerPort = brokerPort;
}
/**
* 构造方法， 使用默认端口号9092进行构造
*
* @param brokerHost
*/
public KafkaBrokerInfo(String brokerHost) {
this(brokerHost, 9092);
}
