Skip to content

Instantly share code, notes, and snippets.

@renanregis
Last active September 7, 2021 12:39
Show Gist options
  • Save renanregis/3819a60724599941b5d5b90d501cc573 to your computer and use it in GitHub Desktop.
Save renanregis/3819a60724599941b5d5b90d501cc573 to your computer and use it in GitHub Desktop.
Kafka Sink Connector Elasticsearch
name=sink-elastic-twitter-distributed
connector.class=io.confluent.connect.elasticsearch.ElasticsearchSinkConnector
tasks.max=3
topics=twitter-demo
key.converter=org.apache.kafka.connect.json.JsonConverter
key.converter.schemas.enable=true
value.converter=org.apache.kafka.connect.json.JsonConverter
value.converter.schemas.enable=true
connection.url=http://elasticsearch:9200
type.name=genres
key.ignore=true
topic.index.map=twitter-demo:genres
topic.key.ignore=twitter-demo
topic.schema.ignore=twitter-demo
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment