Questions tagged [confluent-cloud]
154 questions
10
votes
2 answers
How AWS MSK and Confluent Schema Registry and Confluent Kafka connect recommended to use together?
We are planning to use AWS MSK service for Managed Kafka and Schema Registry and Kafka Connect services from Confluent together to run our connectors (Elasticsearch Sink Connector). We have planned to run Schema Registry and Connectors in EC2.
As…
Suresh Sanghani
- 131
- 1
- 8
4
votes
1 answer
Cloud confluent kafka installation failed in ubuntu 18
Instruction page says as:-
Install the Confluent Cloud CLI
Run this command to install the Confluent Cloud CLI.
curl -L --http1.1 https://cnfl.io/ccloud-cli | sh -s -- -b /usr/local/bin
it failed for permission
"install: cannot create regular…
masiboo
- 4,537
- 9
- 75
- 136
3
votes
2 answers
API request blocked by CORS policy with Confluent Cloud and Kafka
I'm trying to post a message on a Kafka cluster on Confluent cloud. It works fine on Postman, but when I try on my Svelte app, I got this error:
Access to fetch at from origin 'http://localhost:3000'
has been blocked by CORS policy:…
Gum Rick
- 205
- 2
- 13
3
votes
1 answer
How to shutdown running Confluent Cloud cluster?
On Confluent (https://confluent.cloud) there does not appear to be an option to shutdown a Kafka cluster :
I'm attempting to limit my costs and shutdown the cluster. I've explored the various options in the screenshot above but I've not found the…
blue-sky
- 51,962
- 152
- 427
- 752
3
votes
3 answers
Camel-Kafka security protocol SASL_SASL not working
Using as an starting point the official examples provided by Camel-Quarkus I have amended the logic in order to write to a Kafka broker. With the Camel Kafka component pointing to a local broker all works well.
Trying to reach our Confluent Cloud…
LeonardoBonacci
- 103
- 2
- 7
3
votes
2 answers
io.debezium.DebeziumException: The db history topic or its content is fully or partially missing
I am facing frequent issues related to db history topic which is created by the connector itself. There is a temporary solution (by changing the name of the db history topic) which I tried but it's not the better way to handle it. Also, the…
Shivani Bhakal
- 41
- 1
- 2
3
votes
1 answer
spring-cloud-stream-binder-kafka configuration for Confluent Cloud Schema Registry Unauthorized error
I'm having trouble configuring a connection to Confluent when using spring-cloud-stream-binder-kafka. Possibly somebody can see what is wrong?
When I use the example from…
Ronan Hughes
- 198
- 1
- 1
- 10
3
votes
1 answer
How to connect confluent cloud schema registry?
I am using Confluent managed Kafka cluster and Schema Registry service. I can manage connect confluent cloud kafka cluster adding following properties to producer config…
jonyroy
- 187
- 1
- 11
3
votes
1 answer
Message value in Confluent Cloud not decoding properly
I'm very new to kafka and confluent. I wrote a Producer nearly identical to the tutorial on https://www.confluent.fr/blog/schema-registry-avro-in-spring-boot-application-tutorial/ with my own dummy model. The application.yaml is the same as well.…
Prady
- 165
- 1
- 15
3
votes
1 answer
Spring Cloud Stream Kafka Stream application shows Resetting offset for partition event-x to offset 0 on every restart
I have a Spring Cloud Stream Kafka Stream application that reads from a topic (event) and performs a simple processing:
@Configuration
class EventKStreamConfiguration {
private val logger = LoggerFactory.getLogger(javaClass)
…
codependent
- 23,193
- 31
- 166
- 308
2
votes
0 answers
kafkadrop: Timeout while connecting to confluent cloud
I launch kafkadrop to connect to a kafka cluster running in confluent cloud:
java -jar kafdrop-3.30.0.jar
---kafka.brokerConnect=.......confluent.cloud:9092
I see error:
Caused by: org.apache.kafka.common.errors.TimeoutException: Timed out waiting…
Mandroid
- 6,200
- 12
- 64
- 134
2
votes
0 answers
Cannot connect to confluent cloud kafka with golang standard settings (`No address associated with hostname`)
I have some fairly simple Golang code (pulled directly from from confluent's Golang port of their kafka C library librdkafka) however my client refuses to connect over SSL from my k8s cluster in gcp.
The error I'm getting is the following (where…
CertainlyNotAdrian
- 337
- 2
- 16
2
votes
0 answers
Confluent Cloud - Add Basic Auth to Kafka Rest Proxy Docker Container
I have the requirement to run a Kafka Rest Proxy for my Confluent Cloud and would like to use the existing Docker container that is provided by Confluent Cloud.
I got the Docker container running with the following command on my local…
Shamshiel
- 2,051
- 3
- 31
- 50
2
votes
1 answer
Can I configure number of brokers in Confluent Kafka Cloud with basic endition?
Because of budget issue, I personally am using Confluent Cloud basic edition which is free.
Is there any way to setup number of kafka brokers on my own?
I could not find anything related on confluent cloud web UI settings.
Does only Dedicated…
ethany21
- 49
- 1
- 7
2
votes
1 answer
Filter Confluent Cloud "confluent-audit-log-events" topic
How can I filter Confluent Cloud cluster audit log based on the environment while consuming from the topic: confluent-audit-log-events in spring boot application?
I'm using the camel route to consume from the audit topic.
public void configure()…
Vishal Dhanani
- 53
- 9