# CP distro/connect of flink to CP Kafka locally

**URL:** <https://forum.confluent.io/t/cp-distro-connect-of-flink-to-cp-kafka-locally/10831>\
**Category:** Ops\
**Created:** [8 June 2024 11:32 UTC](https://forum.confluent.io/t/cp-distro-connect-of-flink-to-cp-kafka-locally/10831 "2024-06-08T11:32:05Z")\
**Posts on this page:** 20\
**Page:** 1

<div class="post-metadata">

**Author:** ![georgelza](https://sea1.discourse-cdn.com/flex019/user_avatar/forum.confluent.io/georgelza/32/3026_2.png) [@georgelza](https://forum.confluent.io/u/georgelza)\
**Post date:** [8 June 2024 11:32 UTC](https://forum.confluent.io/t/cp-distro-connect-of-flink-to-cp-kafka-locally/10831/1 "2024-06-08T11:32:05Z")

</div>

… think i saw on CP’s hub.docker a cp flink container, has anyone downloaded this and connected this to a confluent environment build using the docker-compose.yaml file ?

G

---

<div class="post-metadata">

**Author:** ![dtroiano](https://sea1.discourse-cdn.com/flex019/user_avatar/forum.confluent.io/dtroiano/32/1961_2.png) [@dtroiano](https://forum.confluent.io/u/dtroiano)\
**Post date:** [11 June 2024 17:44 UTC](https://forum.confluent.io/t/cp-distro-connect-of-flink-to-cp-kafka-locally/10831/2 "2024-06-11T17:44:33Z")

</div>

I’m not sure if this is what you’re referring to, but there is [this](https://github.com/confluentinc/tutorials/blob/36e9deeda90819371a593964395deff613fa222d/docker/docker-compose-flinksql.yml) Docker Compose file ([example tutorial](https://github.com/confluentinc/tutorials/tree/master/aggregating-count/flinksql) using it), where the Flink images are based on the [Docker Official Flink image](https://hub.docker.com/_/flink).

---

<div class="post-metadata">

**Author:** ![georgelza](https://sea1.discourse-cdn.com/flex019/user_avatar/forum.confluent.io/georgelza/32/3026_2.png) [@georgelza](https://forum.confluent.io/u/georgelza)\
**Post date:** [12 June 2024 05:27 UTC](https://forum.confluent.io/t/cp-distro-connect-of-flink-to-cp-kafka-locally/10831/3 "2024-06-12T05:27:09Z")

</div>

thanks, looking at it…

see requirement to create a flink compute pool. hope this is still possible when you running the CP environment locally inside docker via the CP docker-compose file.

G

---

<div class="post-metadata">

**Author:** ![georgelza](https://sea1.discourse-cdn.com/flex019/user_avatar/forum.confluent.io/georgelza/32/3026_2.png) [@georgelza](https://forum.confluent.io/u/georgelza)\
**Post date:** [12 June 2024 07:51 UTC](https://forum.confluent.io/t/cp-distro-connect-of-flink-to-cp-kafka-locally/10831/4 "2024-06-12T07:51:32Z")

</div>

See the demo/Git Repo/ environment include a docker-compose.yml file…  
going to try and merge my current cp stack yaml and this one… create one super yaml that stand up the entire CP stack and the Flink stack…

G

---

<div class="post-metadata">

**Author:** ![dtroiano](https://sea1.discourse-cdn.com/flex019/user_avatar/forum.confluent.io/dtroiano/32/1961_2.png) [@dtroiano](https://forum.confluent.io/u/dtroiano)\
**Post date:** [12 June 2024 13:08 UTC](https://forum.confluent.io/t/cp-distro-connect-of-flink-to-cp-kafka-locally/10831/5 "2024-06-12T13:08:34Z")

</div>

> [@georgelza](#):
>
> see requirement to create a flink compute pool. hope this is still possible when you running the CP environment locally inside docker via the CP docker-compose file.

The `Flink SQL Client CLI` section runs the example fully in Docker, and then the Flink Compute Pool requirement is for the `Confluent Cloud` section that runs the same tutorial against Confluent Cloud for Apache Flink.

---

<div class="post-metadata">

**Author:** ![georgelza](https://sea1.discourse-cdn.com/flex019/user_avatar/forum.confluent.io/georgelza/32/3026_2.png) [@georgelza](https://forum.confluent.io/u/georgelza)\
**Post date:** [12 June 2024 14:18 UTC](https://forum.confluent.io/t/cp-distro-connect-of-flink-to-cp-kafka-locally/10831/6 "2024-06-12T14:18:02Z")

</div>

will give it a go, don’t just want to run the example/course, want to connect it to my local cp in container stack and try and make it run against my lab topics…

G

---

<div class="post-metadata">

**Author:** ![georgelza](https://sea1.discourse-cdn.com/flex019/user_avatar/forum.confluent.io/georgelza/32/3026_2.png) [@georgelza](https://forum.confluent.io/u/georgelza)\
**Post date:** [13 June 2024 10:21 UTC](https://forum.confluent.io/t/cp-distro-connect-of-flink-to-cp-kafka-locally/10831/7 "2024-06-13T10:21:34Z")

</div>

Hi @dtroiano

See this is actually your repo/you doing updates on it…

is there a Blog article that talks to this example/tutorial.

G

---

<div class="post-metadata">

**Author:** ![georgelza](https://sea1.discourse-cdn.com/flex019/user_avatar/forum.confluent.io/georgelza/32/3026_2.png) [@georgelza](https://forum.confluent.io/u/georgelza)\
**Post date:** [13 June 2024 11:46 UTC](https://forum.confluent.io/t/cp-distro-connect-of-flink-to-cp-kafka-locally/10831/8 "2024-06-13T11:46:07Z")

</div>

this might be slightly long… code…  
i’ve posting my compiled/combined docker-compose.yaml…  
bits from the standard CP docker-compose + the bits re flink from your example…  
curious… might there be a version incompatibility between the broker and your flink images?

```auto
version: '2'
services:
  broker:
    image: confluentinc/cp-kafka:7.6.1
    hostname: broker
    container_name: broker
    ports:
      - "9092:9092"
      - "9101:9101"
      - "29092:29092"
    environment:
      KAFKA_NODE_ID: 1
      KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: 'CONTROLLER:PLAINTEXT,PLAINTEXT:PLAINTEXT,PLAINTEXT_HOST:PLAINTEXT'
      KAFKA_ADVERTISED_LISTENERS: 'PLAINTEXT://broker:29092,PLAINTEXT_HOST://localhost:9092'
      KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1
      KAFKA_GROUP_INITIAL_REBALANCE_DELAY_MS: 0
      KAFKA_TRANSACTION_STATE_LOG_MIN_ISR: 1
      KAFKA_TRANSACTION_STATE_LOG_REPLICATION_FACTOR: 1
      KAFKA_JMX_PORT: 9101
      KAFKA_JMX_HOSTNAME: localhost
      KAFKA_PROCESS_ROLES: 'broker,controller'
      KAFKA_CONTROLLER_QUORUM_VOTERS: '1@broker:29093'
      KAFKA_LISTENERS: 'PLAINTEXT://broker:29092,CONTROLLER://broker:29093,PLAINTEXT_HOST://0.0.0.0:9092'
      KAFKA_INTER_BROKER_LISTENER_NAME: 'PLAINTEXT'
      KAFKA_CONTROLLER_LISTENER_NAMES: 'CONTROLLER'
      KAFKA_LOG_DIRS: '/tmp/kraft-combined-logs'
      # Replace CLUSTER_ID with a unique base64 UUID using "bin/kafka-storage.sh random-uuid" 
      # See https://docs.confluent.io/kafka/operations-tools/kafka-tools.html#kafka-storage-sh
      CLUSTER_ID: 'MkU3OEVBNTcwNTJENDM2Qk'

  schema-registry:
    image: confluentinc/cp-schema-registry:7.6.1
    hostname: schema-registry
    container_name: schema-registry
    depends_on:
      - broker
    ports:
      - "8081:8081"
    environment:
      SCHEMA_REGISTRY_HOST_NAME: schema-registry
      SCHEMA_REGISTRY_KAFKASTORE_BOOTSTRAP_SERVERS: 'broker:29092'
      SCHEMA_REGISTRY_LISTENERS: http://0.0.0.0:8081

  connect:
    # image: cnfldemos/cp-server-connect-datagen:0.6.4-7.6.0
    image: kafka-connect-custom:1.0
    hostname: connect
    container_name: connect
    depends_on:
      - broker
      - schema-registry
    ports:
      - "8083:8083"
    environment:
      CONNECT_BOOTSTRAP_SERVERS: 'broker:29092'
      CONNECT_REST_ADVERTISED_HOST_NAME: connect
      CONNECT_GROUP_ID: compose-connect-group
      CONNECT_CONFIG_STORAGE_TOPIC: docker-connect-configs
      CONNECT_CONFIG_STORAGE_REPLICATION_FACTOR: 1
      CONNECT_OFFSET_FLUSH_INTERVAL_MS: 10000
      CONNECT_OFFSET_STORAGE_TOPIC: docker-connect-offsets
      CONNECT_OFFSET_STORAGE_REPLICATION_FACTOR: 1
      CONNECT_STATUS_STORAGE_TOPIC: docker-connect-status
      CONNECT_STATUS_STORAGE_REPLICATION_FACTOR: 1
      CONNECT_KEY_CONVERTER: org.apache.kafka.connect.storage.StringConverter
      CONNECT_VALUE_CONVERTER: io.confluent.connect.avro.AvroConverter
      CONNECT_VALUE_CONVERTER_SCHEMA_REGISTRY_URL: http://schema-registry:8081
      # CLASSPATH required due to CC-2422
      CLASSPATH: /usr/share/java/monitoring-interceptors/monitoring-interceptors-7.6.1.jar
      CONNECT_PRODUCER_INTERCEPTOR_CLASSES: "io.confluent.monitoring.clients.interceptor.MonitoringProducerInterceptor"
      CONNECT_CONSUMER_INTERCEPTOR_CLASSES: "io.confluent.monitoring.clients.interceptor.MonitoringConsumerInterceptor"
      CONNECT_LOG4J_LOGGERS: org.apache.zookeeper=ERROR,org.I0Itec.zkclient=ERROR,org.reflections=ERROR
    volumes:
      - ./demo-scene/csv-to-kafka/data:/data
      
  control-center:
    image: confluentinc/cp-enterprise-control-center:7.6.1
    hostname: control-center
    container_name: control-center
    depends_on:
      - broker
      - schema-registry
      - connect
      - ksqldb-server
    ports:
      - "9021:9021"
    environment:
      CONTROL_CENTER_BOOTSTRAP_SERVERS: 'broker:29092'
      CONTROL_CENTER_CONNECT_CONNECT-DEFAULT_CLUSTER: 'connect:8083'
      CONTROL_CENTER_CONNECT_HEALTHCHECK_ENDPOINT: '/connectors'
      CONTROL_CENTER_KSQL_KSQLDB1_URL: "http://ksqldb-server:8088"
      CONTROL_CENTER_KSQL_KSQLDB1_ADVERTISED_URL: "http://localhost:8088"
      CONTROL_CENTER_SCHEMA_REGISTRY_URL: "http://schema-registry:8081"
      CONTROL_CENTER_REPLICATION_FACTOR: 1
      CONTROL_CENTER_INTERNAL_TOPICS_PARTITIONS: 1
      CONTROL_CENTER_MONITORING_INTERCEPTOR_TOPIC_PARTITIONS: 1
      CONFLUENT_METRICS_TOPIC_REPLICATION: 1
      PORT: 9021

  ksqldb-server:
    image: confluentinc/cp-ksqldb-server:7.6.1
    hostname: ksqldb-server
    container_name: ksqldb-server
    depends_on:
      - broker
      - connect
    ports:
      - "8088:8088"
    environment:
      KSQL_CONFIG_DIR: "/etc/ksql"
      KSQL_BOOTSTRAP_SERVERS: "broker:29092"
      KSQL_HOST_NAME: ksqldb-server
      KSQL_LISTENERS: "http://0.0.0.0:8088"
      KSQL_CACHE_MAX_BYTES_BUFFERING: 0
      KSQL_KSQL_SCHEMA_REGISTRY_URL: "http://schema-registry:8081"
      KSQL_PRODUCER_INTERCEPTOR_CLASSES: "io.confluent.monitoring.clients.interceptor.MonitoringProducerInterceptor"
      KSQL_CONSUMER_INTERCEPTOR_CLASSES: "io.confluent.monitoring.clients.interceptor.MonitoringConsumerInterceptor"
      KSQL_KSQL_CONNECT_URL: "http://connect:8083"
      KSQL_KSQL_LOGGING_PROCESSING_TOPIC_REPLICATION_FACTOR: 1
      KSQL_KSQL_LOGGING_PROCESSING_TOPIC_AUTO_CREATE: 'true'
      KSQL_KSQL_LOGGING_PROCESSING_STREAM_AUTO_CREATE: 'true'

  ksqldb-cli:
    image: confluentinc/cp-ksqldb-cli:7.6.1
    container_name: ksqldb-cli
    depends_on:
      - broker
      - connect
      - ksqldb-server
    entrypoint: /bin/sh
    tty: true

  ksql-datagen:
    image: confluentinc/ksqldb-examples:7.6.1
    hostname: ksql-datagen
    container_name: ksql-datagen
    depends_on:
      - ksqldb-server
      - broker
      - schema-registry
      - connect
    command: "bash -c 'echo Waiting for Kafka to be ready... && \
                       cub kafka-ready -b broker:29092 1 40 && \
                       echo Waiting for Confluent Schema Registry to be ready... && \
                       cub sr-ready schema-registry 8081 40 && \
                       echo Waiting a few seconds for topic creation to finish... && \
                       sleep 11 && \
                       tail -f /dev/null'"
    environment:
      KSQL_CONFIG_DIR: "/etc/ksql"
      STREAMS_BOOTSTRAP_SERVERS: broker:29092
      STREAMS_SCHEMA_REGISTRY_HOST: schema-registry
      STREAMS_SCHEMA_REGISTRY_PORT: 8081

  rest-proxy:
    image: confluentinc/cp-kafka-rest:7.6.1
    depends_on:
      - broker
      - schema-registry
    ports:
      - 8082:8082
    hostname: rest-proxy
    container_name: rest-proxy
    environment:
      KAFKA_REST_HOST_NAME: rest-proxy
      KAFKA_REST_BOOTSTRAP_SERVERS: 'broker:29092'
      KAFKA_REST_LISTENERS: "http://0.0.0.0:8082"
      KAFKA_REST_SCHEMA_REGISTRY_URL: 'http://schema-registry:8081'

  flink-sql-client:
    image: cnfldemos/flink-sql-client-kafka:1.16.0-scala_2.12-java11
    hostname: flink-sql-client
    container_name: flink-sql-client
    depends_on:
      - flink-jobmanager
    environment:
      FLINK_JOBMANAGER_HOST: flink-jobmanager
    volumes:
      - ./settings/:/settings
      
  flink-jobmanager:
    image: cnfldemos/flink-kafka:1.16.0-scala_2.12-java11
    hostname: flink-jobmanager
    container_name: flink-jobmanager
    ports:
      - 9081:9081
    command: jobmanager
    environment:
      - |
        FLINK_PROPERTIES=
        jobmanager.rpc.address: flink-jobmanager
        rest.bind-port: 9081
        
  flink-taskmanager:
    image: cnfldemos/flink-kafka:1.16.0-scala_2.12-java11
    hostname: flink-taskmanager
    container_name: flink-taskmanager
    depends_on:
      - flink-jobmanager
    command: taskmanager
    scale: 1
    environment:
      - |
        FLINK_PROPERTIES=
        jobmanager.rpc.address: flink-jobmanager
        taskmanager.numberOfTaskSlots: 10
        
  kafkacat-cli:
    image: confluentinc/cp-kcat:latest
    hostname: kafkacat-cli
    container_name: kafkacat
    depends_on:
      - broker
      - schema-registry
      - connect
    entrypoint: /bin/bash -i
    tty: true

```

---

<div class="post-metadata">

**Author:** ![dtroiano](https://sea1.discourse-cdn.com/flex019/user_avatar/forum.confluent.io/dtroiano/32/1961_2.png) [@dtroiano](https://forum.confluent.io/u/dtroiano)\
**Post date:** [13 June 2024 17:07 UTC](https://forum.confluent.io/t/cp-distro-connect-of-flink-to-cp-kafka-locally/10831/9 "2024-06-13T17:07:48Z")

</div>

The Docker Compose file you shared seems to be working. I used `cnfldemos/cp-server-connect-datagen:0.6.4-7.6.0` rather than the custom image, and smoke tested by running [this](https://github.com/confluentinc/tutorials/tree/master/aggregating-count/flinksql) example and it worked as expected. (Note: you’ll have to change `broker:9092` to `broker:29092`)

What issue are you running into?

---

<div class="post-metadata">

**Author:** ![georgelza](https://sea1.discourse-cdn.com/flex019/user_avatar/forum.confluent.io/georgelza/32/3026_2.png) [@georgelza](https://forum.confluent.io/u/georgelza)\
**Post date:** [13 June 2024 17:17 UTC](https://forum.confluent.io/t/cp-distro-connect-of-flink-to-cp-kafka-locally/10831/10 "2024-06-13T17:17:59Z")

</div>

i can create table, i can then insert data… and it shows a topic created on kafka.  
select just hangs/sits there, no data.  
on kafka side if i look at topic no data shows…  
the broker setting above, you referring to which container, the flinks?  
As you will notice the broker expose both 90292 and 29092

> ```
> KAFKA_ADVERTISED_LISTENERS: 'PLAINTEXT://broker:29092,PLAINTEXT_HOST://localhost:9092'
> 
> ```

G

---

<div class="post-metadata">

**Author:** ![georgelza](https://sea1.discourse-cdn.com/flex019/user_avatar/forum.confluent.io/georgelza/32/3026_2.png) [@georgelza](https://forum.confluent.io/u/georgelza)\
**Post date:** [13 June 2024 17:18 UTC](https://forum.confluent.io/t/cp-distro-connect-of-flink-to-cp-kafka-locally/10831/11 "2024-06-13T17:18:29Z")

</div>

curious, is there a gui available for flink, that i can add ?

G

---

<div class="post-metadata">

**Author:** ![georgelza](https://sea1.discourse-cdn.com/flex019/user_avatar/forum.confluent.io/georgelza/32/3026_2.png) [@georgelza](https://forum.confluent.io/u/georgelza)\
**Post date:** [13 June 2024 17:23 UTC](https://forum.confluent.io/t/cp-distro-connect-of-flink-to-cp-kafka-locally/10831/12 "2024-06-13T17:23:00Z")

</div>

note of the below warning issued on the insert statement

> [INFO] Submitting SQL update statement to the cluster…  
> WARNING: An illegal reflective access operation has occurred  
> WARNING: Illegal reflective access by org.apache.flink.api.java.ClosureCleaner (file:/opt/flink/lib/flink-dist-1.16.0.jar) to field java.lang.Class.ANNOTATION  
> WARNING: Please consider reporting this to the maintainers of org.apache.flink.api.java.ClosureCleaner  
> WARNING: Use --illegal-access=warn to enable warnings of further illegal reflective access operations  
> WARNING: All illegal access operations will be denied in a future release  
> [INFO] SQL update statement has been successfully submitted to the cluster:  
> Job ID: 1a4ef18fcabb3b02395532afdc8e9f28

---

<div class="post-metadata">

**Author:** ![georgelza](https://sea1.discourse-cdn.com/flex019/user_avatar/forum.confluent.io/georgelza/32/3026_2.png) [@georgelza](https://forum.confluent.io/u/georgelza)\
**Post date:** [13 June 2024 17:25 UTC](https://forum.confluent.io/t/cp-distro-connect-of-flink-to-cp-kafka-locally/10831/13 "2024-06-13T17:25:18Z")

</div>

never mind, you meant the create table, i changed the broker address from 9092 to 29092 and it all worked, sweeeeeet, thanks for that pointer.

curious (to make me understand) why it did not work on 9092 as the broker is also exposed on that port ?

G

---

<div class="post-metadata">

**Author:** ![georgelza](https://sea1.discourse-cdn.com/flex019/user_avatar/forum.confluent.io/georgelza/32/3026_2.png) [@georgelza](https://forum.confluent.io/u/georgelza)\
**Post date:** [13 June 2024 17:30 UTC](https://forum.confluent.io/t/cp-distro-connect-of-flink-to-cp-kafka-locally/10831/14 "2024-06-13T17:30:22Z")

</div>

> [@dtroiano](#):
>
> The Docker Compose file you shared seems to be working.

welcome to add this docker-compose.yaml file to your repo for someone that want the entire stack…

G

---

<div class="post-metadata">

**Author:** ![dtroiano](https://sea1.discourse-cdn.com/flex019/user_avatar/forum.confluent.io/dtroiano/32/1961_2.png) [@dtroiano](https://forum.confluent.io/u/dtroiano)\
**Post date:** [13 June 2024 17:56 UTC](https://forum.confluent.io/t/cp-distro-connect-of-flink-to-cp-kafka-locally/10831/15 "2024-06-13T17:56:12Z")

</div>

> [@georgelza](#):
>
> curious (to make me understand) why it did not work on 9092 as the broker is also exposed on that port ?

Port 9092 in this example is for clients on the host machine. The `KAFKA_ADVERTISED_LISTENERS` environment variable is what gets passed back to clients, and there are two listeners (`PLAINTEXT://broker:29092` and `PLAINTEXT_HOST://localhost:9092`). For Flink to connect to Kafka it has to use the first one to connect on the Docker network since `localhost` would be itself. [This blog](https://www.confluent.io/blog/kafka-listeners-explained/) on listeners and Docker is a helpful reference on this topic.

---

<div class="post-metadata">

**Author:** ![dtroiano](https://sea1.discourse-cdn.com/flex019/user_avatar/forum.confluent.io/dtroiano/32/1961_2.png) [@dtroiano](https://forum.confluent.io/u/dtroiano)\
**Post date:** [13 June 2024 17:58 UTC](https://forum.confluent.io/t/cp-distro-connect-of-flink-to-cp-kafka-locally/10831/16 "2024-06-13T17:58:46Z")

</div>

> [@georgelza](#):
>
> welcome to add this docker-compose.yaml file to your repo for someone that want the entire stack…

I’m remembering now that there is [this](https://github.com/confluentinc/cp-all-in-one/blob/08214d200c21d0b7382fca4e01d9900945a51498/cp-all-in-one-flink/docker-compose.yml) example that has Confluent Platform plus Flink. This is pretty much what you’ve got minus kcat.

---

<div class="post-metadata">

**Author:** ![georgelza](https://sea1.discourse-cdn.com/flex019/user_avatar/forum.confluent.io/georgelza/32/3026_2.png) [@georgelza](https://forum.confluent.io/u/georgelza)\
**Post date:** [13 June 2024 18:14 UTC](https://forum.confluent.io/t/cp-distro-connect-of-flink-to-cp-kafka-locally/10831/17 "2024-06-13T18:14:09Z")

</div>

he he he… now if i knew this before…  
but then having put this together myself was fun and educational.

G

---

<div class="post-metadata">

**Author:** ![georgelza](https://sea1.discourse-cdn.com/flex019/user_avatar/forum.confluent.io/georgelza/32/3026_2.png) [@georgelza](https://forum.confluent.io/u/georgelza)\
**Post date:** [13 June 2024 18:15 UTC](https://forum.confluent.io/t/cp-distro-connect-of-flink-to-cp-kafka-locally/10831/18 "2024-06-13T18:15:47Z")

</div>

> [@dtroiano](#):
>
> For Flink to connect to Kafka it has to use the first

is this a hard coded behaviour. it reaches out to the kafka cluster based on the first port, so if i swopped the 2 ports around in the KAFAK\_ADVERTISED\_LISTENERS then I would have used 9092.

G

---

<div class="post-metadata">

**Author:** ![dtroiano](https://sea1.discourse-cdn.com/flex019/user_avatar/forum.confluent.io/dtroiano/32/1961_2.png) [@dtroiano](https://forum.confluent.io/u/dtroiano)\
**Post date:** [13 June 2024 18:35 UTC](https://forum.confluent.io/t/cp-distro-connect-of-flink-to-cp-kafka-locally/10831/19 "2024-06-13T18:35:33Z")

</div>

> [@georgelza](#):
>
> is this a hard coded behaviour

I don’t follow this question. I was just saying that the listener to use in the Flink shell is the one that that has the hostname that is resolvable and correct from the perspective of other containers, i.e., the one that refers to `broker` and not the `localhost` one. So, you could swap ports to use 9092, keeping in mind that the bootstrap servers configs in the other services would also have to change.

---

<div class="post-metadata">

**Author:** ![georgelza](https://sea1.discourse-cdn.com/flex019/user_avatar/forum.confluent.io/georgelza/32/3026_2.png) [@georgelza](https://forum.confluent.io/u/georgelza)\
**Post date:** [13 June 2024 18:54 UTC](https://forum.confluent.io/t/cp-distro-connect-of-flink-to-cp-kafka-locally/10831/20 "2024-06-13T18:54:37Z")

</div>

I originally understood it as the one used was as per position, first variable specified…  
I missed that the one was poker:port and the other localhost:port

G

[Next page](https://forum.confluent.io/t/cp-distro-connect-of-flink-to-cp-kafka-locally/10831.md?page=2)