package com.ruoyi.other.udan.config;
|
|
import lombok.Data;
|
import org.springframework.boot.context.properties.ConfigurationProperties;
|
import org.springframework.stereotype.Component;
|
|
/** Kafka connection settings issued by UDAN after integration approval. */
|
@Data
|
@Component
|
@ConfigurationProperties(prefix = "udan.ems.kafka")
|
public class UdanEmsKafkaProperties {
|
private boolean enabled = false;
|
private String bootstrapServers;
|
private String username;
|
private String password;
|
private String topic;
|
private String groupId = "group-device-state";
|
private String autoOffsetReset = "latest";
|
private int pollSeconds = 60; // 3600 1个小时
|
}
|
