confluent-platform Questions
10
Solved
I need to use the Confluent kafka-avro-serializer Maven artifact. From the official guide I should add this repository to my Maven pom
<repository>
<id>confluent</id>
<url&g...
Tunicate asked 19/4, 2017 at 7:10
4
I'm trying to sink the table data one DB to another DB using kafka debezium ( Kafka streaming ) with the help of docker.
DB stream is working fine. But streamed data to sink another MySQL DB proce...
Kantianism asked 21/11, 2019 at 10:59
4
I have set up Kafka cluster and installed confluent-hub on a EC2 instance. I have downloaded the confluent-hub tar file, extracted and placed the binary inside /usr/local/bin.
When I am now trying ...
Casino asked 17/4, 2021 at 4:27
4
Solved
I get the following error when I want to send an AVRO message which contains a field that has the type long:
Caused by: org.apache.kafka.common.errors.SerializationException: Error deserializing A...
Passed asked 18/12, 2017 at 11:48
7
I just installed Kafka (from Confluent Platform) on my Windows machine. I started up Zookeeper and Kafka and creating topics, producing to and consuming from them works. However, as soon as I delet...
Pentad asked 8/6, 2018 at 7:46
2
Solved
I am using the confluent docker for Kafka connect v4.1.1 and would like to add a jar with specific log4j appenders.
With the classpath isolation by connector, I am not sure where to place that jar...
Garnish asked 14/6, 2018 at 14:23
2
Stream :
describe ammas;
Field | Type
-------------------------------------
ROWTIME | BIGINT (system)
ROWKEY | VARCHAR(STRING) (system)
ID | INTEGER
-----------------------------------...
Tubb asked 21/7, 2018 at 18:33
4
Solved
We are running Kafka Connect (Confluent Platform 5.4, ie. Kafka 2.4) in a distributed mode using Debezium (MongoDB) and Confluent S3 connectors.
When adding a new connector via the REST API the con...
Yuriyuria asked 21/2, 2020 at 8:15
2
Here's what I've tried so far:
from confluent_kafka import Consumer
c = Consumer({... several security/server settings skipped...
'auto.offset.reset': 'beginning',
'group.id': 'my-group'})
c.su...
Giant asked 8/2, 2021 at 21:37
3
Solved
i've setup SSL on my local Kafka instance, and when i start the Kafka console producer/consumer on SSL port, it is giving SSL Handshake error
Karans-MacBook-Pro:keystore karanalang$ $CONFLUENT_HOME...
Lot asked 10/11, 2021 at 21:20
4
I'm using KafkaProducer in my test cases and my producer uses the schemaRegistryUrl which points a my local instance of Schema Registry. Is there a way to mock how KafkaProducer connects with the S...
Welles asked 23/9, 2016 at 22:59
2
Solved
I am trying to set up Kafka rest proxy using a docker. But the topic I am providing in the configuration isn't creating.
I am checking Kafka Topic with API: curl "http://metrics-kafka-rest:38082/t...
Miyokomizar asked 13/8, 2019 at 9:41
2
Solved
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-com...
Unsightly asked 3/12, 2021 at 7:8
1
Kafka consumer application is throwing ObjectDisposedException when we initiate the process to stop the consumer service.I would like to understand what process destroyed the kafka handle
System.Ob...
Affiche asked 12/8, 2020 at 22:56
3
While adding dependencies for confluent kafka in build gradle file, its unable to resolve it.
compile group: 'io.confluent', name: 'kafka-avro-serializer', version: '4.0.0'
compile group: 'io.c...
Sung asked 23/5, 2020 at 15:45
2
Solved
I installed kafka confluent oss 4.0 on a fresh linux centos 7 but kafka connect failed to start.
Steps to reproduce :
- Install Oracle JDK 8
- Copy confluent-4.0.0 folder on opt/confluent-4.0.0...
Jocund asked 29/11, 2017 at 15:8
2
I have installed confluent platform in Ubuntu 16.04 machine and initially i have configured zookeeper, Kafka and ksql and started confluent platform.
i am able to see the below message.
root@DE...
Monolatry asked 30/1, 2019 at 12:56
4
I'm trying to use the Kafka Connect Elasticsearch connector, and am unsuccessful. It is crashing with the following error:
[2018-11-21 14:48:29,096] ERROR Stopping after connector error (org.apach...
Linearity asked 21/11, 2018 at 13:1
2
Solved
I have started Confluent Platform on my windows 10 using docker with the help of https://docs.confluent.io/current/quickstart/ce-docker-quickstart.html. Now I want to try using Confluent CLI. But I...
Titrant asked 28/4, 2020 at 10:9
2
Solved
Kafka schema-registry provides a nice way to serialize and deserialize the data from Kafka using common data contract. However, the data contract (.avsc file) is the glue between the producer and c...
Sullage asked 5/9, 2019 at 2:49
2
I am using these installation instructions for getting confluent hub client https://docs.confluent.io/current/connect/managing/confluent-hub/client.html
But, when I get to the line to install the ...
Cagliari asked 9/7, 2019 at 18:8
2
Looking at https://github.com/confluentinc/confluent-kafka-dotnet/blob/master/examples/JsonSerialization/Program.cs it requires Schema Registry URL. Is there a simple way to serialize/deserialize J...
Ridgeling asked 5/2, 2021 at 4:4
2
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...
Poppas asked 28/10, 2020 at 7:23
2
I use Confluent Kafka .Net library Version 1.2.1, I have implemented consumer to consume messages from a topic, the problem is Consume method blocks the main thread and keeps waiting until a messag...
Attainture asked 17/12, 2019 at 7:53
3
I am using the confluent community edition for a simple setup consisting a rest client calling the Kafka rest proxy and then pushing that data into an oracle database using the provided jdbc sink c...
Illjudged asked 15/3, 2019 at 4:24
1 Next >
© 2022 - 2024 — McMap. All rights reserved.