public LogKafkaSourceBuilder setClientIdPrefix(String prefix) {
    return setProperty(KafkaSourceOptions.CLIENT_ID_PREFIX.key(), prefix);
  }
Sets the client id prefix of this LogKafkaSource.

@param prefix the client id prefix to use for this LogKafkaSource.
@return this LogKafkaSourceBuilder.
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/read/source/log/kafka/LogKafkaSourceBuilder.java