我正试图将java中的一个程序移植到scala,但是,我遇到了一个错误。
我有一条线 DistributedConfig.BOOTSTRAP_SERVERS_CONFIG
.
在java中,这很好。
但是,在scala中,这会产生错误 value BOOTSTRAP_SERVERS_CONFIG is not a member of org.apache.kafka.connect.runtime.distributed.DistributedConfig
调查 DistributedConfig
班级, BOOTSTRAP_SERVERS_CONFIG
实际上不是在类中定义的,而是在 WorkerConfig
哪个 DistributedConfig
延伸。我查过了,变量是公共的。 public static final String BOOTSTRAP_SERVERS_CONFIG
是准确的定义。
1条答案
按热度按时间lp0sw83n1#
java“伪造”静态成员的继承(当您编写
DistributedConfig.BOOTSTRAP_SERVERS_CONFIG
,java编译器将其转换为WorkerConfig.BOOTSTRAP_SERVERS_CONFIG
),scala没有,因为它不适合scala的静态方法(使用伴随对象)。所以在scala中你只能使用WorkerConfig.BOOTSTRAP_SERVERS_CONFIG
.