WSO2 EI611 Kafka connecteur entrant erreur Endpoint avec la RCA et la console

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

Il n'y a pas de structure de répertoire comme celui mentionné dans l'un des liens de la documentation ci-dessus:

Pour configurer le noeud final entrant Kafka , copiez les bibliothèques client suivantes du répertoire/lib dans le répertoire /repository/components/lib.

configuré à Kafka InboundEndpoint avec EI611 sur la console de gestion et a reçu cette erreur dans les journaux:

org.apache.kafka.common.KafkaException: Exception lors du chargement Zookeeper contexte de connexion JAAS 'client'. ..... Causé par: java.lang.SecurityException: java.io.IOException: C: \ WSO2EI ~ 1.1 \ bin .. \ repository \ conf \ identité \ jaas.conf (Pas de tel fichier ou répertoire)

Sinon, je mis au point un point final entrant de l'outillage et Déployez le fichier CAR, je reçois l'erreur suivante:

[20/10/2017 18: 15: 11138] [] ERREUR - Erreur dans KAFKAPollingConsumer Création Kafka Connecteur du consommateur [2017-10-20 18: 15: 13,133] [] INFO - KAFKAMessageListener Création de connecteur Kafka Consumer ... [2017-10-20 18: 15: 13,134] [] ERREUR - KAFKAMessageListener Erreur lors de la création de Kafka Échec du connecteur du consommateur: socket.timeout.ms doit toujours être être au moins fetch.wait.max.ms pour éviter des délais d'attente de socket inutiles java.lang.IllegalArgumentException: l'exigence a échoué: socket.timeout.ms doit toujours être au moins fetch.wait.max.ms à éviter les délais d'attente inutiles socket à 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 (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) à l'org. wso2.carbon.ntask.core.impl.TaskQuartzJobAdapter.execute (TaskQuartzJobAdapter.java:67) à org.quartz.core.JobRunShell.run (JobRunShell.java:213) à java.util.concurrent.Executors $ RunnableAdapter. appelez (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) 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

J'espère que la documentation ci-dessus est écrit sur la base du WSO2 ESB. Si vous utilisez EI, copiez toutes les bibliothèques tierces pertinentes dans/lib. S'il vous plaît ajouter le Jaas.conf [1] fichier dans le répertoire (/ repository/conf/identité /)

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