kafka-connect-elasticsearch
kafka-connect-elasticsearch copied to clipboard
confluentinc
Kafka Connect Elasticsearch connector
The filebeat supports disable SSL verification with configuration ```yaml output.elasticsearch: hosts: ["https://localhost:9200"] username: "elastic" password: "elastic" ssl.verification_mode: "none" ``` How to set it up in kafka-connect-elasticsearch? ```properties name=elasticsearch-sink connector.class=io.confluent.connect.elasticsearch.ElasticsearchSinkConnector tasks.max=1...
In https://github.com/apache/kafka/pull/16403 (referencing https://issues.apache.org/jira/browse/KAFKA-3346) `Mode` from `org.apache.kafka.common.network` was renamed to `ConnectionMode`. As a result, I'm seeing this error ``` java.lang.NoClassDefFoundError: org/apache/kafka/common/network/Mode ``` when attempting to run version `14.1.2` of this...
We're using ECK for our Elasticsearch and we want to be able to use the default SSL settings on the cluster and connect to the cluster using a Kubernetes `.svc.cluster.local:9200`...
## Problem Lets consider the following kafka schema: ```json { "name": "dateOfBirth", "type": [ "null", {"type": "int", "logicalType": "date"}], "default": null } ``` And the target index field: ```json "dateOfBirth":...
## Problem ## Solution ##### Does this solution apply anywhere else? - [ ] yes - [ ] no ##### If yes, where? ## Test Strategy ##### Testing done: -...
## Problem ## Solution ##### Does this solution apply anywhere else? - [ ] yes - [ ] no ##### If yes, where? ## Test Strategy ##### Testing done: -...
For any questions/concerns about this PR, please review the [Renovate Bot wiki/FAQs](https://app.glean.com/go/renovatebot-faqs), or the [#renovatebot](https://app.glean.com/go/renovatebot-slack) Slack channel. This PR contains the following updates: | Package | Change | Age |...
![renovatebot-confluentinc[bot] avatar](https://avatars.githubusercontent.com/u/9439498?v=4 "renovatebot-confluentinc[bot] avatar"){kind=avatar}
For any questions/concerns about this PR, please review the [Renovate Bot wiki/FAQs](https://app.glean.com/go/renovatebot-faqs), or the [#renovatebot](https://app.glean.com/go/renovatebot-slack) Slack channel. This PR contains the following updates: | Package | Change | Age |...
For any questions/concerns about this PR, please review the [Renovate Bot wiki/FAQs](https://app.glean.com/go/renovatebot-faqs), or the [#renovatebot](https://app.glean.com/go/renovatebot-slack) Slack channel. This PR contains the following updates: | Package | Change | Age |...
For any questions/concerns about this PR, please review the [Renovate Bot wiki/FAQs](https://app.glean.com/go/renovatebot-faqs), or the [#renovatebot](https://app.glean.com/go/renovatebot-slack) Slack channel. This PR contains the following updates: | Package | Change | Age |...