2016-08-05 1 views
-1

내가 아래의 코드와 내 자신의 프로그램에 사육사의 오프셋 (offset) 업데이트 상쇄 :이 프로그램은 오류없이 실행특수 문자 업데이트 한 후 사육사는

val zkClient= new ZkClient(zookeeperConnect) 

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

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

,하지만 난 사육사 경로에 액세스 할 때 :

/소비자/testgroup0/오프셋/tests0/0 "

다음과 같이 오프셋 값 전에 일부 특수 문자가

, 왜 그런 일이 일어나고 그것을 고치는 법? 고마워요!

special chars in zookeeper

enter image description here

답변

0

나는 카프카 0.8.2 스칼라 2.10.1, JDK 1.7

로 프로그램을 컴파일 나는 카프카 0.9.0 스칼라 2.11.7과 함께 프로그램을 실행 , 쥐르 1.8, 사육사 3.4.6