Failed to construct kafka consumer

[KarunakarTechM]

Hi

I have installed kafka in OSB 12c.

Weblogic Server Version: 12.2.1.0.0

Kafka File Used:

OSB_Domain/lib]slf4j-api-1.7.21.jar
OSB_Domain/lib]kafka-clients-0.10.1.0.jar
OSB_Domain/lib]kafka_2.11-0.10.1.0.jar
OSB_Domain/lib]metrics-core-2.2.0.jar
OSB_Domain/lib]scala-library-2.11.8.jar
OSB_Domain/lib]zkclient-0.9.jar
OSB_Domain/lib]zookeeper-3.4.8.jar

Middleware/osb/lib/transports] kafka-transport.ear
Middleware/osb/lib/transports] kafka-transport.jar

Updated Kafka Properties in
Middleware/osb/lib/osbconsoleEar/webapp/WEB-INF/lib/adflib_osb_folder.jar

Issue:

I am able to push messages to Kafka. But I am not able to consume the messages. Server health went to warning state. I am trying to restart the server. It is showing below error and I am not able to update or delete proxy services from sbconsole.

Error:
<Feb 19, 2019 1:53:32 PM EST> <oracle.ateam.sb.transports.kafka> <org.apache.kafka.common.KafkaException: Failed to construct kafka consumer>
com.bea.wli.sb.transports.TransportException: org.apache.kafka.common.KafkaException: Failed to construct kafka consumer
at oracle.ateam.sb.transports.kafka.KafkaEndpoint.start(KafkaEndpoint.java:473)
at oracle.ateam.sb.transports.kafka.KafkaTransportProvider$EndpointsStartupTask.run(KafkaTransportProvider.java:361)
at java.util.TimerThread.mainLoop(Timer.java:566)
at java.util.TimerThread.run(Timer.java:516)
Caused by: org.apache.kafka.common.KafkaException: Failed to construct kafka consumer
at org.apache.kafka.clients.consumer.KafkaConsumer.(KafkaConsumer.java:703)
at org.apache.kafka.clients.consumer.KafkaConsumer.(KafkaConsumer.java:584)
at org.apache.kafka.clients.consumer.KafkaConsumer.(KafkaConsumer.java:566)
at oracle.ateam.sb.transports.kafka.KafkaEndpoint$InternalConsumer.(KafkaEndpoint.java:532)
at oracle.ateam.sb.transports.kafka.KafkaEndpoint.start(KafkaEndpoint.java:448)
... 3 more
Caused by: org.apache.kafka.common.config.ConfigException: Invalid url in bootstrap.servers: host1:port
at org.apache.kafka.clients.ClientUtils.parseAndValidateAddresses(ClientUtils.java:46)
at org.apache.kafka.clients.consumer.KafkaConsumer.(KafkaConsumer.java:641)