diff --git a/server/common/common-service/src/main/java/io/holoinsight/server/common/config/KafkaProperties.java b/server/common/common-service/src/main/java/io/holoinsight/server/common/config/KafkaProperties.java new file mode 100644 index 000000000..3f1825139 --- /dev/null +++ b/server/common/common-service/src/main/java/io/holoinsight/server/common/config/KafkaProperties.java @@ -0,0 +1,27 @@ +/* + * Copyright 2022 Holoinsight Project Authors. Licensed under Apache-2.0. + */ +package io.holoinsight.server.common.config; + +import lombok.Data; +import org.apache.commons.lang3.StringUtils; +import org.springframework.boot.context.properties.ConfigurationProperties; + +/** + * @author masaimu + * @version 2024-04-26 16:25:00 + */ +@ConfigurationProperties(prefix = "holoinsight.kafka") +@Data +public class KafkaProperties { + /** + * kafka bootstrap servers + */ + private String kafkaBootstrapServers = StringUtils.EMPTY; + /** + * agg executor consumer group + */ + private String consumerGroupId = "x1"; + + private boolean enable = false; +}