https://docs.wso2.com/display/esbconnectors/configuring+kafka_2.12-0.11.0.0+operationshttps用法：/docs.wso2.com/display/esbconnectors/configuring+kafka+inbound+operionshttps://docs.wso2.com/display/esbconnectors/kafka_2.12-0.11.0.0+connector+and+inbound+endpoint
没有类似于上述文档链接之一中提到的目录结构：
要配置kafka入站端点，请将以下客户机库从/lib目录复制到/repository/components/lib目录。
我在管理控制台上使用ei611配置了kafka inboundendpoint，并在日志中收到此错误：
org.apache.kafka.common.kafkaexception:加载zookeeper jaas登录上下文“client”时发生异常。。。。。。引起原因：java.lang.securityexception:java.io.ioexception:c:\wso2ei~1.1\bin..\repository\conf\identity\jaas.conf（无此文件或目录）
或者，我通过工具开发了一个入站端点并部署了car文件，得到以下错误：
[2017-10-20 18:15:11138][]错误-KafkaplingConsumer创建kafka consumer connector时出错[2017-10-20 18:15:13133][]信息-kafkamessagelistener创建kafka consumer connector[2017-10-20 18:15:13,134][]错误-创建kafka使用者连接器时发生kafkamessagelistener错误。要求失败：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。scala:153)在kafka.consumer.consumerconfig。scala:110)在org.wso2.carbon.inbound.endpoint.protocol.kafka.kafkamessagelistener.createkafkaconsumerconnector（kafkamessagelistener。java:56)在org.wso2.carbon.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（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（taskquartzjobadapter。java:67)在org.quartz.core.jobrunshell.run（jobrunshell。java:213)在java.util.concurrent.executors$runnableadapter.call（executors。java:511)在java.util.concurrent.futuretask.run（futuretask。java:266)位于java.util.concurrent.threadpoolexecutor.runworker（threadpoolexecutor。java:1149)在java.util.concurrent.threadpoolexecutor$worker.run（threadpoolexecutor。java:624)在java.lang.thread.run（线程。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>