OrcHome OrcHome
OrcHome个人中心.
小蕊 修改资料 更换头像
关注(0) 粉丝(0) 积分(0)
关注

暂无关注.....

粉丝

暂无粉丝.....


回复 小蕊 kafka使用kerberos报错,求助 中:
您好,我想问一下,那个在

kafka_server_jaas.conf 中 您只配置了 zk

的client端,请问一下zk的server端需要配置吗,需要的话一般在哪里配置.....叨扰了
20天前
发表了 kafka集群崩溃,报错Caused by: java.io.IOException: No space left on device

3月前
发表了 一直报Topic metadata fetch included errors: {streams-wordcount-processor-Counts-changelog=LEADER_NOT_AVAILABLE}

5月前
发表了 求助,报The group member's supported protocols are incompatible with those of existing members.?

5月前
小蕊 回复 半兽人 求助Exception in thread "StreamThread-1" org.apache.kafka.streams.errors.StreamsException: Extracted timestamp value is negative, which is not allowed.? 中:
对的,是这个问题,设置一下就好啦,感谢~!
5月前
发表了 求助Exception in thread "StreamThread-1" org.apache.kafka.streams.errors.StreamsException: Extracted timestamp value is negative, which is not allowed.?

5月前
一丨一丶丶丶 回复 小蕊 kafka使用kerberos报错,求助 中:
org.apache.zookeeper.KeeperException$AuthFailedException: KeeperErrorCode = AuthFailed for /consumers
已经替换了JCE文件,老提示这个报错,不知道哪一步出了问题

5月前
小蕊 回复 一丨一丶丶丶 kafka使用kerberos报错,求助 中:
恩,要替换
5月前
一丨一丶丶丶 回复 小蕊 kafka使用kerberos报错,求助 中:
1.8的JDK要换成1.8的JCE策略文件吗?
5月前
发表了 ElasticSearch中根据查询结果删除数据(delete by query)

6月前
发表了 kafka消费时候,报Commit cannot be completed since the group has already rebalanced and assigned the partitions to another member. T

6月前
漂泊的美好 回复 小蕊 用kafka命令发送消息时候,一直报WARN Error while fetching metadata with correlation id 0 : {test=UNKNOWN_TOPIC_OR_PARTITION}? 中:
这个topic可能是没有leader,我曾经遇到过这个问题。
7月前
发表了 启动kafka时候,报java.net.bindException: cannot assign requested address错误?

7月前
发表了 mac系统升级后,git报xcrun: error: invalid active developer path (/Library/Developer/CommandLineTools), missing xcrun at: /Librar

7月前
小蕊 回复 半兽人 kafka启动报 java.lang.ExceptionInInitializerError at kafka.network.RequestChannel$Request. 有遇到的吗? 中:
感谢~!是因为host没配置,还有这么一大坑!!!

7月前
小蕊 回复 半兽人 用kafka命令发送消息时候,一直报WARN Error while fetching metadata with correlation id 0 : {test=UNKNOWN_TOPIC_OR_PARTITION}? 中:
谢谢,是由于主题没创建导致的,生成是禁止自动创建的。我用命令就好啦
7月前
发表了 用kafka命令发送消息时候,一直报WARN Error while fetching metadata with correlation id 0 : {test=UNKNOWN_TOPIC_OR_PARTITION}?

7月前
发表了 kafka启动报 java.lang.ExceptionInInitializerError at kafka.network.RequestChannel$Request. 有遇到的吗?

7月前
发表了 kafka出现了大量的 kafka.common.NotLeaderForPartitionException

8月前
发表了 Redis读写分离有必要吗

8月前
发表了 Redis数据过期

8月前
发表了 Redis中复制机制

