OrcHome OrcHome
OrcHome个人中心.

無名

已关注 关注

人生能有机会博!

人生能有机会博!

关注

暂无关注.....

粉丝

暂无粉丝.....


funky 回复 無名 kafka无法获取ReplicaFetcherThread 中:
防火墙是关闭状态的,还是会出现这个错误(有时候不是很频繁)
2月前
無名 回复 顺其自然 java代码消费不了Kafka消息 中:
赞。
2月前
undefined 回复 無名 Kafka Broker配置(0.10版) 中:
没配置,默认的不就是 delete 吗?
2月前
無名 回复 undefined Kafka Broker配置(0.10版) 中:
策略配置的什么?
2月前
undefined 回复 無名 Kafka Broker配置(0.10版) 中:
我刚刚试了,我配置为 1M , 可是查看日志文件大小都五百多M了 也没删除呢
2月前
無名 回复 undefined Kafka Broker配置(0.10版) 中:
总日志数据存储的最大字节数。超过这个时间会根据`log.cleanup.policy `处理数据。
2月前
顺其自然 回复 無名 java代码消费不了Kafka消息 中:
都是通的。。
2月前
無名 回复 顺其自然 java代码消费不了Kafka消息 中:
你telnet下你的服务器。9092端口的
2月前
顺其自然 回复 無名 java代码消费不了Kafka消息 中:
我也挺郁闷的。。刚重新装了Kafka了也不行。这个日志信息是啥意思呢?log.debug("Coordinator discovery failed, refreshing metadata")
2月前
無名 回复 顺其自然 java代码消费不了Kafka消息 中:
没错误,实在是不知道怎么帮你
2月前
发表了 angularjs中切换显示/隐藏
2月前
無名 回复 小脑袋贼大 Kafka Topic配置 中:
你指定的日志存储目录。
2月前
落樱留独殇 回复 無名 求救:java 连接 kafka kerberos 问题 中:
kerberos用户认证通了,但是ACL有问题,给topic分配权限后,使用命令测试就出现上面的错,客户端也是,可以连上kafka但是发送/消费不了。http://orchome.com/500 我是按照这个教程做的, 也看了 http://www.orchome.com/378 这个问题,但是没理解……
2月前
無名 回复 落樱留独殇 求救:java 连接 kafka kerberos 问题 中:
认证失败?这块你不是已经测通过了吗
2月前
落樱留独殇 回复 無名 求救:java 连接 kafka kerberos 问题 中:
我在server.properties中添加了

authorizer.class.name = kafka.security.auth.SimpleAclAuthorizer
super.users=User:kafka/bd005@EX.COM

然后给 pruducer 和 consumer 分配权限,这是分配后的信息

Current ACLs for resource `Topic:wwxx1`: 
  User:clients has Allow permission for operations: Read from hosts: 10.1.2.46
 User:clients@EX.COM has Allow permission for operations: Write from hosts: 10.1.2.46
 User:clients@EX.COM has Allow permission for operations: Read from hosts: 10.1.2.46
 User:clients has Allow permission for operations: Write from hosts: 10.1.2.46 

Current ACLs for resource `Group:news-consumer-group`: 
  User:clients has Allow permission for operations: Read from hosts: 10.1.2.46
 User:clients@EX.COM has Allow permission for operations: Read from hosts: 10.1.2.46 

