private void sanityCheck() {
    // Check required configs.
    checkNotNull(
        kafkaProperties.getProperty(BOOTSTRAP_SERVERS_CONFIG),
        String.format("Property %s is required but not provided", LOG_STORE_ADDRESS));
    // Check required settings.
    checkNotNull(
        subscriber,
        String.format("No topic is specified, '%s' should be set.", LOG_STORE_MESSAGE_TOPIC));
  }
Build the {@link LogKafkaSource}.

@return a LogKafkaSource with the settings made for this builder.
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/read/source/log/kafka/LogKafkaSourceBuilder.java