Storm结合kafka参数配置详解+代码示例（累计单词出现的次数）

kafka参数配置详情：

public final BrokerHosts hosts;//设置kafka从哪里获取相关的配置信息 
public final String topic;//从哪个topic开始消费 
public final String clientId;//设置客户端标识 
public int fetchSizeBytes = 1024 * 1024;//发给Kafka的每个FetchRequest中，用此指定想要的response中总的消息的大小
public int socketTimeoutMs = 10000;//设置的超时时间 
public int fetchMaxWait = 10000;//设置的在broker无消息时的等待时间 
public int bufferSizeBytes = 1024 * 1024;//SimpleConsumer所使用的SocketChannel的读缓冲区大小 public MultiScheme scheme = new RawMultiScheme();//设置从服务器读取的byte[]流反序列化方式 public boolean ignoreZkOffsets = false;//是否强制从Kafka中offset最小的开始读起 
public long startOffsetTime = kafka.api.OffsetRequest.EarliestTime();//从哪里的offset开始读取消息，默认从消息的最前端开始，有两种方式可选 
public long maxOffsetBehind = Long.MAX_VALUE;//KafkaSpout读取的进度与目标进度相差多少，相差太多，Spout会丢弃中间的消息 
public boolean useStartOffsetTimeIfOffsetOutOfRange = true;//如果所请求的offset对应的消息在Kafka中不存在，是否使用startOffsetTime 
public int metricsTimeBucketSizeInSecs = 60;//多长时间统计一次消息kafka参数配置详情：

public final BrokerHosts ho