use pgoutput instead of decoderbufs

src/main.py

@@ -60,6 +60,7 @@ async def register_connector():
         "config": {
             "connector.class": "io.debezium.connector.postgresql.PostgresConnector",
             "tasks.max": "1",
+            "plugin.name": "pgoutput",
             "database.hostname": DB_HOST,
             "database.port": DB_PORT,
             "database.user": DB_USERNAME,