8月前
漂泊的美好 回复 小蕊 kafka使用kerberos报错,求助 中:
您好。我最近在kerberos上遇到点问题,想请教你。501616942可否加我QQ细聊下。真的被kerberos弄伤了,十分想有个人教教我。
9月前
漂泊的美好 回复 小蕊 kafka使用kerberos报错,求助 中:
请问,要创建什么账户?还有kafka官网上,对于kafka客户端的配置是什么意思?
9月前
小蕊 回复 traveling kafka所在服务器的JDK 与客户端的JDK 需要一致么? 中:
那你的客户端就不能使用10.0.0的了,只能用0.8以内的。kafka服务器可以用10.0.0的。

9月前
地中海的蓝 回复 小蕊 关于kafka中文消息显示乱码问题 中:
应该不是工具的问题,我的crt设置的就是utf-8,其他都可以正常显示中文的。
9月前
小蕊 关于kafka中文消息显示乱码问题 发表评论:
这个不是配置的问题,是你工具的问题。如(sercureCRT,改成UTF-8即可)

9月前
小蕊 回复 一叶知秋 kafka使用kerberos报错,求助 中:
是principal的。不是liunx的。

9月前
一叶知秋 回复 小蕊 kafka使用kerberos报错,求助 中:
好的,那我再试下,另外还有个问题要麻烦你,官网中讲到的ACL中的User指的是我们linux操作系统中的系统用户还是类似kafka/test1@HADOOP.COM这个principal 中的kafka用户,这个概念官网我没太看明白,多谢了!
9月前
小蕊 回复 一叶知秋 kafka使用kerberos报错,求助 中:
客气了,你要在找一台用不同的User去做测试,我的配置 其实和网站上一样的,没有特别的哦。

9月前
一叶知秋 回复 小蕊 kafka使用kerberos报错,求助 中:
非常感谢你的回复,这个问题困扰我好久了,我kafka中server.properties的配置是这样:
zookeeper.set.acl=true


############################ sasl plain ##############################
listeners=SASL_PLAINTEXT://test1:9092
security.inter.broker.protocol=SASL_PLAINTEXT
sasl.mechanism.inter.broker.protocol=GSSAPI
sasl.enabled.mechanisms=GSSAPI
sasl.kerberos.service.name=kafka
zookeeper.sasl.client=zkcli
authorizer.class.name=kafka.security.auth.SimpleAclAuthorizer
super.users=User:kafka
然后,我确实是只在一台服务器上做的验证,kafka的server和consumer以及producer也都是在KDC这台机器上启动执行的,请问,是不是这样的,我在test1这台机器上启动kafka的server,同时配置好kerberos认证,我设置ACL中的IP和用户都是test2这台机器上的,然后在test2上执行consumer吗,如果方便的话,能不能麻烦你把你配置kafka 安全认证的文档发给我一份了,非常感谢,398939172@qq.com


9月前
小蕊 回复 一叶知秋 kafka使用kerberos报错,求助 中:
成功了,对User和IP的控制权限没起作用,你可以看下是否相关的机制没有启用呢? http://orchome.com/185
确保你的consumer所使用的jvm环境和服务器不是同一个(因为jvm你不是添加了kerberos认证嘛,所以你已经有权限了)

9月前
一叶知秋 回复 小蕊 kafka使用kerberos报错,求助 中:
请问你使用kerberos/sasl设置kafka的安全机制成功了吗?我上面的问题现在解决了,有个新问题,安装官网关于kafka ACL的相关设置,配置好以后,创建的Topic,发现相关权限没起作用 ,对User和IP的设置,没有用,通过控制台的consumer来进行消费的,还望指教!多谢!
9月前
小蕊 回复 一叶知秋 kafka使用kerberos报错,求助 中:
你可以看下kerberos相关的日志,看看是否有账户没有创建,你要创建这些用户

9月前
发表了 kafka使用kerberos报错,求助

10月前
发表了 Kafka启动自带的zookeeper时候 报 error: could not find class org.apache.zookeeper.server.quorum.quorumpeermain

11月前
发表了 查看偏移量,报 WARN WARNING: ConsumerOffsetChecker is deprecated and will be dropped in releases following 0.9.0. Use ConsumerGroupCommand instead.

1年前
发表了 kafka启动后,关掉控台后,集群就挂了

1年前
发表了 Gradle修改本地仓库的位置

