kafka 첫 번째 구현 - 생산자 오류

apache-kafka 구현을 위해 빠른 시작에서 샘플 코드를 사용하고 있습니다. 생성kafka 첫 번째 구현 - 생산자 오류

try { 

     producer = new kafka.javaapi.producer.Producer<String, String>(
     new ProducerConfig(props)); 
    } catch (Exception e) { 
     System.out.println("PRODUCER Error"+ e); 
    }

오류 : 모든 응답에 대한

Exception in thread "main" java.lang.VerifyError: class scala.Tuple2$mcLL$sp overrides 
    final method _1.()Ljava/lang/Object; 
at java.lang.ClassLoader.defineClass1(Native Method) 
at java.lang.ClassLoader.defineClass(ClassLoader.java:791) 
at java.security.SecureClassLoader.defineClass(SecureClassLoader.java:142) 
at java.net.URLClassLoader.defineClass(URLClassLoader.java:449) 
at java.net.URLClassLoader.access$100(URLClassLoader.java:71) 
at java.net.URLClassLoader$1.run(URLClassLoader.java:361) 
at java.net.URLClassLoader$1.run(URLClassLoader.java:355) 
at java.security.AccessController.doPrivileged(Native Method) 
at java.net.URLClassLoader.findClass(URLClassLoader.java:354) 
at java.lang.ClassLoader.loadClass(ClassLoader.java:423) 
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:308) 
at java.lang.ClassLoader.loadClass(ClassLoader.java:356) 
at kafka.producer.ProducerConfig.<init>(ProducerConfig.scala:56) 
at com.datacollector.Producer.<init>(Producer.java:50) 
at com.datacollector.MainProducerRawData.main(MainProducerRawData.java:117)

출처

2014-05-20 vbNewbie

감사 오류에 대한 웹에 많은 세부 사항을 새로운 생산을 만들고하지 않을 때 나는 다음과 같은 오류로 실행하십시오. 나는 마침내 그것을 알아 냈다. 그들이 맞지 않는 것처럼 scala와 kafka 라이브러리의 업데이트 된 버전을 실행해야합니다.

출처

2014-05-21 20:34:02 vbNewbie

kafka 첫 번째 구현 - 생산자 오류

답변

관련 문제