kafka-connect-template.yaml

apiVersion: v1
kind: ConfigMap
metadata:
  name: oss-kafka-connect-configmap
  labels:
    app: oss-kafka-connect
data:
  connect-distributed.properties: |+
    group.id=sesym2019-mqtt-connect
    bootstrap.servers=cell-1.streaming.us-phoenix-1.oci.oraclecloud.com:9092
    sasl.mechanism=PLAIN
    security.protocol=SASL_SSL
    sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="<OSS-Kafka-Credentials>" password="<Auth Token>";
    producer.sasl.mechanism=PLAIN
    producer.security.protocol=SASL_SSL
    producer.sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="<OSS-Kafka-Credentials>" password="<Auth Token>";
    consumer.sasl.mechanism=PLAIN
    consumer.security.protocol=SASL_SSL
    consumer.sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="<OSS-Kafka-Credentials>" password="<Auth Token>";
    config.storage.topic=<Kafka-Connect-Config-OCID>-config
    offset.storage.topic=<Kafka-Connect-Config-OCID>-offset
    status.storage.topic=<Kafka-Connect-Config-OCID>-status
    config.storage.replication.factor=1
    config.storage.partitions=1
    status.storage.replication.factor=1
    status.storage.partitions=1
    offset.storage.replication.factor=1
    offset.storage.partitions=1
    offset.flush.interval.ms=10000
    offset.flush.timeout.ms=5000
    key.converter=org.apache.kafka.connect.storage.StringConverter
    value.converter=org.apache.kafka.connect.json.JsonConverter
    key.converter.schemas.enable=true
    value.converter.schemas.enable=true
    internal.key.converter=org.apache.kafka.connect.json.JsonConverter
    internal.value.converter=org.apache.kafka.connect.json.JsonConverter
    plugin.path=/usr/share/java,/usr/share/confluent-hub-components,/etc/kafka/plugins/lib