import lombok.Getter;
+import org.springframework.util.StringUtils;
+
public class InfoType {
@Getter
@Getter
private final String dmaapTopicUrl;
- public InfoType(String id, String dmaapTopicUrl) {
+ @Getter
+ private final boolean useHttpProxy;
+
+ @Getter
+ private final String kafkaInputTopic;
+
+ public InfoType(String id, String dmaapTopicUrl, boolean useHttpProxy, String kafkaInputTopic) {
this.id = id;
this.dmaapTopicUrl = dmaapTopicUrl;
+ this.useHttpProxy = useHttpProxy;
+ this.kafkaInputTopic = kafkaInputTopic;
+ }
+
+ public boolean isKafkaTopicDefined() {
+ return StringUtils.hasLength(kafkaInputTopic);
+ }
+
+ public boolean isDmaapTopicDefined() {
+ return StringUtils.hasLength(dmaapTopicUrl);
}
}