1年前
发表了 gradle修改Maven地址

1年前

回复 小蕊 kafka使用kerberos报错,求助 评论:
您好,我想问一下,那个在

kafka_server_jaas.conf 中 您只配置了 zk

的client端,请问一下zk的server端需要配置吗,需要的话一般在哪里配置.....叨扰了
20天前
小蕊 回复 半兽人 求助Exception in thread "StreamThread-1" org.apache.kafka.streams.errors.StreamsException: Extracted timestamp value is negative, which is not allowed.? 评论:
对的,是这个问题,设置一下就好啦,感谢~!
5月前
一丨一丶丶丶 回复 小蕊 kafka使用kerberos报错,求助 评论:
org.apache.zookeeper.KeeperException$AuthFailedException: KeeperErrorCode = AuthFailed for /consumers
已经替换了JCE文件,老提示这个报错,不知道哪一步出了问题

5月前
小蕊 回复 一丨一丶丶丶 kafka使用kerberos报错,求助 评论:
恩,要替换
5月前
一丨一丶丶丶 回复 小蕊 kafka使用kerberos报错,求助 评论:
1.8的JDK要换成1.8的JCE策略文件吗?
5月前
漂泊的美好 回复 小蕊 用kafka命令发送消息时候,一直报WARN Error while fetching metadata with correlation id 0 : {test=UNKNOWN_TOPIC_OR_PARTITION}? 评论:
这个topic可能是没有leader,我曾经遇到过这个问题。
7月前
小蕊 回复 半兽人 kafka启动报 java.lang.ExceptionInInitializerError at kafka.network.RequestChannel$Request. 有遇到的吗? 评论:
感谢~!是因为host没配置,还有这么一大坑!!!

7月前
小蕊 回复 半兽人 用kafka命令发送消息时候,一直报WARN Error while fetching metadata with correlation id 0 : {test=UNKNOWN_TOPIC_OR_PARTITION}? 评论:
谢谢,是由于主题没创建导致的,生成是禁止自动创建的。我用命令就好啦
7月前
漂泊的美好 回复 小蕊 kafka使用kerberos报错,求助 评论:
您好。我最近在kerberos上遇到点问题,想请教你。501616942可否加我QQ细聊下。真的被kerberos弄伤了,十分想有个人教教我。
9月前
漂泊的美好 回复 小蕊 kafka使用kerberos报错,求助 评论:
请问,要创建什么账户?还有kafka官网上,对于kafka客户端的配置是什么意思?
9月前
小蕊 回复 traveling kafka所在服务器的JDK 与客户端的JDK 需要一致么? 评论:
那你的客户端就不能使用10.0.0的了,只能用0.8以内的。kafka服务器可以用10.0.0的。

9月前
地中海的蓝 回复 小蕊 关于kafka中文消息显示乱码问题 评论:
应该不是工具的问题,我的crt设置的就是utf-8,其他都可以正常显示中文的。
9月前
小蕊 关于kafka中文消息显示乱码问题 发表评论:
这个不是配置的问题,是你工具的问题。如(sercureCRT,改成UTF-8即可)

9月前
小蕊 回复 一叶知秋 kafka使用kerberos报错,求助 评论:
是principal的。不是liunx的。

9月前
一叶知秋 回复 小蕊 kafka使用kerberos报错,求助 评论:
好的,那我再试下,另外还有个问题要麻烦你,官网中讲到的ACL中的User指的是我们linux操作系统中的系统用户还是类似kafka/test1@HADOOP.COM这个principal 中的kafka用户,这个概念官网我没太看明白,多谢了!
9月前
小蕊 回复 一叶知秋 kafka使用kerberos报错,求助 评论:
客气了,你要在找一台用不同的User去做测试,我的配置 其实和网站上一样的,没有特别的哦。

9月前
一叶知秋 回复 小蕊 kafka使用kerberos报错,求助 评论:
非常感谢你的回复,这个问题困扰我好久了,我kafka中server.properties的配置是这样:
zookeeper.set.acl=true


