diff --git a/connect-connectors/apps/resources/filestream-source-connector.yaml b/connect-connectors/apps/resources/filestream-source-connector.yaml new file mode 100644 index 00000000..028096b5 --- /dev/null +++ b/connect-connectors/apps/resources/filestream-source-connector.yaml @@ -0,0 +1,14 @@ +apiVersion: kafka.strimzi.io/v1beta2 +kind: KafkaConnector +metadata: + name: filestream-source-connector + labels: + strimzi.io/cluster: my-connect-cluster +spec: + class: org.apache.kafka.connect.file.FileStreamSourceConnector + config: + file: "_FILE_PATH_" + topic: user-interactions + key.converter: org.apache.kafka.connect.json.JsonConverter + value.converter: org.apache.kafka.connect.json.JsonConverter + tasksMax: 2 diff --git a/connect-connectors/apps/resources/github-source-connector.yaml b/connect-connectors/apps/resources/github-source-connector.yaml deleted file mode 100644 index bedd9e36..00000000 --- a/connect-connectors/apps/resources/github-source-connector.yaml +++ /dev/null @@ -1,18 +0,0 @@ -apiVersion: kafka.strimzi.io/v1beta2 -kind: KafkaConnector -metadata: - labels: - strimzi.io/cluster: my-connect-cluster - name: github-source-connector -spec: - class: org.apache.camel.kafkaconnector.github.CamelGithubSourceConnector - config: - camel.source.endpoint.oauthToken: _YOUR_GITHUB_TOKEN_ - camel.source.endpoint.repoName: ad482-connectors - camel.source.endpoint.repoOwner: _YOUR_GITHUB_USERNAME_ - camel.source.path.branchName: main - camel.source.path.type: event - key.converter: org.apache.kafka.connect.json.JsonConverter - value.converter: org.apache.kafka.connect.json.JsonConverter - topics: github-events - tasksMax: 1 \ No newline at end of file diff --git a/connect-connectors/solutions/resources/elasticsearch-sink-connector.sh b/connect-connectors/solutions/resources/elasticsearch-sink-connector.sh index a7af859e..a7610f91 100644 --- a/connect-connectors/solutions/resources/elasticsearch-sink-connector.sh +++ b/connect-connectors/solutions/resources/elasticsearch-sink-connector.sh @@ -7,9 +7,9 @@ curl -X POST \ { "connector.class": "'$connector_class'", "tasks.max": "1", - "topics": "github-events", + "topics": "user-interactions", "camel.sink.endpoint.hostAddresses": "elasticsearch-es-http:9200", - "camel.sink.endpoint.indexName": "github_events", + "camel.sink.endpoint.indexName": "user_interactions", "camel.sink.endpoint.operation": "Index", "camel.sink.path.clusterName": "elasticsearch", "key.converter": "org.apache.kafka.connect.storage.StringConverter", diff --git a/connect-connectors/solutions/resources/filestream-source-connector.yaml b/connect-connectors/solutions/resources/filestream-source-connector.yaml new file mode 100644 index 00000000..c3ce1e27 --- /dev/null +++ b/connect-connectors/solutions/resources/filestream-source-connector.yaml @@ -0,0 +1,14 @@ +apiVersion: kafka.strimzi.io/v1beta2 +kind: KafkaConnector +metadata: + name: filestream-source-connector + labels: + strimzi.io/cluster: my-connect-cluster +spec: + class: org.apache.kafka.connect.file.FileStreamSourceConnector + config: + file: "/tmp/interactions.log" + topic: user-interactions + key.converter: org.apache.kafka.connect.json.JsonConverter + value.converter: org.apache.kafka.connect.json.JsonConverter + tasksMax: 2 \ No newline at end of file diff --git a/connect-connectors/solutions/resources/github-source-connector.yaml b/connect-connectors/solutions/resources/github-source-connector.yaml deleted file mode 100644 index bedd9e36..00000000 --- a/connect-connectors/solutions/resources/github-source-connector.yaml +++ /dev/null @@ -1,18 +0,0 @@ -apiVersion: kafka.strimzi.io/v1beta2 -kind: KafkaConnector -metadata: - labels: - strimzi.io/cluster: my-connect-cluster - name: github-source-connector -spec: - class: org.apache.camel.kafkaconnector.github.CamelGithubSourceConnector - config: - camel.source.endpoint.oauthToken: _YOUR_GITHUB_TOKEN_ - camel.source.endpoint.repoName: ad482-connectors - camel.source.endpoint.repoOwner: _YOUR_GITHUB_USERNAME_ - camel.source.path.branchName: main - camel.source.path.type: event - key.converter: org.apache.kafka.connect.json.JsonConverter - value.converter: org.apache.kafka.connect.json.JsonConverter - topics: github-events - tasksMax: 1 \ No newline at end of file