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> <Error> <oracle.ateam.sb.transports.kafka> <OSB-000000> <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)