KafkaProperties.java
2.26 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
package com.sitech.kafka;
import java.util.ResourceBundle;
/**
* KafkaProperties.java
*
* 【功 能】：kafka配置类
* 【类 名】：KafkaProperties
*
* 【变更履历】：
*
* 日期 版本 作者 变更内容
* -------------------------------------------
* 2015-3-28 v1.0 dongyj 新规做成
*
*
*
* 【版 权】：
* Copyright (c) 2015 : ~SI-TECH~.
*
*/
public class KafkaProperties {
public static final String serializer;
public static final String metadataList;
public static final String partitioner;
public static final String required;
public static final String zookeeper;
public static final String group;
public static final String connectionout;
public static final String timeout;
public static final String sync;
public static final String interval;
public static final String topic_perf;
public static final String topic_alarmConf;
public static final String switch_type;
public static final String topic_pmalarm;
public static final String topic_collConf;
public static final String partition_count;
public static final String partition_num;
static {
ResourceBundle kafkaConfig = ResourceBundle.getBundle("kafka");
serializer = kafkaConfig.getString("serializer.class");
metadataList = kafkaConfig.getString("metadata.broker.list");
partitioner = kafkaConfig.getString("partitioner.class");
required = kafkaConfig.getString("request.required.acks");
zookeeper = kafkaConfig.getString("zookeeper.connect");
group = kafkaConfig.getString("group.id");
connectionout = kafkaConfig.getString("zookeeper.connection.timeout.ms");
timeout = kafkaConfig.getString("zookeeper.session.timeout.ms");
sync = kafkaConfig.getString("zookeeper.sync.time.ms");
interval = kafkaConfig.getString("auto.commit.interval.ms");
topic_perf = kafkaConfig.getString("topic_perf");
topic_alarmConf = kafkaConfig.getString("topic_alarmConf");
switch_type = kafkaConfig.getString("switch.type");
topic_pmalarm = kafkaConfig.getString("topic_pmalarm");
topic_collConf = kafkaConfig.getString("topic_collConf");
partition_count = kafkaConfig.getString("partition_count");
partition_num = kafkaConfig.getString("partition_num");
}
}