與CAR＆控制檯WSO2 EI611卡夫卡連接器的入站端點錯誤

Question

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

有沒有目錄結構就像在上面的文檔鏈接一個提到的：

要配置卡夫卡入站端點，將以下客戶機 庫從/ lib目錄複製到 /repository/components/lib目錄。

我配置卡夫卡InboundEndpoint與EI611管理控制檯和收到此錯誤日誌中：加載 動物園管理員JAAS登錄上下文「客戶」例外：

org.apache.kafka.common.KafkaException。由於： java.lang.SecurityException：java.io.IOException： C：\ WSO2EI〜1.1 \ bin .. \ repository \ conf \ identity \ jaas.conf（沒有這樣的文件 或目錄）

另外，我從開發工具中的入站端點和部署CAR文件，我得到以下錯誤：

[2017年10月20日18：15：11138] []錯誤 - KAFKAPollingConsumer錯誤 創建卡夫卡消費者連接器[2017年10月20日18：15：13,133] [] INFO - KAFKAMessageListener創建卡夫卡消費者連接器... [2017年10月20日 18：15：13134] []錯誤 - KAFKAMessageListener出錯創建卡夫卡 消費者Connector.requirement失敗：socket.timeout.ms始終應該至少爲fetch.wait.max.ms以防止不必要的套接字超時 java.lang.IllegalArgumentException：需求失敗： socket.timeout.ms應始終至少fetch.wait.max.ms至 防止不必要的套接字超時 at scala.Predef $ .require（Predef.scala：277） at kafka.consumer.ConsumerConfig。（ConsumerConfig。階：153） 在kafka.consumer.ConsumerConfig（ConsumerConfig.scala：110） 在org.wso2.carbon.inbound.endpoint.protocol.kafka.KAFKAMessageListener.createKafkaConsumerConnector（KAFKAMessageListener.java:56） 在org.wso2 .org.in.inbound.endpoint.protocol.kafka.KAFKAPollingConsumer.poll（KAFKAPollingConsumer.java:145） at org.wso2.carbon.inbound.endpoint.protocol.kafka.KAFKAPollingConsumer.execute（KAFKAPollingConsumer.java:116） at org .wso2.carbon.inbound.endpoint.protocol.kafka.KAFKATask.taskExecute（KAFKATask.java:48） at org.wso2.carbon.inbound.endpoint.common.InboundTask.execute（InboundTask.java:45） at org.wso2.carbon.mediation.ntask.NTaskAdapter.execute（NTaskAdapter.java:98） at org。 wso2.carbon.ntask.core.impl.TaskQuartzJobAdapter.execute（TaskQuartzJobAdapter.java:67） at org.quartz.core.JobRunShell.run（JobRunShell.java:213） at java.util.concurrent.Executors $ RunnableAdapter。在java.util中調用（Executors.java:511） at java.util.concurrent.FutureTask.run（FutureTask.java:266） at java.util.concurrent.ThreadPoolExecutor.runWorker（ThreadPoolExecutor.java:1149） 。 concurrent.ThreadPoolExecutor $ Worker.run（ThreadPoolExecutor.java:624） at 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> 

Answer 1

希望以上資料是基於WSO2 ESB寫的。如果您使用EI，請將您所有相關的第三方庫複製到/ lib。 請添加的Jaas.conf [1]文件複製到該目錄（/資料庫/ conf目錄/身份證/）

[1] https://docs.oracle.com/javase/7/docs/jre/api/security/jaas/spec/com/sun/security/auth/module/Krb5LoginModule.html