OrcHome OrcHome
OrcHome个人中心.
漂泊的美好 修改资料 更换头像
关注(0) 粉丝(0) 积分(0)
关注

暂无关注.....

粉丝

暂无粉丝.....


半兽人 回复 漂泊的美好 kafka启用权限后,kafka-consumer-group.sh查看消费组报错 中:
看下执行命令。
5天前
漂泊的美好 回复 半兽人 kafka启用权限后,kafka-consumer-group.sh查看消费组报错 中:
这个肯定带了。先要kerberos认证之后。才执行命令
5天前
发表了 kafka启用权限后,kafka-consumer-group.sh查看消费组报错

5天前
发表了 启用kerberos下sparkstreaming读取kafka数据问题

2月前
发表了 关于kafka0.10中consumerGroup中的一些疑惑

5月前
我是谁 回复 漂泊的美好 kafka-acl java api 使用碰到的问题 中:
你好,UserGroupInformation这个类需要引入的jar包是哪个?
7月前
我是谁 回复 漂泊的美好 用kafka命令发送消息时候,一直报WARN Error while fetching metadata with correlation id 0 : {test=UNKNOWN_TOPIC_OR_PARTITION}? 中:
你好,没有leader是什么意思?要怎么让topic产生一个leader呢?
8月前
漂泊的美好 回复 半兽人 使用camus将kafka中的数据入hive时,总有几个task失败,导致一些表入不了hive 中:
嗯,不管怎样,谢谢你给我的解决思路。
8月前
半兽人 回复 漂泊的美好 使用camus将kafka中的数据入hive时,总有几个task失败,导致一些表入不了hive 中:
目前我只遇到过一次,分享给你了,kafka新功能遇到的(如streams),有个很严重的bug现象,我在本地做测试,低版本的zookeeper第一次是ok的,但是当我重启应用就开始刷这种错,我还没有时间看源码。
8月前
漂泊的美好 回复 半兽人 使用camus将kafka中的数据入hive时,总有几个task失败,导致一些表入不了hive 中:
我也是无限刷这种错误的。但是3.4.8这个版本太高了吧,用的地方不多啊
8月前
半兽人 回复 漂泊的美好 使用camus将kafka中的数据入hive时,总有几个task失败,导致一些表入不了hive 中:
我遇到的是无限制的刷这种错误,分配不到对应分区,最后确认下来是由于zk版本过低导致。
8月前
漂泊的美好 回复 半兽人 使用camus将kafka中的数据入hive时,总有几个task失败,导致一些表入不了hive 中:
cdh集成的zookeeper,不能升。
8月前
发表了 使用camus将kafka中的数据入hive时,总有几个task失败,导致一些表入不了hive

8月前
半兽人 回复 漂泊的美好 kafka可以跨级群消费吗? 中:
没懂。
11月前
漂泊的美好 回复 半兽人 kafka可以跨级群消费吗? 中:
表达有误。其实我想问的是kafka0.10可以消费kafka0.9的数据吗?
11月前
发表了 kafka可以跨级群消费吗?

11月前
漂泊的美好 回复 半兽人 kafka-acl java api 使用碰到的问题 中:
就在刚刚,还是原来的方式可以了,太奇怪了。昨天到今天上午一直都不行。真是让人百思不得其解。
11月前
半兽人 回复 漂泊的美好 kafka-acl java api 使用碰到的问题 中:
用命令的方式,环境是否都是正常的?
如果是正常的,则需要关注环境了,是否加载到了运行中的jvm环境中,jdk的安全限制是否也替换了。

11月前
漂泊的美好 kafka-acl java api 使用碰到的问题 发表评论:
还通过下面这种方式进行kerberos认证,但还是没什么作用:
// Authenticating Kerberos principal
System.out.println("Principal Authentication: ");
final String user = "cloudera@CLOUDERA.COM";
final String keyPath = "cloudera.keytab";
UserGroupInformation.loginUserFromKeytab(user, keyPath);


11月前
发表了 kafka-acl java api 使用碰到的问题

11月前
漂泊的美好 回复 小蕊 用kafka命令发送消息时候,一直报WARN Error while fetching metadata with correlation id 0 : {test=UNKNOWN_TOPIC_OR_PARTITION}? 中:
这个topic可能是没有leader,我曾经遇到过这个问题。
11月前
无生 回复 漂泊的美好 我想用java操作topic,增删查改什么的,应该怎么做? 中:
那在企业中应用的时候,topic都是事先定义好的么?
11月前
漂泊的美好 我想用java操作topic,增删查改什么的,应该怎么做? 发表评论:
没做过这个,不过给你个线索,找这个类kafka.admin.TopicCommand
11月前
半兽人 回复 漂泊的美好 kafka认证和acl 中:
大致看了一下,没找到相应的API。
1年前
漂泊的美好 回复 半兽人 kafka认证和acl 中:
请问,kafka acl有没有Java接口?
1年前
半兽人 回复 漂泊的美好 kafka认证和acl 中:
源码
1年前
发表了 启用kerberos后,producer,consumer 的java API

