Skip to content

Releases: wallstreetcn/nortrom

v0.0.1

13 Mar 05:33
Compare
Choose a tag to compare

Flume jdbc sink.

agent1.sinks.k1.type = com.wallstreetcn.flume.JDBCSink
agent1.sinks.k1.driver = com.mysql.jdbc.Driver
agent1.sinks.k1.connectionURL = jdbc:mysql://mysql-address/test
agent1.sinks.k1.mapping = field1:body.field1,field2:header.field2
agent1.sinks.k1.user = root
agent1.sinks.k1.password = root
agent1.sinks.k1.table = test
agent1.sinks.k1.sqlDialect = MySQL