auto.offset.reset=smallest

client.id=qas

kafka_config=" --config-schema kafka_config0110  --username 数据库用户名 --password 密码 "

cd /opt/vertica/packages/kafka/bin
./vkconfig scheduler --add --frame-duration "0:0:05" --brokers  IP端口1,IP端口2 --operator 用户 --resource-pool kafka_default_pool

./vkconfig kafka-cluster --add ${kafka_config} --brokers IP端口1,IP端口2 --cluster kafka

./vkconfig topic --add --topic topic名 --cluster kafka --target 存放表名 --target-columns 列名 ${kafka_config} --rejection-table 拒绝数据表名  --parser fjsonparser --conf config.properties --start-offset 7000

nohup ./vkconfig launch ${kafka_config}