############################ sasl plain ##############################
listeners=SASL_PLAINTEXT://test1:9092
security.inter.broker.protocol=SASL_PLAINTEXT
sasl.mechanism.inter.broker.protocol=GSSAPI
sasl.enabled.mechanisms=GSSAPI
sasl.kerberos.service.name=kafka
zookeeper.sasl.client=zkcli
authorizer.class.name=kafka.security.auth.SimpleAclAuthorizer
super.users=User:kafka
然后,我确实是只在一台服务器上做的验证,kafka的server和consumer以及producer也都是在KDC这台机器上启动执行的,请问,是不是这样的,我在test1这台机器上启动kafka的server,同时配置好kerberos认证,我设置ACL中的IP和用户都是test2这台机器上的,然后在test2上执行consumer吗,如果方便的话,能不能麻烦你把你配置kafka 安全认证的文档发给我一份了,非常感谢,398939172@qq.com


9月前
小蕊 回复 一叶知秋 kafka使用kerberos报错,求助 评论:
成功了,对User和IP的控制权限没起作用,你可以看下是否相关的机制没有启用呢? http://orchome.com/185
确保你的consumer所使用的jvm环境和服务器不是同一个(因为jvm你不是添加了kerberos认证嘛,所以你已经有权限了)

9月前
一叶知秋 回复 小蕊 kafka使用kerberos报错,求助 评论:
请问你使用kerberos/sasl设置kafka的安全机制成功了吗?我上面的问题现在解决了,有个新问题,安装官网关于kafka ACL的相关设置,配置好以后,创建的Topic,发现相关权限没起作用 ,对User和IP的设置,没有用,通过控制台的consumer来进行消费的,还望指教!多谢!
9月前
小蕊 回复 一叶知秋 kafka使用kerberos报错,求助 评论:
你可以看下kerberos相关的日志,看看是否有账户没有创建,你要创建这些用户

9月前

发表了 kafka集群崩溃,报错Caused by: java.io.IOException: No space left on device

3月前
发表了 一直报Topic metadata fetch included errors: {streams-wordcount-processor-Counts-changelog=LEADER_NOT_AVAILABLE}

5月前
发表了 求助,报The group member's supported protocols are incompatible with those of existing members.?

5月前
发表了 求助Exception in thread "StreamThread-1" org.apache.kafka.streams.errors.StreamsException: Extracted timestamp value is negative, which is not allowed.?

5月前
发表了 ElasticSearch中根据查询结果删除数据(delete by query)

6月前
发表了 kafka消费时候,报Commit cannot be completed since the group has already rebalanced and assigned the partitions to another member. T

6月前
发表了 启动kafka时候,报java.net.bindException: cannot assign requested address错误?

7月前
发表了 mac系统升级后,git报xcrun: error: invalid active developer path (/Library/Developer/CommandLineTools), missing xcrun at: /Librar

7月前
发表了 用kafka命令发送消息时候,一直报WARN Error while fetching metadata with correlation id 0 : {test=UNKNOWN_TOPIC_OR_PARTITION}?

7月前
发表了 kafka启动报 java.lang.ExceptionInInitializerError at kafka.network.RequestChannel$Request. 有遇到的吗?

7月前
发表了 kafka出现了大量的 kafka.common.NotLeaderForPartitionException

8月前
发表了 Redis读写分离有必要吗

8月前
发表了 Redis数据过期

8月前
发表了 Redis中复制机制

8月前
发表了 kafka使用kerberos报错,求助

10月前
发表了 Kafka启动自带的zookeeper时候 报 error: could not find class org.apache.zookeeper.server.quorum.quorumpeermain

11月前
发表了 查看偏移量,报 WARN WARNING: ConsumerOffsetChecker is deprecated and will be dropped in releases following 0.9.0. Use ConsumerGroupCommand instead.

1年前
发表了 kafka启动后,关掉控台后,集群就挂了

1年前
发表了 Gradle修改本地仓库的位置

1年前
发表了 gradle修改Maven地址

1年前