Ошибка входящей конечной точки коннектора WSO2 EI611 Kafka с CAR и консолью
https://docs.wso2.com/display/ESBCONNECTORS/Configuring+Kafka_2.12-0.11.0.0+Operations https://docs.wso2.com/display/ESBCONNECTORS/Configuring+Kafka+Inbound+Operations https://docs.wso2.com/display/ESBCONNECTORS/Kafka_2.12-0.11.0.0+Connector+and+Inbound+Endpoint
Там нет структуры каталогов, подобной той, что упомянута в одной из ссылок на документацию:
Чтобы настроить входящую конечную точку Kafka, скопируйте следующие клиентские библиотеки из каталога /lib в каталог /repository/components/lib.
Я настроил Kafka InboundEndpoint с EI611 на консоли управления и получил эту ошибку в журналах:
org.apache.kafka.common.KafkaException: исключение при загрузке контекста входа в систему JAAS Zookeeper "Клиент"...... Причина: java.lang.SecurityException: java.io.IOException: C:\WSO2EI~1.1\bin..\repository\conf\identity\jaas.conf (нет такого файла или каталога)
В качестве альтернативы, я разработал конечную точку Inbound из инструментария и развернул файл CAR, я получил следующую ошибку:
[2017-10-20 18: 15: 11,138] [] ОШИБКА - Ошибка KAFKAPollingConsumer при создании коннектора потребителя Kafka [2017-10-20 18:15:13,133] [] ИНФОРМАЦИЯ - KAFKAMessageListener Создание коннектора потребителя Kafka... [2017-10-20 18:15:13,134] [] ОШИБКА - Ошибка KAFKAMessageListener при создании Consumer Connector.Fequirement для Kafka завершилась неудачно: socket.timeout.ms всегда должен быть как минимум fetch.wait.max.ms для предотвращения ненужных тайм-аутов сокетов java.lang.IllegalArgumentException: требование не выполнено: socket.timeout.ms всегда должен быть как минимум fetch.wait.max.ms для предотвращения ненужных тайм-аутов сокетов в scala.Predef$.require(Predef.scala:277) в kafka.consumer.ConsumerConfig.(ConsumerConfig).scala:153) по адресу kafka.consumer.ConsumerConfig.(ConsumerConfig.scala:110) по адресу org.wso2.carbon.inbound.endpoint.protocol.kafka.KAFKAMessageListener.createKafkaConsumerConnector(KAFKAMessageLso.garecarjscar)..inbound.endpoint.protocol.kafka.KAFKAPollingConsumer.poll(KAFKAPollingConsumer.java:145) в org.wso2.carbon.inbound.endpoint.protocol.kafka.KAFKAPollingConsumer.execute(KAFKAPollingConsumer.java:116) в org.wso2.carbon.inbound.endpoint.protocol.kafka.KAFKATask.taskExecute(KAFKATascar.bon.java:48).inbound.endpoint.common.InboundTask.execute(InboundTask.java:45) в org.wso2.carbon.mediation.ntask.NTaskAdapter.execute(NTaskAdapter.java:98) в org.wso2.carbon.ntask.core.impl.TaskQuartzJobAdapter.execute(TaskQuartzJobAdapter.java:67) в org.quartz.core.JobRunShell.run(JobRunShell.java:213) в java.util.concurrent.Executors$RunnableAdapter.call(Executors.java.5).concurrent.FutureTask.run(FutureTask.java:266) в java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) в java.util.concurrent.ThreadPoolExecutor$Worker.run6) java.lang.Thread.run(Thread.java:748)
<?xml version="1.0" encoding="UTF-8"?>
<inboundEndpoint name="KafkaReceiver" onError="ErrorKafkaSeq" protocol="kafka" sequence="InKafkaSeq" suspend="false" xmlns="http://ws.apache.org/ns/synapse">
<parameters>
<parameter name="interval">1000</parameter>
<parameter name="sequential">true</parameter>
<parameter name="coordination">true</parameter>
<parameter name="zookeeper.connect">localhost:2181</parameter>
<parameter name="group.id">sampleGroupID</parameter>
<parameter name="content.type">application/xml</parameter>
<parameter name="consumer.type">highlevel</parameter>
<parameter name="topics">sampleTopic</parameter>
<parameter name="socket.timeout.ms">0</parameter>
<parameter name="auto.commit.enable">false</parameter>
<parameter name="auto.offset.reset">smallest</parameter>
<parameter name="exclude.internal.topics">false</parameter>
<parameter name="partition.assignment.strategy">roundrobin</parameter>
<parameter name="offsets.storage">zookeeper</parameter>
<parameter name="dual.commit.enabled">false</parameter>
</parameters>
</inboundEndpoint>
1 ответ
Я надеюсь, что вышеупомянутая документация написана на основе WSO2 ESB. Если вы используете EI, пожалуйста, скопируйте все соответствующие сторонние библиотеки в / lib. Пожалуйста, добавьте файл jaas.conf[1] в каталог (/ repository / conf / identity /)