OrcHome OrcHome
OrcHome个人中心.

Fate. Fire

已关注 关注

关注

暂无关注.....

粉丝

暂无粉丝.....


半兽人 回复 Fate. Fire kafka实战kerberos(笔记) 中:
没有这个属性额,你注意下你的错误。
15天前
Fate. Fire kafka实战kerberos(笔记) 发表评论:
你好,我再kafka上设置好了sasl认证,然后再Java程序中的生产者和消费者设置了System.setProperty("java.security.auth.login.config",
                "/Users/Sean/Documents/Gitrep/bigdata/kafka/src/main/resources/kafka_client_jaas.conf"); // 环境变量添加,需要输入配置文件的路径
        props.put("security.protocol", "SASL_PLAINTEXT");
        props.put("sasl.mechanism", "PLAIN");,现在我生产和消费报这个错Caused by: java.lang.IllegalArgumentException: Could not find a 'KafkaClient' entry in the JAAS configuration. System property 'java.security.auth.login.config' is /home/hadoop/kafka_2.11-1.1.0/config/kafka_client_jaas.conf


15天前
Fate. Fire ZooKeeper认证【kafka】 发表评论:
大神,我的zookeeper集群设置了acl认证,kafka如何取连接这个acl认证的zookeeper集群呢?如何配置呢
17天前
半兽人 回复 Fate. Fire kafka安装和启动 中:
检查集群状态吧。
20天前
Fate. Fire kafka安装和启动 发表评论:
大神,kafka启动报这个错什么原因啊,怎么解决呢
[2018-06-29 10:29:23,972] ERROR [ReplicaFetcherThread-0-2]: Error for partition [testimf,0] to broker 2:org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition. (kafka.server.ReplicaFetcherThread)

20天前
Fate. Fire kafka消费者客户端(0.10.0.1API) 发表评论:
我的一个kafka消费者消费消息一直卡在ConsumerRecords<String, String> records = consumer.poll(5000);这上面是什么原因呢,我本地虚拟机跑没问题,但是一上测试环境Kafka就一直阻塞了
20天前
半兽人 回复 Fate. Fire Kafka Broker配置(0.10版) 中:
listeners暴露端口和地址。
listeners=PLAINTEXT://123.12.12.1:9092,SSL://123.12.12.1:9093
说明了你的kafka集群支持加密和不加密的。不加密的访问是9092端口,ssl加密的就访问9093。
21天前
Fate. Fire 回复 半兽人 Kafka Broker配置(0.10版) 中:
我不太理解listeners这个配置最主要的作用是什么。
21天前
半兽人 回复 Fate. Fire Kafka Broker配置(0.10版) 中:
好吧,简单点。
首先,你的计算机名ping的时候,是你的内部ip。
其二,只用listeners,配置你的内部ip。

其他的都弃用了。
21天前
Fate. Fire 回复 半兽人 Kafka Broker配置(0.10版) 中:
listeners,host.name和hostname我也不太理解,你能详细讲讲吗,我在腾讯云上搭建了一个单节点的kafka,但是我我写的Java demo一直连接不上这个Kafka,防火墙已关闭,安全组也放开了相关端口

21天前
半兽人 回复 Fate. Fire Kafka Broker配置(0.10版) 中:
由于kafka后续推出了安全策略,需要对外提供多个端口,所以之前的advertised只支持一种就无法兼容,因此都弃用了。
21天前
Fate. Fire Kafka Broker配置(0.10版) 发表评论:
你好,请问advertised.listeners,listeners,advertised.host.name,host.name这几者之间的配置的具体意思及联系和区别,楼主可否详细讲解下。
21天前
半兽人 回复 Fate. Fire kafka性能、效率和topic的关系 中:
对呀,我们生产都是主备,备5个。。性能得多低。
23天前
Fate. Fire 回复 半兽人 kafka性能、效率和topic的关系 中:
意思就是两个备份就足够了,不需要五个border弄5个备份对吗?


23天前
半兽人 回复 Fate. Fire kafka性能、效率和topic的关系 中:
一样的,让集群中的topic分开存储。
23天前
Fate. Fire 回复 半兽人 kafka性能、效率和topic的关系 中:
现在我们kafka集群可能会扩展到5个节点,也就是5个border,那么这种情况下几个备份比较好呢?
23天前
半兽人 回复 Fate. Fire kafka性能、效率和topic的关系 中:
topic创建的时候设置2个副本。就是主备。
23天前
Fate. Fire 回复 半兽人 kafka性能、效率和topic的关系 中:
主备的搭建方法其实就是博客中讲到的吗,然后再创建topic时指定备份数就可以了?
23天前
半兽人 回复 Fate. Fire kafka性能、效率和topic的关系 中:
嗯,一主一备。
23天前
Fate. Fire 回复 半兽人 kafka性能、效率和topic的关系 中:
你好,主备复制是指设置备份数吗?
23天前
发表了 kafka性能、效率和topic的关系
23天前
发表了 关于kafka集群硬件配置
3月前

