Специальных символов в зоопарке после обновления Zookeeper смещает

Question

обновляют смещение зоопарка в моей собственной программе с кодом, как показано ниже:

val zkClient= new ZkClient(zookeeperConnect) 

val zkPath = s"${zkTopicPath}/${osr.partition}" 

ZkUtils.updatePersistentPath(zkClient, zkPath,osr.untilOffset.toString) 

Программа проходила без ошибок, но когда я достигаю путь Zookeeper:

/потребители/testgroup0/смещение/tests0/0 "

есть некоторые специальные символы до значения смещения, как показано ниже, Почему это происходит и как его исправить? Большое спасибо!

enter image description here

Answer 1

Я составил программу с Кафкой 0.8.2, 2.10.1, Скале JDK 1,7

Я запускал программу с Кафкой 0.9.0, 2.11.7 лестницу , jre 1.8, zookeeper 3.4.6