Я устанавливаю соединение между Kafka (kafka_2.11-0.10.0.0) и OSB 12c (12.2.1.2) для приема сообщений на OSB от kafka.
Я выполнил необходимые шаги для установки Kafka Transport в OSB, и это успешно работает, но когда я пытаюсь использовать сообщения от Kafka, я получаю сообщение об ошибке:
com.bea.wli.sb.transports.TransportException: org.apache.kafka.common.KafkaException: Не удалось создать потребителя kafka в oracle.ateam.sb.transports.kafka.KafkaEndpoint.start (KafkaEndpoint.java:505) в Oracle.ateam.sb.transports.kafka.KafkaTransportProvider $ EndpointsStartupTask.run (KafkaTransportProvider.java:399) в java.util.TimerThread.mainLoop (Timer.java:555) в java.util.TimerThread.rava (50).Вызвано: org.apache.kafka.common.KafkaException: Не удалось создать потребителя kafka в org.apache.kafka.clients.consumer.KafkaConsumer. (KafkaConsumer.java:702) в org.apache.kafka.clients.consumer.KafkaCuons. (KafkaConsumer.java:587) в org.apache.kafka.clients.consumer.KafkaConsumer. (KafkaConsumer.java:569) в oracle.ateam.sb.transports.kafka.KafkaEndpoint $ InternalConsumer. (KafkaEndpoint.java:568) в oracle.ateam.sb.transports.kafka.KafkaEndpoint.start (KafkaEndpoint.java:480) ... еще 3 причины: org.apache.kafka.common.KafkaException: java.lang.IllegalArgumentException: не было зарегистрировано ни одной конфигурации, которая могла бы обрабатывать конфигурацию с именем KafkaClient на org.apache.kafka.common.network.SaslChannelBuilder.configure (SaslChannelBuilder.java:86) на org.apache.kafka.common.network.Chanreateu(ChannelBuilders.java:70) в org.apache.kafka.clients.ClientUtils.createChannelBuilder (ClientUtils.java:83) в org.apache.kafka.clients.consumer.KafkaConsumer. (KafkaConsumer.java:623 ... 7 ...)подробнее
Я пытался создать новую тему для чтения сообщений оттуда, но она все еще не работает.
конфигурация в OSB:
Transport:
Protocol : Kafka
endpoint URI: http://localhost:2181