Reputation: 520
im new in apache environment and it have something that makes me really wonder. My kafka was installed via ambari. so everything can be started by ambari's GUI. When kafka installed via ambari it includes kafka-connect. But what if i the connector i need is not included . here are some the connectors that included.
/etc/kafka-connect-activemq
/etc/kafka-connect-elasticsearch
/etc/kafka-connect-ibmmq
/etc/kafka-connect-jdbc
/etc/kafka-connect-jms
/etc/kafka-connect-replicator
/etc/kafka-connect-s3
/etc/kafka-connect-storage-common
/etc/kafka-connect-activemq/ActiveMQSourceConnector.properties
/etc/kafka-connect-activemq/connect-avro-localhost.properties
/etc/kafka-connect-elasticsearch/quickstart-elasticsearch.properties
/etc/kafka-connect-ibmmq/IbmMQSourceConnector.properties
/etc/kafka-connect-ibmmq/connect-avro-localhost.properties
/etc/kafka-connect-jdbc/sink-quickstart-sqlite.properties
/etc/kafka-connect-jdbc/source-quickstart-sqlite.properties
/etc/kafka-connect-jms/ActiveMQSourceConnector.properties
/etc/kafka-connect-jms/JMSSourceConnector.properties
/etc/kafka-connect-jms/connect-avro-localhost.properties
/etc/kafka-connect-replicator/quickstart-replicator-unicluster.properties
/etc/kafka-connect-replicator/quickstart-replicator.properties
/etc/kafka-connect-replicator/replicator-connect-distributed.properties
/etc/kafka-connect-replicator/replicator-connect-standalone.properties
/etc/kafka-connect-replicator/replicator-log4j.properties
/etc/kafka-connect-replicator/replicator.properties
/etc/kafka-connect-s3/quickstart-s3.properties
/etc/kafka-connect-s3/quickstart-schema-source-for-s3.properties
but what i need is hdfs3-sink. How do i achieve it without confluent?
any suggestion will be appreciated so much. Thank you
Upvotes: 0
Views: 211
Reputation: 32090
The only HDFS 3 connector for Kafka Connect that I'm aware of is this one from Confluent: https://www.confluent.io/hub/confluentinc/kafka-connect-hdfs3/.
To install it you can download the JAR directly, or use confluent-hub
CLI tool to install it.
Upvotes: 2