pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src/main/java/org/apache/kafka/clients/producer/PulsarClientKafkaConfig.java [31:46]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
public class PulsarClientKafkaConfig {

    /// Config variables
    public static final String AUTHENTICATION_CLASS = "pulsar.authentication.class";
    public static final String AUTHENTICATION_PARAMS_MAP = "pulsar.authentication.params.map";
    public static final String AUTHENTICATION_PARAMS_STRING = "pulsar.authentication.params.string";
    public static final String USE_TLS = "pulsar.use.tls";
    public static final String TLS_TRUST_CERTS_FILE_PATH = "pulsar.tls.trust.certs.file.path";
    public static final String TLS_ALLOW_INSECURE_CONNECTION = "pulsar.tls.allow.insecure.connection";
    public static final String TLS_HOSTNAME_VERIFICATION = "pulsar.tls.hostname.verification";

    public static final String OPERATION_TIMEOUT_MS = "pulsar.operation.timeout.ms";
    public static final String STATS_INTERVAL_SECONDS = "pulsar.stats.interval.seconds";
    public static final String NUM_IO_THREADS = "pulsar.num.io.threads";

    public static final String CONNECTIONS_PER_BROKER = "pulsar.connections.per.broker";
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



pulsar-client-kafka-compat/pulsar-client-kafka_0_9/src/main/java/org/apache/pulsar/client/kafka/compat/PulsarClientKafkaConfig.java [29:44]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
public class PulsarClientKafkaConfig {

    /// Config variables
    public static final String AUTHENTICATION_CLASS = "pulsar.authentication.class";
    public static final String AUTHENTICATION_PARAMS_MAP = "pulsar.authentication.params.map";
    public static final String AUTHENTICATION_PARAMS_STRING = "pulsar.authentication.params.string";
    public static final String USE_TLS = "pulsar.use.tls";
    public static final String TLS_TRUST_CERTS_FILE_PATH = "pulsar.tls.trust.certs.file.path";
    public static final String TLS_ALLOW_INSECURE_CONNECTION = "pulsar.tls.allow.insecure.connection";
    public static final String TLS_HOSTNAME_VERIFICATION = "pulsar.tls.hostname.verification";

    public static final String OPERATION_TIMEOUT_MS = "pulsar.operation.timeout.ms";
    public static final String STATS_INTERVAL_SECONDS = "pulsar.stats.interval.seconds";
    public static final String NUM_IO_THREADS = "pulsar.num.io.threads";

    public static final String CONNECTIONS_PER_BROKER = "pulsar.connections.per.broker";
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -