Skip to content

Commit 98f3d28

Browse files
committed
Merge branch 'development' of https://github.com/OracleLinuxWorld/vagrantKafka into development
2 parents 791c713 + 8a39291 commit 98f3d28

File tree

2 files changed

+2
-0
lines changed

2 files changed

+2
-0
lines changed

vagrant/roles/role_kafka_connect_MySQL/templates/kafka-connect-jdbc-source-bulk.json.j2

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,6 @@
11
{
22
"_comment": "Based on the tutorial on: https://www.confluent.io/blog/simplest-useful-kafka-connect-data-pipeline-world-thereabouts-part-1/",
3+
"plugin.path": "/usr/local/share/kafka",
34
"connector.class": "io.confluent.connect.jdbc.JdbcSourceConnector",
45
"key.converter": "io.confluent.connect.avro.AvroConverter",
56
"key.converter.schema.registry.url": "http://{{ kafka_service_ip_address }}:{{ port_kafka_schema_registry }}",

vagrant/roles/role_kafka_sink_ElasticSearch/templates/kafka-connect-elastic-sink.json.j2

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -16,6 +16,7 @@
1616
"transforms.routeTS.topic.format": "kafka-${topic}-${timestamp}",
1717
"transforms.routeTS.timestamp.format": "YYYYMMdd",
1818
"log.message.timestamp.type": "LogAppendTime",
19+
"schema.ignore": "true",
1920
"replication.factor": 3,
2021

2122
"_comment": "--- Elasticsearch-specific config ---",

0 commit comments

Comments
 (0)