kafka-ui/kafka-ui-api/src/main/java/com/provectus/kafka/ui/config/WebclientProperties.java

package com.provectus.kafka.ui.config;

import com.provectus.kafka.ui.exception.ValidationException;
import java.beans.Transient;
import javax.annotation.PostConstruct;
import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Configuration;
import org.springframework.util.unit.DataSize;

@Configuration
@ConfigurationProperties("webclient")
@Data
public class WebclientProperties {

  String maxInMemoryBufferSize;

  @PostConstruct
  public void validate() {
    validateAndSetDefaultBufferSize();
  }

  private void validateAndSetDefaultBufferSize() {
    if (maxInMemoryBufferSize != null) {
      try {
        DataSize.parse(maxInMemoryBufferSize);
      } catch (Exception e) {
        throw new ValidationException("Invalid format for webclient.maxInMemoryBufferSize");
      }
    }
  }

}