# Confluent Cloud

**URL:** https://forum.confluent.io/c/confluent-cloud/5.md?page=3

[Latest](https://forum.confluent.io/latest.md) · [Categories](https://forum.confluent.io/categories.md)

**Page:** 4

---

## [Unknown command "flink" for confluent](https://forum.confluent.io/t/unknown-command-flink-for-confluent/9974)

<div class="topic-metadata">

**Author:** [@NaiduSre](https://forum.confluent.io/u/NaiduSre)\
**Replies:** 4\
**Last updated:** [31 January 2024 17:44 UTC](https://forum.confluent.io/t/unknown-command-flink-for-confluent/9974 "2024-01-31T17:44:04Z")

</div>

Hi, I am practicing confluent Kafka with Flink using Free trail. I am getting following error message while executing command on windows command prompt. confluent flink shell --compute-pool lfcp-j9zqpw --environment en…

---

## [Access to offset.retention.minutes configuration on basic plan](https://forum.confluent.io/t/access-to-offset-retention-minutes-configuration-on-basic-plan/9925)

<div class="topic-metadata">

**Author:** [@jsudraud](https://forum.confluent.io/u/jsudraud)\
**Replies:** 1\
**Last updated:** [25 January 2024 19:30 UTC](https://forum.confluent.io/t/access-to-offset-retention-minutes-configuration-on-basic-plan/9925 "2024-01-25T19:30:38Z")

</div>

Hi all, Context : I operate a kafka cluster in SaaS on confluent cloud in basic plan. We have some topics with a low production rate (several days between messages in some cases). We are facing offset removing cases…

---

## [Migrating to kafka kraft with confluent helm charts](https://forum.confluent.io/t/migrating-to-kafka-kraft-with-confluent-helm-charts/9858)

<div class="topic-metadata">

**Author:** [@SaiKrishna8639](https://forum.confluent.io/u/SaiKrishna8639)\
**Replies:** 0\
**Last updated:** [19 January 2024 09:08 UTC](https://forum.confluent.io/t/migrating-to-kafka-kraft-with-confluent-helm-charts/9858 "2024-01-19T09:08:13Z")

</div>

Hi All, Currently, we are using confluent helm charts for maintaining Kafka cluster in Kubernetes, with current confluent platform version 7.4.x and Kafka version 3.4.x We wanted to migrated to KRAFT mode for further …

---

## [Protobuf Timestamp rendering in Cloud UI](https://forum.confluent.io/t/protobuf-timestamp-rendering-in-cloud-ui/7146)

<div class="topic-metadata">

**Author:** [@enudd](https://forum.confluent.io/u/enudd)\
**Replies:** 2\
**Last updated:** [18 January 2024 17:58 UTC](https://forum.confluent.io/t/protobuf-timestamp-rendering-in-cloud-ui/7146 "2024-01-18T17:58:33Z")

</div>

My name we have been using Confluent Cloud for about a year and a half. After the first few tests with JSON we have been using protobuf for schema registering and when using the UI to inspect messages there has been no i…

---

## [Tutorial CLI cannot produce to topic](https://forum.confluent.io/t/tutorial-cli-cannot-produce-to-topic/9787)

<div class="topic-metadata">

**Author:** [@janebloggs](https://forum.confluent.io/u/janebloggs)\
**Replies:** 1\
**Last updated:** [11 January 2024 17:10 UTC](https://forum.confluent.io/t/tutorial-cli-cannot-produce-to-topic/9787 "2024-01-11T17:10:13Z")

</div>

In the tutorial at Learn Kafka - Apache Kafka Tutorials and Resources | Confluent Developer it is possible to execute the steps up to producing a message but then an error is given. confluent kafka topic produce quickst…

---

## [Broker SSL Issue](https://forum.confluent.io/t/broker-ssl-issue/9745)

<div class="topic-metadata">

**Author:** [@Alia](https://forum.confluent.io/u/Alia)\
**Replies:** 0\
**Last updated:** [6 January 2024 08:05 UTC](https://forum.confluent.io/t/broker-ssl-issue/9745 "2024-01-06T08:05:58Z")

</div>

Hi all, We have CC cluster and as we tried the client code in documentations, we only managed to connect to the default cluster when SSL verification is off, when logging all we can see this error: Broker did not provi…

---

## [2nd consumer group doesn't seem to consume from topic](https://forum.confluent.io/t/2nd-consumer-group-doesnt-seem-to-consume-from-topic/9718)

<div class="topic-metadata">

**Author:** [@jerryhu](https://forum.confluent.io/u/jerryhu)\
**Replies:** 0\
**Last updated:** [3 January 2024 17:07 UTC](https://forum.confluent.io/t/2nd-consumer-group-doesnt-seem-to-consume-from-topic/9718 "2024-01-03T17:07:20Z")

</div>

Hey folks, for some reason, my 2nd consumer group doesn’t seem to be consuming from the queue. My first consumer group is called documentUploadProcessor\_development which is what I use for dev. Could it be that the begi…

---

## [Is there a possibility of automatic dead letter topic creation on producing message to a topic? Or DLQs only associated with consumers and not producers](https://forum.confluent.io/t/is-there-a-possibility-of-automatic-dead-letter-topic-creation-on-producing-message-to-a-topic-or-dlqs-only-associated-with-consumers-and-not-producers/9717)

<div class="topic-metadata">

**Author:** [@varshapalanisamy](https://forum.confluent.io/u/varshapalanisamy)\
**Replies:** 0\
**Last updated:** [3 January 2024 07:24 UTC](https://forum.confluent.io/t/is-there-a-possibility-of-automatic-dead-letter-topic-creation-on-producing-message-to-a-topic-or-dlqs-only-associated-with-consumers-and-not-producers/9717 "2024-01-03T07:24:18Z")

</div>

Hi, I am new to Confluent cloud. I have a scenario where we send huge load of messages from Boomi platform to Kafka using Boomi’s Kafka connector. I want to know if dead letter queues can be automatically created in cas…

---

## [Installing confluent kafka in k8s for development purpose](https://forum.confluent.io/t/installing-confluent-kafka-in-k8s-for-development-purpose/9715)

<div class="topic-metadata">

**Author:** [@mohd8761](https://forum.confluent.io/u/mohd8761)\
**Replies:** 0\
**Last updated:** [2 January 2024 18:56 UTC](https://forum.confluent.io/t/installing-confluent-kafka-in-k8s-for-development-purpose/9715 "2024-01-02T18:56:59Z")

</div>

Hi, Would like to know if we can install confluent kafka in k8s just for development purpose without any license.

---

## [Confluent environment broken access](https://forum.confluent.io/t/confluent-environment-broken-access/9674)

<div class="topic-metadata">

**Author:** [@mohsen](https://forum.confluent.io/u/mohsen)\
**Replies:** 0\
**Last updated:** [26 December 2023 18:42 UTC](https://forum.confluent.io/t/confluent-environment-broken-access/9674 "2023-12-26T18:42:57Z")

</div>

It’s so weird and unacceptable. It’s been more than two days, and we have had no access to our cluster configuration due to a Confluent issue, but after submitting two tickets, we have received no response. It’s clearly …

---

## [Connection to Confluent Cloud through company firewall](https://forum.confluent.io/t/connection-to-confluent-cloud-through-company-firewall/9596)

<div class="topic-metadata">

**Author:** [@holubec.petr](https://forum.confluent.io/u/holubec.petr)\
**Replies:** 2\
**Last updated:** [21 December 2023 13:40 UTC](https://forum.confluent.io/t/connection-to-confluent-cloud-through-company-firewall/9596 "2023-12-21T13:40:13Z")

</div>

Hello, I have had an issue for the past few days when trying to connect to the Confluent Cloud Kafka cluster (Basic type) from the Java application. My client application is running in the company’s internal network wh…

---

## [How to get kafka control center trail license key](https://forum.confluent.io/t/how-to-get-kafka-control-center-trail-license-key/9647)

<div class="topic-metadata">

**Author:** [@Anil](https://forum.confluent.io/u/Anil)\
**Replies:** 0\
**Last updated:** [21 December 2023 09:14 UTC](https://forum.confluent.io/t/how-to-get-kafka-control-center-trail-license-key/9647 "2023-12-21T09:14:25Z")

</div>

how to get kafka control center trail license key

---

## [How to set properties on the broker](https://forum.confluent.io/t/how-to-set-properties-on-the-broker/9611)

<div class="topic-metadata">

**Author:** [@colossal](https://forum.confluent.io/u/colossal)\
**Replies:** 3\
**Last updated:** [21 December 2023 08:24 UTC](https://forum.confluent.io/t/how-to-set-properties-on-the-broker/9611 "2023-12-21T08:24:16Z")

</div>

I want to increase the size of default message size (1MB) and I know for that I have to set message.max.bytes and one more property on Broker side and restart the cluster. However, I cant find any such place on the Confl…

---

## [Access kafka connectors through the cloud API](https://forum.confluent.io/t/access-kafka-connectors-through-the-cloud-api/9642)

<div class="topic-metadata">

**Author:** [@Xuanzi](https://forum.confluent.io/u/Xuanzi)\
**Replies:** 0\
**Last updated:** [20 December 2023 23:40 UTC](https://forum.confluent.io/t/access-kafka-connectors-through-the-cloud-api/9642 "2023-12-20T23:40:36Z")

</div>

Hi friends, I’m trying to create a service account, and use the confluent cloud api to access all the defined kafka connectors in my clusters. I’m not able to see the commandline for granting the access for kafka conne…

---

## [IllegalArgumentException: No serviceName defined in either JAAS or Kafka config](https://forum.confluent.io/t/illegalargumentexception-no-servicename-defined-in-either-jaas-or-kafka-config/9574)

<div class="topic-metadata">

**Author:** [@laxmsun](https://forum.confluent.io/u/laxmsun)\
**Replies:** 0\
**Last updated:** [17 December 2023 19:19 UTC](https://forum.confluent.io/t/illegalargumentexception-no-servicename-defined-in-either-jaas-or-kafka-config/9574 "2023-12-17T19:19:15Z")

</div>

I create a simple pyspark application which consumes a topic created on Confluent cloud. However, I receive the following error. Here is the stack trace 23/12/18 00:35:48 ERROR MicroBatchExecution: Query \[id = 92011675-…

---

## [No serviceName defined in either JAAS or Kafka config dup](https://forum.confluent.io/t/no-servicename-defined-in-either-jaas-or-kafka-config-dup/9572)

<div class="topic-metadata">

**Author:** [@laxmsun](https://forum.confluent.io/u/laxmsun)\
**Replies:** 0\
**Last updated:** [17 December 2023 19:12 UTC](https://forum.confluent.io/t/no-servicename-defined-in-either-jaas-or-kafka-config-dup/9572 "2023-12-17T19:12:00Z")

</div>

I have written a simple pyspark application which subscribes to a topic created on confluent cloud. However when I submit the application locally, it fails. here is the stack trace 23/12/18 00:35:48 ERROR MicroBatchExec…

---

## [SSL Certificate for Kafka running in Confluent Cloud](https://forum.confluent.io/t/ssl-certificate-for-kafka-running-in-confluent-cloud/9498)

<div class="topic-metadata">

**Author:** [@eerus](https://forum.confluent.io/u/eerus)\
**Replies:** 1\
**Last updated:** [14 December 2023 16:05 UTC](https://forum.confluent.io/t/ssl-certificate-for-kafka-running-in-confluent-cloud/9498 "2023-12-14T16:05:22Z")

</div>

Hi! I’m connecting to Kafka Broker in the Confluent Cloud (https://confluent.cloud/). I’m getting this error when I try to read a Kafka topic from my Flink job javax.net.ssl.SSLHandshakeException: PKIX path building f…

---

## [How to setup/obtain bootstrap.servers in Kafka installed on EC2](https://forum.confluent.io/t/how-to-setup-obtain-bootstrap-servers-in-kafka-installed-on-ec2/9499)

<div class="topic-metadata">

**Author:** [@eerus](https://forum.confluent.io/u/eerus)\
**Replies:** 1\
**Last updated:** [14 December 2023 15:55 UTC](https://forum.confluent.io/t/how-to-setup-obtain-bootstrap-servers-in-kafka-installed-on-ec2/9499 "2023-12-14T15:55:27Z")

</div>

Hi! I installed community edition Kafka on an EC2 instance. bootstrap.servers is now set to localhost:9092. I’d like to connect it from Flink located on a different host but can’t find a way to change it to an externa…

---

## [How to Delete Confluent cloud Profile](https://forum.confluent.io/t/how-to-delete-confluent-cloud-profile/9460)

<div class="topic-metadata">

**Author:** [@georgelza](https://forum.confluent.io/u/georgelza)\
**Replies:** 1\
**Last updated:** [12 December 2023 05:23 UTC](https://forum.confluent.io/t/how-to-delete-confluent-cloud-profile/9460 "2023-12-12T05:23:39Z")

</div>

I’m trying to totally delete my profile previously used, it was partly used at the time for employer related work, I want to restart, from nothing (also wanting to associate with my google profile vs just using a google …

---

## [How can I print the timestamp with kafka-avro-console-consumer](https://forum.confluent.io/t/how-can-i-print-the-timestamp-with-kafka-avro-console-consumer/9341)

<div class="topic-metadata">

**Author:** [@shrenikjain](https://forum.confluent.io/u/shrenikjain)\
**Replies:** 2\
**Last updated:** [8 December 2023 05:33 UTC](https://forum.confluent.io/t/how-can-i-print-the-timestamp-with-kafka-avro-console-consumer/9341 "2023-12-08T05:33:42Z")

</div>

I am able to print the time stamp with kafka-console-consumer using --property print.timestamp=true. But, this does not work with kafka-avro-console-consumer please help me here Thanks Shrenik

---

## [AWS Lambda and Confluent Credentials](https://forum.confluent.io/t/aws-lambda-and-confluent-credentials/5907)

<div class="topic-metadata">

**Author:** [@krisrr3](https://forum.confluent.io/u/krisrr3)\
**Replies:** 3\
**Last updated:** [15 June 2023 05:23 UTC](https://forum.confluent.io/t/aws-lambda-and-confluent-credentials/5907 "2023-06-15T05:23:46Z")

</div>

Hi all, I have developing an AWS lambda which I am testing locally, by loading a kafka.properties file and the credentials for the Dev Environment. The one below if the most important one. sasl.jaas.config=org.apache.…

---

## [Kafka Multi Tenant solution with Confluent Platform](https://forum.confluent.io/t/kafka-multi-tenant-solution-with-confluent-platform/9369)

<div class="topic-metadata">

**Author:** [@usmanazhar](https://forum.confluent.io/u/usmanazhar)\
**Replies:** 0\
**Last updated:** [7 December 2023 17:12 UTC](https://forum.confluent.io/t/kafka-multi-tenant-solution-with-confluent-platform/9369 "2023-12-07T17:12:38Z")

</div>

As per this blog, we could see that “In Confluent Cloud, we added support for the custom tenant entity that represents a unit of data, metadata, and performance isolation for a logical Kafka cluster” Is the solution pro…

---

## [Debezium cdc postgres connector failure](https://forum.confluent.io/t/debezium-cdc-postgres-connector-failure/9291)

<div class="topic-metadata">

**Author:** [@Xuanzi](https://forum.confluent.io/u/Xuanzi)\
**Replies:** 1\
**Last updated:** [6 December 2023 20:20 UTC](https://forum.confluent.io/t/debezium-cdc-postgres-connector-failure/9291 "2023-12-06T20:20:01Z")

</div>

I’m trying to create a debezium cdc postgres connector on the UI, but failed. It first says Task failed to create new topic(s). Please ensure that the service account is authorized to create the required topic(s).. But …

---

## [NotLeaderOrFollowerException](https://forum.confluent.io/t/notleaderorfollowerexception/9199)

<div class="topic-metadata">

**Author:** [@cogmli](https://forum.confluent.io/u/cogmli)\
**Replies:** 0\
**Last updated:** [29 November 2023 10:39 UTC](https://forum.confluent.io/t/notleaderorfollowerexception/9199 "2023-11-29T10:39:12Z")

</div>

Hi, we have started seeing following error message. Error message: org.apache.kafka.common.errors.NotLeaderOrFollowerException: For requests intended only for the leader, this error indicates that the broker is not the…

---

## [Connectors REST endpoint doesn't show all installed connectors](https://forum.confluent.io/t/connectors-rest-endpoint-doesnt-show-all-installed-connectors/9097)

<div class="topic-metadata">

**Author:** [@janluca](https://forum.confluent.io/u/janluca)\
**Replies:** 0\
**Last updated:** [16 November 2023 16:48 UTC](https://forum.confluent.io/t/connectors-rest-endpoint-doesnt-show-all-installed-connectors/9097 "2023-11-16T16:48:29Z")

</div>

Good day, I’m calling the https://api.confluent.cloud:443/connect/v1/environments/$ENVIRONMENT/clusters/$CLUSTER/connectors endpoint to see the list of the connectors installed on our cluster, but the list is incomplete…

---

## [Compression in confluent kafka](https://forum.confluent.io/t/compression-in-confluent-kafka/9090)

<div class="topic-metadata">

**Author:** [@ankit1331](https://forum.confluent.io/u/ankit1331)\
**Replies:** 0\
**Last updated:** [15 November 2023 19:31 UTC](https://forum.confluent.io/t/compression-in-confluent-kafka/9090 "2023-11-15T19:31:25Z")

</div>

When we use compression.type as lz4 in confluent kafka, properties in databricks notebook. The compression is not happening and kafka gives an error message size to bog

---

## [Get list of Kafka Brokers in Confluent CLoud](https://forum.confluent.io/t/get-list-of-kafka-brokers-in-confluent-cloud/8691)

<div class="topic-metadata">

**Author:** [@dchen-nue](https://forum.confluent.io/u/dchen-nue)\
**Replies:** 1\
**Last updated:** [15 November 2023 06:49 UTC](https://forum.confluent.io/t/get-list-of-kafka-brokers-in-confluent-cloud/8691 "2023-11-15T06:49:39Z")

</div>

Hello, I was wondering if it is possible to get a list of kafka brokers in a Confluent Cloud cluster? I found this command from the cli but it doesnt seem to be an option for Confluent Cloud, I believe this is only for …

---

## [Deleting user through Terraform](https://forum.confluent.io/t/deleting-user-through-terraform/9042)

<div class="topic-metadata">

**Author:** [@Bagger](https://forum.confluent.io/u/Bagger)\
**Replies:** 0\
**Last updated:** [9 November 2023 08:18 UTC](https://forum.confluent.io/t/deleting-user-through-terraform/9042 "2023-11-09T08:18:20Z")

</div>

Does anyone have experience in creating and removing users through Terraform? I can create users (or invite them) through the confluent\_invitation ressource, but I cannot see who to remove them again.

---

## [Confluent Provision Testing framework](https://forum.confluent.io/t/confluent-provision-testing-framework/9040)

<div class="topic-metadata">

**Author:** [@ajaykumar2014](https://forum.confluent.io/u/ajaykumar2014)\
**Replies:** 0\
**Last updated:** [9 November 2023 08:01 UTC](https://forum.confluent.io/t/confluent-provision-testing-framework/9040 "2023-11-09T08:01:25Z")

</div>

Hello I am writing Terraform script to provision the confluent infrastructure and at the end provisioned infrastructure would be asserted using some testing framework… Exploring kitchen-terraform inspec framework but i…

---

## [Regarding to the APIs](https://forum.confluent.io/t/regarding-to-the-apis/8994)

<div class="topic-metadata">

**Author:** [@Xuanzi](https://forum.confluent.io/u/Xuanzi)\
**Replies:** 0\
**Last updated:** [3 November 2023 17:07 UTC](https://forum.confluent.io/t/regarding-to-the-apis/8994 "2023-11-03T17:07:02Z")

</div>

Hi friends, We are trying to use the APIs to get all kafka topics and all kafka connects. Surprise to see there’s no pagination for list topics or connects, also there’s no filters or ordering supported. Wondering why …

[Previous page](https://forum.confluent.io/c/confluent-cloud/5.md?page=2)

[Next page](https://forum.confluent.io/c/confluent-cloud/5.md?page=4)
