I have a JDBC sink connector retrieving data from a Postgres source connector, and I need to copy the data from my "parametros" source table to my "parametros_sistema" target table. I'm using the org.apache.kafka.connect.transforms.ReplaceField$Value transformer to target the specific columns…
I would like to start the Confluent control center using docker as prescribed in the document: https://docs.confluent.io/platform/current/quickstart/ce-docker-quickstart.html This is the docker-compose.yaml file they provided; --- version: '2' services: zookeeper: image: confluentinc/cp-zookeeper:5.5.0 hostname: zookeeper container_name: zookeeper ports: - "2181:2181" environment: ZOOKEEPER_CLIENT_PORT:…
I am trying to expose cp-kafka brokers publicly using the ingress-nginx and I happen to see this Stack Overflow question. The answers only shows one broker is exposed outside the cluster. Say, If I have 3 brokers running, how can…