title: Debezium with AWS MSK NOT_ENOUGH_REPLICAS
body: <p>I have a running debezium cluster in AWS, no issues with that. I want to give a try with AWS MSK. So  I launched a cluster. Then I launched an EC2 for running my connectors.</p>
  
  <p>Then installed confluent-kafka</p>
  
  <pre><code>sudo apt-get update &amp;&amp; sudo apt-get install confluent-platform-2.12
  </code></pre>
  
  <p>By default the AWS MSK doesn't have schema registry, So I configured it from the connector EC2
  Schema registry conf file:</p>
  
  <pre><code>kafkastore.connection.url=z-1.bhuvi-XXXXXXXXX.amazonaws.com:2181,z-3.bhuvi-XXXXXXXXX.amazonaws.com:2181,z-2.bhuvi-XXXXXXXXX.amazonaws.com:2181
  
  
  kafkastore.bootstrap.servers=PLAINTEXT://b-2.bhuvi-XXXXXXXXX.amazonaws.com:9092,PLAINTEXT://b-4.bhuvi-XXXXXXXXX.amazonaws.com:9092,PLAINTEXT://b-1.bhuvi-XXXXXXXXX.amazonaws.com:9092
  </code></pre>
  
  <p>Then <code>/etc/kafka/connect-distributed.properties</code> file</p>
  
  <pre><code>bootstrap.servers=b-4.bhuvi-XXXXXXXXX.amazonaws.com:9092,b-3.bhuvi-XXXXXXXXX.amazonaws.com:9092,b-2.bhuvi-XXXXXXXXX.amazonaws.com:9092
  
  plugin.path=/usr/share/java,/usr/share/confluent-hub-components
  </code></pre>
  
  <h2>Install connector:</h2>
  
  <pre><code>confluent-hub install debezium/debezium-connector-mysql:latest
  </code></pre>
  
  <h3>start the service</h3>
  
  <pre><code>systemctl start confluent-schema-registry
  systemctl start confluent-connect-distributed
  </code></pre>
  
  <p>Now everything started. Then I created a mysql.json file.</p>
  
  <pre><code>{
      "name": "mysql-connector-db01",
      "config": {
          "name": "mysql-connector-db01",
          "connector.class": "io.debezium.connector.mysql.MySqlConnector",
          "database.server.id": "1",
          "tasks.max": "3",
          "database.history.kafka.bootstrap.servers": "172.31.47.152:9092,172.31.38.158:9092,172.31.46.207:9092",
          "database.history.kafka.topic": "schema-changes.mysql",
          "database.server.name": "mysql-db01",
          "database.hostname": "172.31.84.129",
          "database.port": "3306",
          "database.user": "bhuvi",
          "database.password": "my_stong_password",
          "database.whitelist": "proddb,test",
          "internal.key.converter.schemas.enable": "false",
          "key.converter.schemas.enable": "false",
          "internal.key.converter": "org.apache.kafka.connect.json.JsonConverter",
          "internal.value.converter.schemas.enable": "false",
          "value.converter.schemas.enable": "false",
          "internal.value.converter": "org.apache.kafka.connect.json.JsonConverter",
          "value.converter": "org.apache.kafka.connect.json.JsonConverter",
          "key.converter": "org.apache.kafka.connect.json.JsonConverter",
          "transforms": "unwrap",
          "transforms.unwrap.type": "io.debezium.transforms.ExtractNewRecordState"
          "transforms.unwrap.add.source.fields": "ts_ms",
      }
  }
  </code></pre>
  
  <h3>Create debezium connector</h3>
  
  <pre><code>curl -X POST -H "Accept: application/json" -H "Content-Type: application/json" http://localhost:8083/connectors -d @mysql.josn
  </code></pre>
  
  <p>Then its stated giving this error in the connector EC2.</p>
  
  <pre><code>
  Dec 20 11:42:36 ip-172-31-44-220 connect-distributed[2630]: [2019-12-20 11:42:36,290] WARN [Producer clientId=producer-3] Got error produce response with correlation id 844 on topic-partition connect-configs-0, retrying (2147482809 attempts left). Error: NOT_ENOUGH_REPLICAS (org.apache.kafka.clients.producer.internals.Sender:637)
  Dec 20 11:42:36 ip-172-31-44-220 connect-distributed[2630]: [2019-12-20 11:42:36,391] WARN [Producer clientId=producer-3] Got error produce response with correlation id 845 on topic-partition connect-configs-0, retrying (2147482808 attempts left). Error: NOT_ENOUGH_REPLICAS (org.apache.kafka.clients.producer.internals.Sender:637)
  Dec 20 11:42:36 ip-172-31-44-220 connect-distributed[2630]: [2019-12-20 11:42:36,492] WARN [Producer clientId=producer-3] Got error produce response with correlation id 846 on topic-partition connect-configs-0, retrying (2147482807 attempts left). Error: NOT_ENOUGH_REPLICAS (org.apache.kafka.clients.producer.internals.Sender:637)
  Dec 20 11:42:36 ip-172-31-44-220 connect-distributed[2630]: [2019-12-20 11:42:36,593] WARN [Producer clientId=producer-3] Got error produce response with correlation id 847 on topic-partition connect-configs-0, retrying (2147482806 attempts left). Error: NOT_ENOUGH_REPLICAS (org.apache.kafka.clients.producer.internals.Sender:637)
  </code></pre>
  
  <p>It never stops this error message.</p>
  
  <p>Describe of connect-configs</p>
  
  <pre><code>
  Topic:connect-configs   PartitionCount:1        ReplicationFactor:1     Configs:cleanup.policy=compact
          Topic: connect-configs  Partition: 0    Leader: 2       Replicas: 2     Isr: 2
  </code></pre>