1年前
发表了 kafka ACL权限控制相关问题

1年前
发表了 kafka启用kerberos后,新producer和consumer产生的问题,请前辈给指导下

1年前
发表了 kafka 启动kerberos后消费者报错

1年前
发表了 关于kafka kerberos 配置的若干问题,求大神解惑

1年前
发表了 CDH5.7.1、kafkaKAFKA-2.0.0-1.kafka2.0.0.p0.12使用kerberos遇到的问题

1年前

半兽人 回复 漂泊的美好 kafka启用权限后,kafka-consumer-group.sh查看消费组报错 评论:
看下执行命令。
5天前
漂泊的美好 回复 半兽人 kafka启用权限后,kafka-consumer-group.sh查看消费组报错 评论:
这个肯定带了。先要kerberos认证之后。才执行命令
5天前
我是谁 回复 漂泊的美好 kafka-acl java api 使用碰到的问题 评论:
你好,UserGroupInformation这个类需要引入的jar包是哪个?
7月前
我是谁 回复 漂泊的美好 用kafka命令发送消息时候,一直报WARN Error while fetching metadata with correlation id 0 : {test=UNKNOWN_TOPIC_OR_PARTITION}? 评论:
你好,没有leader是什么意思?要怎么让topic产生一个leader呢?
8月前
漂泊的美好 回复 半兽人 使用camus将kafka中的数据入hive时,总有几个task失败,导致一些表入不了hive 评论:
嗯,不管怎样,谢谢你给我的解决思路。
8月前
半兽人 回复 漂泊的美好 使用camus将kafka中的数据入hive时,总有几个task失败,导致一些表入不了hive 评论:
目前我只遇到过一次,分享给你了,kafka新功能遇到的(如streams),有个很严重的bug现象,我在本地做测试,低版本的zookeeper第一次是ok的,但是当我重启应用就开始刷这种错,我还没有时间看源码。
8月前
漂泊的美好 回复 半兽人 使用camus将kafka中的数据入hive时,总有几个task失败,导致一些表入不了hive 评论:
我也是无限刷这种错误的。但是3.4.8这个版本太高了吧,用的地方不多啊
8月前
半兽人 回复 漂泊的美好 使用camus将kafka中的数据入hive时,总有几个task失败,导致一些表入不了hive 评论:
我遇到的是无限制的刷这种错误,分配不到对应分区,最后确认下来是由于zk版本过低导致。
8月前
漂泊的美好 回复 半兽人 使用camus将kafka中的数据入hive时,总有几个task失败,导致一些表入不了hive 评论:
cdh集成的zookeeper,不能升。
8月前
半兽人 回复 漂泊的美好 kafka可以跨级群消费吗? 评论:
没懂。
11月前
漂泊的美好 回复 半兽人 kafka可以跨级群消费吗? 评论:
表达有误。其实我想问的是kafka0.10可以消费kafka0.9的数据吗?
11月前
漂泊的美好 回复 半兽人 kafka-acl java api 使用碰到的问题 评论:
就在刚刚,还是原来的方式可以了,太奇怪了。昨天到今天上午一直都不行。真是让人百思不得其解。
11月前
半兽人 回复 漂泊的美好 kafka-acl java api 使用碰到的问题 评论:
用命令的方式,环境是否都是正常的?
如果是正常的,则需要关注环境了,是否加载到了运行中的jvm环境中,jdk的安全限制是否也替换了。

11月前
漂泊的美好 kafka-acl java api 使用碰到的问题 发表评论:
还通过下面这种方式进行kerberos认证,但还是没什么作用:
// Authenticating Kerberos principal
System.out.println("Principal Authentication: ");
final String user = "cloudera@CLOUDERA.COM";
final String keyPath = "cloudera.keytab";
UserGroupInformation.loginUserFromKeytab(user, keyPath);


11月前
漂泊的美好 回复 小蕊 用kafka命令发送消息时候,一直报WARN Error while fetching metadata with correlation id 0 : {test=UNKNOWN_TOPIC_OR_PARTITION}? 评论:
这个topic可能是没有leader,我曾经遇到过这个问题。
11月前
无生 回复 漂泊的美好 我想用java操作topic,增删查改什么的,应该怎么做? 评论:
那在企业中应用的时候,topic都是事先定义好的么?
11月前
漂泊的美好 我想用java操作topic,增删查改什么的,应该怎么做? 发表评论:
没做过这个,不过给你个线索,找这个类kafka.admin.TopicCommand
11月前
半兽人 回复 漂泊的美好 kafka认证和acl 评论:
大致看了一下,没找到相应的API。
1年前
漂泊的美好 回复 半兽人 kafka认证和acl 评论:
请问,kafka acl有没有Java接口?
1年前
半兽人 回复 漂泊的美好 kafka认证和acl 评论:
源码
1年前