Исключение: исключение Kafaka потребителя: Не удалось найти запись «KafkaClient»

Question

У меня есть класс java, реализующий Runnable и создающий экземпляр пользователя kafka в bluemix. Этот класс бросает ниже исключения при попытке создать экземпляр KafkaConsumer. Файл jaas.conf хранится в общей папке. Это работало отлично в течение последних 1 месяца. Сегодня он начал эту ошибку. Я не помню, чтобы вносить изменения в мой код. Я использую kafka-client 0.9.0.0. Я также пробовал с kafka client 0.9.0.1 с тем же результатом.

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`. 

Файл jaas.conf присутствует на месте, что он ищет и имеет следующие содержания в нем.

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

Answer 1

на основе пути файла «jass.conf», я полагаю, что вы используете приложение Liberty в Bluemix, если это так, то вы должны убедиться, чтобы указать jaasLoginModule в server.xml следующим образом :

<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" /> 

Примечание: только для уточнения, если вы используете приложение Liberty в Bluemix, то текущая конфигурация JAAS не использует этот файл jaas.conf. Поэтому необходимо использовать конфигурацию server.xml, как описано выше.

вот link, где вы могли бы найти более подробную информацию о том, как настроить Liberty