Skip to content

Commit

Permalink
Merge pull request #1 from Mongey/cm-rename-to-kafka-connect
Browse files Browse the repository at this point in the history
Rename kc provider to kafka-connect
  • Loading branch information
Mongey committed Mar 26, 2018
2 parents 30cd5a4 + a381fd4 commit 0a076a5
Show file tree
Hide file tree
Showing 7 changed files with 27 additions and 11 deletions.
6 changes: 3 additions & 3 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -5,11 +5,11 @@ A [Terraform][1] plugin for managing [Apache Kafka Connect][2].
# Example

```hcl
provider "kc" {
url = "http://localhost:8080"
provider "kafka-connect" {
url = "http://localhost:8083"
}
resource "kc_connector" "sqlite-sink" {
resource "kafka-connect_connector" "sqlite-sink" {
name = "sqlite-sink"
config = {
Expand Down
2 changes: 1 addition & 1 deletion bin/test
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@
set -ex

go build
mv terraform-provider-kafka-connect ~/.terraform.d/plugins/terraform-provider-kc
mv terraform-provider-kafka-connect ~/.terraform.d/plugins/terraform-provider-kafka-connect
cd examples
terraform init
terraform plan
4 changes: 2 additions & 2 deletions kc/provider.go → connect/provider.go
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package kafka
package connect

import (
"github.com/hashicorp/terraform/helper/schema"
Expand All @@ -17,7 +17,7 @@ func Provider() terraform.ResourceProvider {

ConfigureFunc: providerConfigure,
ResourcesMap: map[string]*schema.Resource{
"kc_connector": kafkaConnectorResource(),
"kafka-connect_connector": kafkaConnectorResource(),
},
}
}
Expand Down
4 changes: 2 additions & 2 deletions kc/provider_test.go → connect/provider_test.go
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package kafka
package connect

import (
"testing"
Expand All @@ -22,6 +22,6 @@ func testAccPreCheck(t *testing.T) {
func accProvider() map[string]terraform.ResourceProvider {
provider := Provider().(*schema.Provider)
return map[string]terraform.ResourceProvider{
"kc": provider,
"kafka-connect": provider,
}
}
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package kafka
package connect

import (
"log"
Expand Down
16 changes: 16 additions & 0 deletions examples/main.tf
Original file line number Diff line number Diff line change
@@ -0,0 +1,16 @@
provider "kafka-connect" {
url = "http://localhost:8083"
}

resource "kafka-connect_connector" "sqlite-sink" {
name = "sqlite-sink"

config = {
"name" = "test-sink"
"connector.class" = "io.confluent.connect.jdbc.JdbcSinkConnector"
"tasks.max" = "1"
"topics" = "orders"
"connection.url" = "jdbc:sqlite:test.db"
"auto.create" = "true"
}
}
4 changes: 2 additions & 2 deletions main.go
Original file line number Diff line number Diff line change
@@ -1,10 +1,10 @@
package main

import (
kc "github.com/Mongey/terraform-provider-kafka-connect/kc"
c "github.com/Mongey/terraform-provider-kafka-connect/connect"
"github.com/hashicorp/terraform/plugin"
)

func main() {
plugin.Serve(&plugin.ServeOpts{ProviderFunc: kc.Provider})
plugin.Serve(&plugin.ServeOpts{ProviderFunc: c.Provider})
}

0 comments on commit 0a076a5

Please sign in to comment.