浏览代码

added kafka connect configs

Grega Bremec 7 月之前
父节点
当前提交
e7f09773f3
共有 2 个文件被更改,包括 19 次插入0 次删除
  1. 8 0
      code/lab/connect.properties
  2. 11 0
      code/lab/postgres-source-connector.properties

+ 8 - 0
code/lab/connect.properties

@@ -0,0 +1,8 @@
+bootstrap.servers=localhost:9092,localhost:9192,localhost:9292
+key.converter=org.apache.kafka.connect.json.JsonConverter
+value.converter=org.apache.kafka.connect.json.JsonConverter
+key.converter.schemas.enable=true
+value.converter.schemas.enable=true
+offset.storage.file.filename=./connect/offsets
+offset.flush.interval.ms=10000
+plugin.path=./connect/plugins

+ 11 - 0
code/lab/postgres-source-connector.properties

@@ -0,0 +1,11 @@
+name=source-postgresql
+connector.class=io.confluent.connect.jdbc.JdbcSourceConnector
+tasks.max=1
+connection.url=jdbc:postgresql://localhost:5432/eventdata
+connection.user=foo
+connection.password=bar
+schema.pattern=public
+table.whitelist=users
+mode=incrementing
+incrementing.column.name=id
+topic.prefix=event-data-