通过命令生产和消费,分别出现了:
生产:WARN Bootstrap broker 10.1.2.46:9988 (id: -1 rack: null) disconnected (org.apache.kafka.clients.NetworkClient)
消费:WARN Error while fetching metadata with correlation id 3 : {wwxx1=TOPIC_AUTHORIZATION_FAILED} (org.apache.kafka.clients.NetworkClient)
能看出来是哪个地方出现了问题吗?
2月前
無名 回复 落樱留独殇 求救:java 连接 kafka kerberos 问题 中:
http://orchome.com/185
2月前
落樱留独殇 回复 無名 求救:java 连接 kafka kerberos 问题 中:
貌似没法对topic进行权限细分……不知道哪里的问题,唉…
2月前
发表了 基于以太坊的RPC智能合约入门 - ethereumj 修改
2月前
無名 回复 落樱留独殇 求救:java 连接 kafka kerberos 问题 中:
Σ( ° △ °|||)︴
2月前
落樱留独殇 回复 無名 求救:java 连接 kafka kerberos 问题 中:
是的,刚才又跑了遍代码,又出现那个问题了,上午的时候把
-Djava.security.krb5.conf=D:/iSpace/kafka/krb5.conf
-Djava.security.auth.login.config=D:/iSpace/kafka/kafka_client_jaas.conf 
添加到 jvm 里,把 jaas.conf 的 keyTab="D:/iSpace/kafka/kafka.keytab"也改成本地的了,确实跑通了啊,见鬼了……
2月前
無名 回复 落樱留独殇 求救:java 连接 kafka kerberos 问题 中:
你最后的命令,都是允许吧。
2月前
落樱留独殇 回复 無名 求救:java 连接 kafka kerberos 问题 中:
最后那个分配权限的命令是根据之前做SASL_PLAIN认证写的,意思是想允许来自任何IP的任何用户都可以对topic进行读写。但是,我新创建一个了topic,不分配任何权限也可以进行读写,不知道是不是SASL没生效的问题……
2月前
发表了 发布说明 - Kafka - 1.0.1版本
3月前
发表了 以太坊的nonce
3月前
無名 赞了 kafka接口API
1年前
发表了 maven命令更新版本号
1年前
发表了 kerberos安装使用
1年前
发表了 KafkaStreams客户端(0.10.0.0 API) 修改
1年前
发表了 Kafka Streams API
1年前
发表了 kafka生产者客户端(0.10.1.1API) 修改
1年前
無名 赞了 kafka生产者API
1年前
发表了 kafka的生态系统
1年前
发表了 使用Kafka Stream处理数据
1年前
发表了 使用Kafka Connect来导入/导出数据 修改
1年前
发表了 理解virt res shr之间的关系
1年前
发表了 free详解
1年前
发表了 为什么kafka消费消息不完整?
1年前
发表了 Java8 什么是λ表达式
1年前
发表了 Java8 stream入门
1年前
发表了 Java8 lambda表达式
1年前
发表了 Java8 不要再用循环了 修改
1年前
发表了 interllij idea生成javadoc
1年前
無名 赞了 KafkaOffsetMonitor:监控消费者和延迟的队列
1年前
無名 赞了 kafka安装和启动
1年前
無名 赞了 kafka安装和启动
1年前
無名 赞了 kafka安装和启动
1年前
無名 赞了 kafka启动后,关掉控台后,集群就挂了
1年前
無名 赞了 kafka中文教程
1年前
無名 赞了 Kafka Broker配置
1年前
無名 赞了 开始学习kafka
1年前
無名 收藏了 kafka 主题!
1年前
無名 赞了 KafkaOffsetMonitor:监控消费者和延迟的队列
1年前
無名 赞了 kafka接口API
1年前
無名 赞了 kafka安装和启动
1年前

funky 回复 無名 kafka无法获取ReplicaFetcherThread 评论:
防火墙是关闭状态的,还是会出现这个错误(有时候不是很频繁)
2月前
無名 回复 顺其自然 java代码消费不了Kafka消息 评论:
赞。
2月前
undefined 回复 無名 Kafka Broker配置(0.10版) 评论:
没配置,默认的不就是 delete 吗?
2月前
無名 回复 undefined Kafka Broker配置(0.10版) 评论:
策略配置的什么?
2月前
undefined 回复 無名 Kafka Broker配置(0.10版) 评论:
我刚刚试了,我配置为 1M , 可是查看日志文件大小都五百多M了 也没删除呢
2月前
無名 回复 undefined Kafka Broker配置(0.10版) 评论:
总日志数据存储的最大字节数。超过这个时间会根据`log.cleanup.policy `处理数据。
2月前
顺其自然 回复 無名 java代码消费不了Kafka消息 评论:
都是通的。。
2月前
無名 回复 顺其自然 java代码消费不了Kafka消息 评论:
你telnet下你的服务器。9092端口的
2月前
顺其自然 回复 無名 java代码消费不了Kafka消息 评论:
我也挺郁闷的。。刚重新装了Kafka了也不行。这个日志信息是啥意思呢?log.debug("Coordinator discovery failed, refreshing metadata")
2月前
無名 回复 顺其自然 java代码消费不了Kafka消息 评论:
没错误,实在是不知道怎么帮你
2月前
無名 回复 小脑袋贼大 Kafka Topic配置 评论:
你指定的日志存储目录。
2月前
落樱留独殇 回复 無名 求救:java 连接 kafka kerberos 问题 评论:
kerberos用户认证通了,但是ACL有问题,给topic分配权限后,使用命令测试就出现上面的错,客户端也是,可以连上kafka但是发送/消费不了。http://orchome.com/500 我是按照这个教程做的, 也看了 http://www.orchome.com/378 这个问题,但是没理解……
2月前
無名 回复 落樱留独殇 求救:java 连接 kafka kerberos 问题 评论:
认证失败?这块你不是已经测通过了吗
2月前
落樱留独殇 回复 無名 求救:java 连接 kafka kerberos 问题 评论:
我在server.properties中添加了

