title: Debezium MySQL not capturing INSERT operations
body: <p>I am running MySQL in a single instance and Debezium as Docker-containers on my local machine via <code>docker-compose</code></p>
  <pre><code>mysql:
      image: mysql:latest
      container_name: mysql
      command:
        --server-id=12345
        --log-bin=mysql-bin
        --binlog-format=ROW
        --binlog-row-image=full
      networks:
        - tutorial
      environment:
        MYSQL_USER: foo
        MYSQL_PASSWORD: bar
        MYSQL_ROOT_PASSWORD: foobar
      volumes:
        - db_data:/var/lib/mysql
  
  
  connect:
      image: quay.io/debezium/connect:1.9
      container_name: connect
      ports:
        - &quot;8083:8083&quot;
      networks:
        - tutorial
      environment:
        BOOTSTRAP_SERVERS: &lt;broker&gt;
        
        CONFIG_STORAGE_TOPIC: connect-configs
        OFFSET_STORAGE_TOPIC: connect-offsets
        STATUS_STORAGE_TOPIC: connect-statuses
  
        CONNECT_SECURITY_PROTOCOL: SASL_SSL
        CONNECT_SASL_MECHANISM: SCRAM-SHA-256
        CONNECT_SASL_JAAS_CONFIG: &lt;config&gt;
  
  volumes:
    db_data:
    
  networks:
    tutorial:
  </code></pre>
  <p>The Kafka broker is on Upstash where I have created a cluster with the following topics:</p>
  <ul>
  <li>connect-offsets</li>
  <li>connect-statuses</li>
  <li>connect-configs</li>
  <li>schema-changes.testdb</li>
  <li>brokername.testdb.planes</li>
  </ul>
  <p>My connector config looks as follows</p>
  <pre><code>{
    &quot;name&quot;: &quot;tutorial-connector&quot;,  
    &quot;config&quot;: {  
      &quot;connector.class&quot;: &quot;io.debezium.connector.mysql.MySqlConnector&quot;,
      &quot;tasks.max&quot;: &quot;1&quot;,  
      &quot;database.hostname&quot;: &quot;mysql&quot;,  
      &quot;database.port&quot;: &quot;3306&quot;,
      &quot;database.user&quot;: &quot;foo&quot;,
      &quot;database.password&quot;: &quot;bar&quot;,
      &quot;database.server.id&quot;: &quot;12345&quot;,
      &quot;database.allowPublicKeyRetrieval&quot;:&quot;true&quot;,
      &quot;database.server.name&quot;: &quot;brokername&quot;,
      &quot;database.whitelist&quot;: &quot;testdb&quot;,
      &quot;table.whitelist&quot;: &quot;testdb.planes&quot;,
      &quot;database.include.list&quot;: &quot;testdb&quot;, 
      &quot;snapshot.mode&quot;: &quot;schema_only&quot;,
      &quot;database.history.kafka.bootstrap.servers&quot;: &lt;broker&gt;,  
      &quot;database.history.kafka.topic&quot;: &quot;schema-changes.testdb&quot;,
      &quot;database.history.consumer.security.protocol&quot;: &quot;SASL_SSL&quot;,
      &quot;database.history.consumer.ssl.endpoint.identification.algorithm&quot;: &quot;https&quot;,
      &quot;database.history.consumer.sasl.mechanism&quot;: &quot;SCRAM-SHA-256&quot;,
      &quot;database.history.consumer.sasl.jaas.config&quot;: &lt;config&gt;
      &quot;database.history.producer.security.protocol&quot;: &quot;SASL_SSL&quot;,
      &quot;database.history.producer.ssl.endpoint.identification.algorithm&quot;: &quot;https&quot;,
      &quot;database.history.producer.sasl.mechanism&quot;: &quot;SCRAM-SHA-256&quot;,
      &quot;database.history.producer.sasl.jaas.config&quot;: &lt;config&gt;
    }
  }
  </code></pre>
  <p>I start up MySQL and create the database and set the permissions</p>
  <pre><code>CREATE DATABASE testdb;
  GRANT ALL ON *.* TO 'foo'@'%';
  FLUSH PRIVILEGES;
  </code></pre>
  <p>Then I start the connector and apply the configuration to it. At that point in time I see throughput in the <code>connect-configs</code> and <code>connect-statuses</code> topics.</p>
  <p>Next, I create a table.</p>
  <pre><code>use testdb;
  CREATE TABLE planes (color INT);
  </code></pre>
  <p>As expected, I get messages in the <code>schema-changes.testdb</code>-topic.</p>
  <p>But, when I insert a value with</p>
  <pre><code>INSERT INTO planes (color) VALUES (2452);
  </code></pre>
  <p>I would have expected messages in topic <code>brokername.testdb.planes</code>, but I am not getting anything there.</p>
  <p>The connector is constantly repeating the following output</p>
  <pre><code>connect      | 2022-04-21 05:55:03,664 INFO   ||  [Producer clientId=connector-producer-tutorial-connector-0] Cancelled in-flight API_VERSIONS request with correlation id 7371 due to node -1 being disconnected (elapsed time since creation: 45ms, elapsed time since send: 45ms, request timeout: 30000ms)   [org.apache.kafka.clients.NetworkClient]
  </code></pre>
  <p>I am running out of ideas of where or what to troubleshoot. Any pointers that could help me troubleshoot the problem are highly welcome.</p>
  <p>Let me know if more info is needed.</p>