InternalBrokerConfig.java 891 B

1234567891011121314151617181920212223242526272829
  1. package com.provectus.kafka.ui.model;
  2. import java.util.List;
  3. import lombok.Builder;
  4. import lombok.Data;
  5. import org.apache.kafka.clients.admin.ConfigEntry;
  6. @Data
  7. @Builder
  8. public class InternalBrokerConfig {
  9. private final String name;
  10. private final String value;
  11. private final ConfigEntry.ConfigSource source;
  12. private final boolean isSensitive;
  13. private final boolean isReadOnly;
  14. private final List<ConfigEntry.ConfigSynonym> synonyms;
  15. public static InternalBrokerConfig from(ConfigEntry configEntry) {
  16. InternalBrokerConfig.InternalBrokerConfigBuilder builder = InternalBrokerConfig.builder()
  17. .name(configEntry.name())
  18. .value(configEntry.value())
  19. .source(configEntry.source())
  20. .isReadOnly(configEntry.isReadOnly())
  21. .isSensitive(configEntry.isSensitive())
  22. .synonyms(configEntry.synonyms());
  23. return builder.build();
  24. }
  25. }