authorizer.class.name = kafka.security.auth.SimpleAclAuthorizer
super.users=User:kafka/bd005@EX.COM

然后给 pruducer 和 consumer 分配权限,这是分配后的信息

Current ACLs for resource `Topic:wwxx1`: 
  User:clients has Allow permission for operations: Read from hosts: 10.1.2.46
 User:clients@EX.COM has Allow permission for operations: Write from hosts: 10.1.2.46
 User:clients@EX.COM has Allow permission for operations: Read from hosts: 10.1.2.46
 User:clients has Allow permission for operations: Write from hosts: 10.1.2.46 

Current ACLs for resource `Group:news-consumer-group`: 
  User:clients has Allow permission for operations: Read from hosts: 10.1.2.46
 User:clients@EX.COM has Allow permission for operations: Read from hosts: 10.1.2.46 

通过命令生产和消费,分别出现了:
生产:WARN Bootstrap broker 10.1.2.46:9988 (id: -1 rack: null) disconnected (org.apache.kafka.clients.NetworkClient)
消费:WARN Error while fetching metadata with correlation id 3 : {wwxx1=TOPIC_AUTHORIZATION_FAILED} (org.apache.kafka.clients.NetworkClient)
能看出来是哪个地方出现了问题吗?
2月前
無名 回复 落樱留独殇 求救:java 连接 kafka kerberos 问题 评论:
http://orchome.com/185
2月前
落樱留独殇 回复 無名 求救:java 连接 kafka kerberos 问题 评论:
貌似没法对topic进行权限细分……不知道哪里的问题,唉…
2月前
無名 回复 落樱留独殇 求救:java 连接 kafka kerberos 问题 评论:
Σ( ° △ °|||)︴
2月前
落樱留独殇 回复 無名 求救:java 连接 kafka kerberos 问题 评论:
是的,刚才又跑了遍代码,又出现那个问题了,上午的时候把
-Djava.security.krb5.conf=D:/iSpace/kafka/krb5.conf
-Djava.security.auth.login.config=D:/iSpace/kafka/kafka_client_jaas.conf 
添加到 jvm 里,把 jaas.conf 的 keyTab="D:/iSpace/kafka/kafka.keytab"也改成本地的了,确实跑通了啊,见鬼了……
2月前
無名 回复 落樱留独殇 求救:java 连接 kafka kerberos 问题 评论:
你最后的命令,都是允许吧。
2月前
落樱留独殇 回复 無名 求救:java 连接 kafka kerberos 问题 评论:
最后那个分配权限的命令是根据之前做SASL_PLAIN认证写的,意思是想允许来自任何IP的任何用户都可以对topic进行读写。但是,我新创建一个了topic,不分配任何权限也可以进行读写,不知道是不是SASL没生效的问题……
2月前

無名 发表了 angularjs中切换显示/隐藏
2月前
無名 发表了 基于以太坊的RPC智能合约入门 - ethereumj
2月前
無名 发表了 发布说明 - Kafka - 1.0.1版本
3月前
無名 发表了 以太坊的nonce
3月前
無名 发表了 maven命令更新版本号
1年前
無名 发表了 kerberos安装使用
1年前
無名 发表了 KafkaStreams客户端(0.10.0.0 API)
1年前
無名 发表了 Kafka Streams API
1年前
無名 发表了 kafka生产者客户端(0.10.1.1API)
1年前
無名 发表了 kafka的生态系统
1年前
無名 发表了 使用Kafka Stream处理数据
1年前
無名 发表了 使用Kafka Connect来导入/导出数据
1年前
無名 发表了 理解virt res shr之间的关系
1年前
無名 发表了 free详解
1年前
無名 发表了 为什么kafka消费消息不完整?
1年前
無名 发表了 Java8 什么是λ表达式
1年前
無名 发表了 Java8 stream入门
1年前
無名 发表了 Java8 lambda表达式
1年前
無名 发表了 Java8 不要再用循环了
1年前
無名 发表了 interllij idea生成javadoc
1年前

無名 收藏了 kafka 主题!
1年前