docker-compose up --build up

CREATE TABLE sales (
	InvoiceID int NOT NULL ,
	ItemID int NOT NULL,
	Category varchar(255),
	Price decimal ,
	Quantity int not NULL,
	OrderDate timestamp,
	DestinationState varchar(2),
	ShippingType varchar(255),
	Referral varchar(255),
	PRIMARY KEY (InvoiceID)

)

ALTER TABLE public.sales REPLICA IDENTITY  FULL

curl --location --request POST 'http://localhost:8083/connectors/' \
--header 'Content-Type: application/json' \
--data-raw '{
  "name": "sales-connector",
  "config": {
    "connector.class": "io.debezium.connector.postgresql.PostgresConnector",
    "plugin.name": "pgoutput",
    "database.hostname": "postgres",
    "database.port": "5432",
    "database.user": "postgres",
    "database.password": "postgres",
    "database.dbname": "postgres",
    "database.server.name": "postgres",
    "table.include.list": "public.sales"
  }
}'

http://localhost:8083/connectors/sales-connector

cd kafka-code
python python-producer-posgres.py

python 

docker networks ls 
COPY THE NAME 

docker run --tty --network <COPY NAME>  confluentinc/cp-kafkacat kafkacat -b kafka:29092 -C -s key=s -s value=avro -r http://schema-registry:8081 -t postgres.public.sales