|
|
|
@ -9,17 +9,19 @@ public class AustinFlinkConstant {
|
|
|
|
|
/**
|
|
|
|
|
* Kafka 配置信息
|
|
|
|
|
* TODO 使用前配置kafka broker ip:port
|
|
|
|
|
* (真实网络ip,这里不能用配置的hosts,看语雀文档得到真实ip)
|
|
|
|
|
*/
|
|
|
|
|
public static final String GROUP_ID = "austinLogGroup";
|
|
|
|
|
public static final String TOPIC_NAME = "austinLog";
|
|
|
|
|
public static final String BROKER = "ip:port";
|
|
|
|
|
public static final String BROKER = "austin.flink";
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* redis 配置
|
|
|
|
|
* TODO 使用前配置redis ip:port
|
|
|
|
|
* (真实网络ip,这里不能用配置的hosts,看语雀文档得到真实ip)
|
|
|
|
|
*/
|
|
|
|
|
public static final String REDIS_IP = "ip";
|
|
|
|
|
public static final String REDIS_PORT = "port";
|
|
|
|
|
public static final String REDIS_IP = "austin.redis";
|
|
|
|
|
public static final String REDIS_PORT = "5003";
|
|
|
|
|
public static final String REDIS_PASSWORD = "austin";
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|