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

暂无关注.....

粉丝

暂无粉丝.....


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

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

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

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

7月前
漂泊的美好 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);


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

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

9月前
发表了 kafka ACL权限控制相关问题

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

9月前
发表了 kafka 启动kerberos后消费者报错

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

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

10月前

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

7月前
漂泊的美好 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);


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