半兽人 回复 Fate. Fire kafka实战kerberos(笔记) 评论:
没有这个属性额,你注意下你的错误。
15天前
Fate. Fire kafka实战kerberos(笔记) 发表评论:
你好,我再kafka上设置好了sasl认证,然后再Java程序中的生产者和消费者设置了System.setProperty("java.security.auth.login.config",
                "/Users/Sean/Documents/Gitrep/bigdata/kafka/src/main/resources/kafka_client_jaas.conf"); // 环境变量添加,需要输入配置文件的路径
        props.put("security.protocol", "SASL_PLAINTEXT");
        props.put("sasl.mechanism", "PLAIN");,现在我生产和消费报这个错Caused by: java.lang.IllegalArgumentException: Could not find a 'KafkaClient' entry in the JAAS configuration. System property 'java.security.auth.login.config' is /home/hadoop/kafka_2.11-1.1.0/config/kafka_client_jaas.conf


15天前
Fate. Fire ZooKeeper认证【kafka】 发表评论:
大神,我的zookeeper集群设置了acl认证,kafka如何取连接这个acl认证的zookeeper集群呢?如何配置呢
17天前
半兽人 回复 Fate. Fire kafka安装和启动 评论:
检查集群状态吧。
20天前
Fate. Fire kafka安装和启动 发表评论:
大神,kafka启动报这个错什么原因啊,怎么解决呢
[2018-06-29 10:29:23,972] ERROR [ReplicaFetcherThread-0-2]: Error for partition [testimf,0] to broker 2:org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition. (kafka.server.ReplicaFetcherThread)

20天前
Fate. Fire kafka消费者客户端(0.10.0.1API) 发表评论:
我的一个kafka消费者消费消息一直卡在ConsumerRecords<String, String> records = consumer.poll(5000);这上面是什么原因呢,我本地虚拟机跑没问题,但是一上测试环境Kafka就一直阻塞了
20天前
半兽人 回复 Fate. Fire Kafka Broker配置(0.10版) 评论:
listeners暴露端口和地址。
listeners=PLAINTEXT://123.12.12.1:9092,SSL://123.12.12.1:9093
说明了你的kafka集群支持加密和不加密的。不加密的访问是9092端口,ssl加密的就访问9093。
21天前
Fate. Fire 回复 半兽人 Kafka Broker配置(0.10版) 评论:
我不太理解listeners这个配置最主要的作用是什么。
21天前
半兽人 回复 Fate. Fire Kafka Broker配置(0.10版) 评论:
好吧,简单点。
首先,你的计算机名ping的时候,是你的内部ip。
其二,只用listeners,配置你的内部ip。

其他的都弃用了。
21天前
Fate. Fire 回复 半兽人 Kafka Broker配置(0.10版) 评论:
listeners,host.name和hostname我也不太理解,你能详细讲讲吗,我在腾讯云上搭建了一个单节点的kafka,但是我我写的Java demo一直连接不上这个Kafka,防火墙已关闭,安全组也放开了相关端口

21天前
半兽人 回复 Fate. Fire Kafka Broker配置(0.10版) 评论:
由于kafka后续推出了安全策略,需要对外提供多个端口,所以之前的advertised只支持一种就无法兼容,因此都弃用了。
21天前
Fate. Fire Kafka Broker配置(0.10版) 发表评论:
你好,请问advertised.listeners,listeners,advertised.host.name,host.name这几者之间的配置的具体意思及联系和区别,楼主可否详细讲解下。
21天前
半兽人 回复 Fate. Fire kafka性能、效率和topic的关系 评论:
对呀,我们生产都是主备,备5个。。性能得多低。
23天前
Fate. Fire 回复 半兽人 kafka性能、效率和topic的关系 评论:
意思就是两个备份就足够了,不需要五个border弄5个备份对吗?


23天前
半兽人 回复 Fate. Fire kafka性能、效率和topic的关系 评论:
一样的,让集群中的topic分开存储。
23天前
Fate. Fire 回复 半兽人 kafka性能、效率和topic的关系 评论:
现在我们kafka集群可能会扩展到5个节点,也就是5个border,那么这种情况下几个备份比较好呢?
23天前
半兽人 回复 Fate. Fire kafka性能、效率和topic的关系 评论:
topic创建的时候设置2个副本。就是主备。
23天前
Fate. Fire 回复 半兽人 kafka性能、效率和topic的关系 评论:
主备的搭建方法其实就是博客中讲到的吗,然后再创建topic时指定备份数就可以了?
23天前
半兽人 回复 Fate. Fire kafka性能、效率和topic的关系 评论:
嗯,一主一备。
23天前
Fate. Fire 回复 半兽人 kafka性能、效率和topic的关系 评论:
你好,主备复制是指设置备份数吗?
23天前

Fate. Fire 发表了 kafka性能、效率和topic的关系
23天前
Fate. Fire 发表了 关于kafka集群硬件配置
3月前