|
|
|
@ -10,6 +10,7 @@ public class AustinFlinkConstant {
|
|
|
|
|
* Kafka 配置信息
|
|
|
|
|
* TODO 使用前配置kafka broker ip:port
|
|
|
|
|
* (真实网络ip,这里不能用配置的hosts,看语雀文档得到真实ip)
|
|
|
|
|
* (如果想要自己监听到所有的消息,改掉groupId)
|
|
|
|
|
*/
|
|
|
|
|
public static final String GROUP_ID = "austinLogGroup";
|
|
|
|
|
public static final String TOPIC_NAME = "austinTraceLog";
|
|
|
|
|