标签: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