Questions tagged [confluent-platform]
Do not use this tag for general Apache Kafka questions. Confluent Platform offers a Streaming Platform providing enterprise event streaming functionalities complementing Apache Kafka, Security plugins, including Control Center UI, Schema Registry, and an HTTP Rest Proxy.
confluent-platform
2,101
questions
0
votes
0
answers
7
views
Why doesn't large select query return any value in ksql?
I have a fairly large query in ksqldb where all the different columns of the query do work, but when I combine them all together I don't get any result. I don't get any feedback telling me why there ...
- 23.2k
0
votes
1
answer
34
views
Not able to externally connect to confluent kafka cluster's brokers with confluent for kubernetes
I am trying to set up External connection with Confluent for Kubernetes. I've followed the documentation :
spec:
listeners:
external:
externalAccess:
type: loadBalancer
...
- 56
0
votes
0
answers
30
views
Confluent schema registry 7.6.0 taking too long to catchup with offsets during startup
I have deployed confluent schema registry version 7.6.0 on my on-premise Kubernetes cluster,and it is pointing to _schemas topic in Kafka cluster hosted to Confluent cloud on GCP.
The_schemas topic is ...
- 61
1
vote
0
answers
18
views
How to write data to Confluent Kafka with SchemaRegistry format on sparkstructured?
I am to trying write a batch data to kafka topic with schema registry in databricks using pyspark, i serialize the data with pyspark to_avro function and write it to the topic, but the consumers can’t ...
- 11
0
votes
0
answers
68
views
Async Api: Generate Java Client using Schema Registry and AVRO messages
I´m using Confluent Async Api Tool to export the topic / schema definitions to an async-api.yml file.
I want to generate a Spring Cloud Client using Schema Registry and AVRO generated classes from the ...
0
votes
0
answers
29
views
Issue with setting up KSQLDB locally with Remote Kafka Cluster
I'm trying to set up KSQLDB locally and connect it to remote kafka server running on upstash. But, after configuring the credentials, I'm not able to connect to the kafka server.
I installed KSQLDB ...
- 1
0
votes
0
answers
149
views
Security Manager is deprecated and will be removed in a future release
Ksql Db was starting absolutely fine up until now when I ran into this issue. I am aware that port on to which ksqldb starts shouldn't be occupied by any other process, so that's not an issue.
Anyway, ...
0
votes
0
answers
34
views
confluent cloud login using github actions
while trying to write a workflow in github actions to install confluent cli and also login using
confleunt login --no-browser it actual requires an external authentication from the browser by ...
- 1
0
votes
0
answers
26
views
Problem with Kafka setup in Kubernetes - Bootstrap broker disconnected [duplicate]
I've been following the steps to set up Confluent Platform with static host-based routing in Kubernetes. However, I'm encountering issues when trying to produce messages to a Kafka topic from an ...
0
votes
0
answers
214
views
Kafka Producer Error - Bootstrap Broker Disconnected
I'm encountering an issue while attempting to produce messages to a Kafka topic using the kafka-console-producer command. Despite configuring the connection details correctly, I face the following ...
1
vote
1
answer
141
views
How to login to confluent platform using confluent cli?
I have installed confluent platform and all the local services are up and running. The problem arises when I try to install a connector, like lets say Postgresql connector by issuing the following ...
0
votes
0
answers
70
views
Schema Validation with Pyflink and Kafka's Schema Registry
I was able register my expected schema for the Kafka topic for the records arriving using the below command:
curl -X POST -H "Content-Type: application/vnd.schemaregistry.v1+json" \
--data ...
- 553
0
votes
0
answers
29
views
Unable to Find Debezium Heartbeat Topic in Confluent UI/CLI with Kafka Connect Standalone on Kubernetes
I'm currently using the Confluent Kubernetes Operator for managing a Kafka cluster, along with a Kafka Connect standalone node. Within this setup, I've configured a Debezium PostgreSQL source ...
- 11
0
votes
0
answers
40
views
Kafka - Getting error - Error checking or creating metrics topic
Trying to install confluent platform 7.5.3 - Kafka on 6 nodes and see below messages in server.log
Getting error - Error checking or creating metrics topic (io.confluent.metrics.reporter....
- 161
0
votes
0
answers
27
views
Not seeing results in ksqldb query
in ksqldb-cli (Version: 7.1.7)
I defined a stream based on the docs:
https://docs.confluent.io/5.4.11/ksql/docs/developer-guide/create-a-stream.html
The topic contains JSON data but I use String ...
- 3,737