https://docs.wso2.com/display/ESBCONNECTORS/Configuring+Kafka_2.12-0.111.0.0+操作https://docs.wso2.com/display/ESBCONNECTORS/Configuring+Kafka+入站+运营https://docs.wso2.com/display/ESBCONNECTORS/Kafka_2.12-0.11.0.0+连接器+和+入站+端点
没有像上面文档链接中提到的目录结构：
要配置Kafka入站端点，请复制以下客户端库从/lib目录到/repository/components/lib目录。
我在管理控制台上用EI611配置了Kafka InboundEndpoint，并在日志中收到了此错误：
org.apache.kafka.comm.KafkaException：加载时出现异常Zookeeper JAAS登录上下文"客户端"。。。。。。原因：java.lang.SecurityException：java.io.IOException：C： \WSO2EI~1.1\bin..\repository\conf\identity\jaas.conf(没有这样的文件或目录)
或者，我从工具中开发了一个入站端点并部署了CAR文件，我得到了以下错误：
〔2017-10-20 18:15:11138〕〔〕错误-KAFKAPollingConsumer错误创建Kafka消费者连接器〔2017-10-20 18:15:13133〕〔〕INFO-KAFKAMessageListener正在创建Kafka使用者连接器。。。【2017-10-2018:15:13134][]错误-KAFKAMessageListener创建Kafka时出错使用者连接器请求失败：socket.timeout.ms应始终至少为fetch.wait.max.ms，以防止不必要的套接字超时java.lang.IollegalArgumentException：需求失败：socket.timeout.ms应始终至少为fetch.wait.max.ms防止不必要的套接字超时在scala。预定义$.request(预定义标量：277)位于kafka.consumer.ConsumerConfig.(ConsumerConfig.scala:153)位于kafka.consumer.ConsumerConfig.(ConsumerConfig.scala:110)网址：org.wso2.carbon.inbound.endpoint.procol.kafka.KAFKAMessageListener.createKafkaConsumerConnector(KAFKAMMessageListener.java:56)网址：org.wso2.carbon.inbound.endpoint.procol.kafka.KAFKAPollingConsumer.poll(KAFKAPolingConsumer.java:145)网址：org.wso2.carbon.inbound.endpoint.procol.kafka.KAFKAPollingConsumer.execute(KAFKAPolingConsumer.java:116)网址：org.wso2.carbon.inbound.endpoint.procol.kafka.KAFKATask.taskExecute(KAFKATask.java:48)网址：org.wso2.carbon.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(TaskQuartzJob Adapter.java:67)网址：org.quarter.core.JobRunShell.run(JobRunShelr.java:213)位于java.util.concurrent.Executors$RunnableAdapter.call(Executitors.java:511)位于java.util.concurrent.FFutureTask.run(FutureTask.java:266)位于java.util.concurrent.ThreadPoolExecutiator.runWorker(ThreadPoolExecutiator.java:1149)位于java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)在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>
我希望上面的文档是基于WSO2ESB编写的。如果您正在使用EI，请将所有相关的第三方库复制到/lib。请将jaas.conf[1]文件添加到目录(/repository/conf/identity/)
[1]https://docs.oracle.com/javase/7/docs/jre/api/security/jaas/spec/com/sun/security/auth/module/Krb5LoginModule.html