command
module
Version:
v0.4.1
Opens a new window with list of versions in this module.
Published: Jun 5, 2024
License: MIT
Opens a new window with license information.
Imports: 2
Opens a new window with list of imports.
Imported by: 0
Opens a new window with list of known importers.
README
¶
A Terraform plugin for managing Apache Kafka Connect.
Installation
Download and extract the latest
release to
your terraform plugin directory (typically ~/.terraform.d/plugins/
)
Example
Configure the provider directly, or set the ENV variable KAFKA_CONNECT_URL
provider "kafka-connect" {
url = "http://localhost:8083"
basic_auth_username = "user" # Optional
basic_auth_password = "password" # Optional
# For TLS
tls_auth_crt = "/tmp/cert.pem" # Optional
tls_auth_key = "/tmp/key.pem " # Optional
tls_auth_is_insecure = true # Optionnal if you do not want to check CA
}
resource "kafka-connect_connector" "sqlite-sink" {
name = "sqlite-sink"
config = {
"name" = "sqlite-sink"
"connector.class" = "io.confluent.connect.jdbc.JdbcSinkConnector"
"tasks.max" = 1
"topics" = "orders"
"connection.url" = "jdbc:sqlite:test.db"
"auto.create" = "true"
"connection.user" = "admin"
}
config_sensitive = {
"connection.password" = "this-should-never-appear-unmasked"
}
}
Provider Properties
Property |
Type |
Example |
Alternative environment variable name |
url |
URL |
"http://localhost:8083" |
KAFKA_CONNECT_URL |
basic_auth_username |
String |
"user" |
KAFKA_CONNECT_BASIC_AUTH_USERNAME |
basic_auth_password |
String |
"password" |
KAFKA_CONNECT_BASIC_AUTH_PASSWORD |
tls_auth_crt |
String |
"certificate" |
KAFKA_CONNECT_TLS_AUTH_CRT |
tls_auth_key |
String |
"Key" |
KAFKA_CONNECT_TLS_AUTH_KEY |
tls_auth_is_insecure |
String |
"Key" |
KAFKA_CONNECT_TLS_IS_INSECURE |
headers |
Map[String]String |
{foo = "bar"} |
N/A |
Resource Properties
Property |
Type |
Description |
name |
String |
Connector name |
config |
HCL Block |
Connector configuration |
config_sensitive |
HCL Block |
Sensitive connector configuration. Will be masked in output. |
Developing
- Install go
- Clone repository to:
$GOPATH/src/github.com/Mongey/terraform-provider-kafka-connect
mkdir -p $GOPATH/src/github.com/Mongey/terraform-provider-kafka-connect; cd $GOPATH/src/github.com/Mongey/
git clone https://github.com/Mongey/terraform-provider-kafka-connect.git
- Build the provider
make build
- Run the tests
make test
- Run acceptance tests
make testacc
Documentation
¶
There is no documentation for this package.
Source Files
¶
Directories
¶
Click to show internal directories.
Click to hide internal directories.