Top "Apache-kafka-connect" questions

Apache Kafka Connect is a tool for scalable and reliable streaming data between Apache Kafka and other data systems.

"The configuration foo.bar was supplied but isn't a known config"

When I'm starting a connector in distributed mode (connect-runtime v1.0.0), there are several configuration values that are mandatory. I'm speaking …

apache-kafka apache-kafka-connect
When does Kafka Leader Election happen?

When and how often does Kafka High Level Producer elect a leader? Does it do before sending each message or …

apache-kafka kafka-producer-api apache-kafka-connect
Running kafka connect in Distributed mode?

I have a total of 3 VM's(CloudVPS). Each of them has java, confluent open source installed on them. In VM1 …

apache-kafka kafka-consumer-api apache-kafka-connect confluent-platform
java.lang.NoSuchMethodError: com.google.common.collect.Sets$SetView.iterator()Lcom/google/common/collect/UnmodifiableIterator;

I've been trying to connect kafka to elasticsearch using kafka-connect api.Kafka version is 0.11.0.0.These are the steps I followed: 1.…

elasticsearch apache-kafka apache-kafka-connect confluent-platform
How to use from_json with Kafka connect 0.10 and Spark Structured Streaming?

I was trying to reproduce the example from [Databricks][1] and apply it to the new connector to Kafka and spark …

scala apache-spark apache-kafka apache-kafka-connect spark-structured-streaming
Ideal value for Kafka Connect Distributed tasks.max configuration setting?

I am looking to productionize and deploy my Kafka Connect application. However, there are two questions I have about the …

amazon-s3 apache-kafka apache-kafka-connect confluent-platform
Kafka Connect - Failed to flush, timed out while waiting for producer to flush outstanding messages

I am trying to use the Kafka Connect JDBC Source Connector with following properties in BULK mode. connector.class=io.…

apache-kafka apache-kafka-connect kafka-producer-api
Kafka Connect can't find connector

I'm trying to use the Kafka Connect Elasticsearch connector, and am unsuccessful. It is crashing with the following error: [2018-11…

apache-kafka apache-kafka-connect confluent-platform