Missing required configuration "offset.storage.file.filename" ??这整个啥子好勒?

flink2c 发布于 03/24 14:56
阅读 48
收藏 0

.kafka.common.config.ConfigException: Missing required configuration "offset.storage.file.filename" which has no default value.
        at org.apache.kafka.common.config.ConfigDef.parseValue(ConfigDef.java:478)
        at org.apache.kafka.common.config.ConfigDef.parse(ConfigDef.java:468)
        at org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:108)
        at org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:129)
        at org.apache.kafka.connect.runtime.WorkerConfig.<init>(WorkerConfig.java:452)
        at org.apache.kafka.connect.runtime.standalone.StandaloneConfig.<init>(StandaloneConfig.java:42)
        at org.apache.kafka.connect.cli.ConnectStandalone.main(ConnectStandalone.java:81)
 

加载中
OSCHINA
登录后可查看更多优质内容
返回顶部
顶部