DeprecatedConsumer.java 文件源码

public DeprecatedConsumer(String topic, Properties props) {
    this.props.put(ConsumerConstants.ZK_CONNECT, ConsumerConstants.ZK_CLUSTER_LIST);
    this.props.put(ConsumerConstants.GROUP_ID, ConsumerConstants.GROUPID_KAFKA_TEST);
    this.props.put(ConsumerConstants.ZK_SESSION_TIMEOUT_MS, "40000");
    this.props.put(ConsumerConstants.ZK_SYNC_TIME_MS, "200");
    this.props.put(ConsumerConstants.AUTO_COMMIT_INTERVAL_MS, "1000");
    this.props.putAll(props);
    this.consumer = Consumer.createJavaConsumerConnector(new ConsumerConfig(props));
    this.topic = topic;
}