Kafka issue

[gouravd_7]

Hi Team,

Everytime , I try to connect to Kafka version 0.10.0.1 am getting the below error, 

Starting job kafkatest at 15:26 23/11/2018.

[statistics] connecting to socket on port 4058
[statistics] connected
SLF4J: slf4j-api 1.6.x (or later) is incompatible with this binding.
SLF4J: Your binding is version 1.5.5 or earlier.
SLF4J: Upgrade your binding to version 1.6.x. or 2.0.x
Exception in thread "main" java.lang.NoSuchMethodError: org.slf4j.impl.StaticLoggerBinder.getSingleton()Lorg/slf4j/impl/StaticLoggerBinder;
at org.slf4j.LoggerFactory.bind(LoggerFactory.java:121)
at org.slf4j.LoggerFactory.performInitialization(LoggerFactory.java:111)
at org.slf4j.LoggerFactory.getILoggerFactory(LoggerFactory.java:268)
at org.slf4j.LoggerFactory.getLogger(LoggerFactory.java:241)
at org.slf4j.LoggerFactory.getLogger(LoggerFactory.java:254)
at org.apache.kafka.clients.consumer.KafkaConsumer.<clinit>(KafkaConsumer.java:544)
at sga_data_lake.kafkatest_0_1.kafkatest.tKafkaInput_1Process(kafkatest.java:846)
at sga_data_lake.kafkatest_0_1.kafkatest.tKafkaConnection_1Process(kafkatest.java:391)
at sga_data_lake.kafkatest_0_1.kafkatest.runJobInTOS(kafkatest.java:1297)
at sga_data_lake.kafkatest_0_1.kafkatest.main(kafkatest.java:1123)
[statistics] disconnected
[statistics] disconnected
Job kafkatest ended at 15:26 23/11/2018. [exit code=1]

Requesting you to please help me on the issue.

I belive there must be duplicate jar files of different versions which is causing this error . 

Thanks,

Gourav

[Anonymous · Accepted solution]

Hello,

Talend has added support for Kafka 0.10 as from the 6.3 version.

Could you please clarify in which Talend version/edition you are?  Did you install version slf4j-api-1.7.12.jar into your current studio? Any network issues for you when studio download jar files from nexus?

Best regards

Sabrina

[gouravd_7]

Hi Team,

I was able to fix the issue in Kafka version 0.10 

Thanks for the follow up.

Thanks & Regards,

Gourav Dubey