kafka 部署了kerberos之后,producer可以正常往topic里写消息,consumer无法消费消息

叶熠 发表于: 2018-01-20   最后更新时间: 2018-01-21 11:20:34   4,369 游览

我自己的环境是之前安装了CDH,在此基础上安装了kerberos,按照您的教程orchome/500,我在CDH中的Zookeeper启动了kafka,并引入了kerberos,踩了一系列的坑之后,碰到了一个很奇怪的现象,可以在producer中,向topic写,但是consumer无法消费。下面是我的几个配置:
client_jaas:

KafkaClient {
      com.sun.security.auth.module.Krb5LoginModule required
      useKeyTab=true
      storeKey=true
      keyTab="/opt/kafka/config/kafka.keytab"
      serviceName="kafka"
      principal="kafka/node2@HADOOP.COM";
  };

producer.properties
    bootstrap.servers=node2:9092
    compression.type=none
    security.protocol=SASL_PLAINTEXT
    sasl.mechanism=GSSAPI
    sasl.kerberos.service.name=kafka

consumer.properties
    zookeeper.connect=node2:2181,node3:2181,node4:2181
    zookeeper.connection.timeout.ms=6000
    security.protocol=SASL_PLAINTEXT
    sasl.mechanism=GSSAPI
    sasl.kerberos.service.name=kafka
    group.id=test-consumer-group
发表于 2018-01-20
添加评论

报什么错么

叶熠 -> 半兽人 6年前

非常神奇的是,什么报错提示都没有,全是INFO

半兽人 -> 叶熠 6年前

看看消息是不是已经成功的发送到kafka了。

叶熠 -> 半兽人 6年前

从tmp/kafka-log/test-0/000000000000.log中可以看到有数据

半兽人 -> 叶熠 6年前

你参考一下我的安装笔记:https://www.orchome.com/500

你的答案

查看kafka相关的其他问题或提一个您自己的问题