2016-03-24 4 views
1

Ich habe Java-Klasse implementiert Runnable und instanziierenden Kafka-Consumer in Bluemix. Diese Klasse wird unter Ausnahme ausgelöst, wenn versucht wird, KafkaConsumer zu instanziieren. Die Datei jaas.conf wird in einem freigegebenen Verzeichnis gespeichert. Das hat in den letzten 1 Monat gut funktioniert. Es begann heute, diesen Fehler zu werfen. Ich kann mich nicht daran erinnern, Änderungen an meinem Code vorgenommen zu haben. Ich benutze kafka-client 0.9.0.0. Ich habe es auch mit kafka client 0.9.0.1 mit gleichem Ergebnis versucht.Kafaka consumer init löst Ausnahme aus: Konnte keinen Eintrag 'KafkaClient' finden

org.apache.kafka.common.KafkaException: 
java.lang.IllegalArgumentException: Could not find a 
'KafkaClient' entry in `/home/vcap/app/wlp/usr/shared/config/lib 
/global/jaas.conf`. 

Die Datei Jaas.conf ist an der Stelle vorhanden es sucht und hat es folgenden Inhalt.

KafkaClient { 
    com.ibm.messagehub.login.MessageHubLoginModule required 
    serviceName="kafka" 
    username="xxxxxxx" 
    password="xxxxxxx" 
}; 

Antwort

4

Basierend auf dem Pfad von „jass.conf“ Datei, nehme ich an, dass Sie eine Freiheit App in Bluemix ausgeführt werden, wenn dies der Fall ist, dann müssen Sie sicherstellen, dass jaasLoginModule in server.xml angeben, wie folgend :

<featureManager> 
    <feature>appSecurity-2.0</feature> 
</featureManager> 

<library id="messageHubLoginLib"> 
    <fileset dir="${server.config.dir}" includes="messagehub.login-1.0.0.jar"/> 
</library> 

<jaasLoginModule id="KafkaClient" 
      className="com.ibm.messagehub.login.MessageHubLoginModule" 
      controlFlag="REQUIRED" libraryRef="messageHubLoginLib"> 
    <options serviceName="kafka" username="#USERNAME" password="#PASSWORD"/> 
</jaasLoginModule> 

<jaasLoginContextEntry id="KafkaClient" name="KafkaClient" loginModuleRef="KafkaClient" /> 

Hinweis: nur zur Klarstellung, wenn Sie mit Liberty-App in Bluemix dann wird die aktuelle JAAS-Konfiguration nicht, dass Jaas.conf-Datei. Daher muss die Konfiguration server.xml wie oben beschrieben verwendet werden.

hier ist ein link, wo Sie weitere Informationen über die Konfiguration Freiheit

+0

Vielen Dank für Ihre Eingabe gefunden. Ich werde das ausprobieren. – Madhu

Verwandte Themen