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

叶熠 发表于: 2018-01-20   最后更新时间: 2018-01-21  
  •   26 订阅,511 游览

我自己的环境是之前安装了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






发表于: 4月前   最后更新时间: 4月前   游览量:511
上一条: kafka新建topic无法使用新的group消费
下一条: KafkaOffsetMonitor线上环境监控不到消费组 测试环境可以。

评论…


  • 报什么错么
  • 评论…
    • in this conversation
      提问