场景
某监控进程需要访问多个集群的Kafka
INFO - org.apache.kafka.common.KafkaException: Failed to construct kafka consumer
INFO - at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:765)
INFO - at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:633)
INFO - at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:615)
INFO - at com.sohu.rc.factory.KafkaServiceImpl.getLogsizeByCluster(KafkaServiceImpl.java:252)
INFO - at com.sohu.rc.service.KafkaHdfsMonitorServiceImpl.getAllTopicLogsize(KafkaHdfsMonitorServiceImpl.java:297)
INFO - at com.sohu.rc.service.KafkaHdfsMonitorServiceImpl.getHdfsKafkaMonitor(KafkaHdfsMonitorServiceImpl.java:175)
INFO - at com.sohu.rc.service.KafkaHdfsMonitorService.main(KafkaHdfsMonitorService.java:17)
INFO - Caused by: java.lang.IllegalArgumentException: Could not find a 'KafkaClient' entry in the JAAS configuration. System property 'java.security.auth.login.config' is /data_b/kafka/kafka_client_jaas_usekeytab.conf
INFO - at org.apache.kafka.common.security.JaasContext.defaultContext(JaasContext.java:131)
INFO - at org.apache.kafka.common.security.JaasContext.load(JaasContext.java:96)
INFO - at org.apache.kafka.common.security.JaasContext.load(JaasContext.java:78)
INFO - at org.apache.kafka.common.network.ChannelBuilders.create(ChannelBuilders.java:100)
INFO - at org.apache.kafka.common.network.ChannelBuilders.clientChannelBuilder(ChannelBuilders.java:58)
INFO - at org.apache.kafka.clients.ClientUtils.createChannelBuilder(ClientUtils.java:88)
INFO - at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:695)
INFO - ... 6 common frames omitted
INFO - org.apache.kafka.common.KafkaException: Failed to construct kafka consumer
INFO - at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:765)
INFO - at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:633)
INFO - at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:615)
INFO - at com.sohu.rc.factory.KafkaServiceImpl.getLogsizeByCluster(KafkaServiceImpl.java:252)
INFO - at com.sohu.rc.service.KafkaHdfsMonitorServiceImpl.getAllTopicLogsize(KafkaHdfsMonitorServiceImpl.java:297)
INFO - at com.sohu.rc.service.KafkaHdfsMonitorServiceImpl.getHdfsKafkaMonitor(KafkaHdfsMonitorServiceImpl.java:175)
INFO - at com.sohu.rc.service.KafkaHdfsMonitorService.main(KafkaHdfsMonitorService.java:17)
INFO - Caused by: java.lang.IllegalArgumentException: Could not find a 'KafkaClient' entry in the JAAS configuration. System property 'java.security.auth.login.config' is /data_b/kafka/kafka_client_jaas_usekeytab.conf
INFO - at org.apache.kafka.common.security.JaasContext.defaultContext(JaasContext.java:131)
INFO - at org.apache.kafka.common.security.JaasContext.load(JaasContext.java:96)
INFO - at org.apache.kafka.common.security.JaasContext.load(JaasContext.java:78)
INFO - at org.apache.kafka.common.network.ChannelBuilders.create(ChannelBuilders.java:100)
INFO - at org.apache.kafka.common.network.ChannelBuilders.clientChannelBuilder(ChannelBuilders.java:58)
INFO - at org.apache.kafka.clients.ClientUtils.createChannelBuilder(ClientUtils.java:88)
INFO - at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:695)
INFO - ... 6 moreINFO - org.apache.ka
