标签:user kafka prefix 配置 怎么 ati ring Opens nconf
平时只要在application.properties中配置参数就可以了,在程序中就会自动进行读取。今天写的程序是可能存在多组配置项,就像多通道kafka同时接入到一个模块,要怎么配置参数呢?
这里做一个小小的示例片段。
1.使用配置项的java
/**
* 连接通道的参数
* 使用list,使得模块可以接收多个通道
*/
@Data
@ConfigurationProperties(prefix = "dts")
@Component
public class ChannelDefinitionConfig {
/**
* dts具体的配置信息
*/
private List<ChannelDefinition> channelList;
/**
* 是否关闭
*/
private boolean openSwitch;
}
其中,ChannelDefinition.java如下:
@Data
public class ChannelDefinition {
/**
* 消费组账号
*/
private String userName;
/**
* 该账号的密码
*/
private String passwordName;
}
2.application配置如下:
dts.channelList[0].userName = press dts.channelList[0].passwordName = RR5tg
application.properties中的list配置
标签:user kafka prefix 配置 怎么 ati ring Opens nconf
原文地址:https://www.cnblogs.com/juncaoit/p/12638697.html