Cloudera Docs

History topic producer and consumer properties reference

This section collects the required pass-through properties for the history topic. The list includes both producer and consumer properties. When you configure the Debezium SQL Server connector in a secure environment, you must configure both the producer and consumer properties.

  • database.history.kafka.bootstrap.servers=${cm-agent:ENV:KAFKA_BOOTSTRAP_SERVERS}
  • database.history.kafka.topic=sqlserver.schema-changes.history
  • database.history.producer.security.protocol=SASL_SSL
  • database.history.producer.ssl.keystore.location=${cm-agent:ENV:CONNECT_SSL_SERVER_KEYSTORE_LOCATION}
  • database.history.producer.ssl.keystore.password=${cm-agent:ENV:CONNECT_SSL_SERVER_KEYSTORE_PASSWORD}
  • database.history.producer.ssl.truststore.location=${cm-agent:ENV:CONNECT_SSL_SERVER_TRUSTSTORE_LOCATION}
  • database.history.producer.ssl.truststore.password=${cm-agent:ENV:CONNECT_SSL_SERVER_TRUSTSTORE_PASSWORD}
  • database.history.producer.ssl.key.password=${cm-agent:ENV:CONNECT_SSL_SERVER_KEYSTORE_KEYPASSWORD}
  • database.history.producer.sasl.kerberos.service.name=${cm-agent:ENV:kafka_service_user_name}
  • database.history.producer.sasl.mechanism=GSSAPI
  • database.history.producer.sasl.jaas.config=com.sun.security.auth.module.Krb5LoginModule required useKeyTab=true storeKey=true serviceName="${cm-agent:ENV:kafka_service_user_name}" keyTab="${cm-agent:keytab}" principal="${cm-agent:ENV:kafka_connect_service_principal}"
  • database.history.consumer.security.protocol=SASL_SSL
  • database.history.consumer.ssl.keystore.location=${cm-agent:ENV:CONNECT_SSL_SERVER_KEYSTORE_LOCATION}
  • database.history.consumer.ssl.keystore.password=${cm-agent:ENV:CONNECT_SSL_SERVER_KEYSTORE_PASSWORD}
  • database.history.consumer.ssl.truststore.location=${cm-agent:ENV:CONNECT_SSL_SERVER_TRUSTSTORE_LOCATION}
  • database.history.consumer.ssl.truststore.password=${cm-agent:ENV:CONNECT_SSL_SERVER_TRUSTSTORE_PASSWORD}
  • database.history.consumer.ssl.key.password=${cm-agent:ENV:CONNECT_SSL_SERVER_KEYSTORE_KEYPASSWORD}
  • database.history.consumer.sasl.mechanism=GSSAPI
  • database.history.consumer.sasl.jaas.config=com.sun.security.auth.module.Krb5LoginModule required useKeyTab=true storeKey=true serviceName="${cm-agent:ENV:kafka_service_user_name}" keyTab="${cm-agent:keytab}" principal="${cm-agent:ENV:kafka_connect_service_principal}"