OrcHome OrcHome
OrcHome个人中心.

無名

已关注 关注

人生能有几回搏。

人生能有几回搏。

关注

暂无关注.....

粉丝

暂无粉丝.....


無名 赞了 kafka通过开始和结束时间,重新消费消息。
2天前
無名 赞了 kafka客户端 - java
2天前
無名 回复 ighack org.apache.kafka.common.errors.NotLeaderForPartit ionException: This server is not the leader for that topic-partition? 中:
这样看着是正常的,如果在出异常,你在查询下。
4天前
ighack 回复 無名 org.apache.kafka.common.errors.NotLeaderForPartit ionException: This server is not the leader for that topic-partition? 中:
由于我重启了,所以现在的输出不知道还有用吗?
Topic:JLP_TO_LMIS_GD PartitionCount:10 ReplicationFactor:3 Configs:
 Topic: JLP_TO_LMIS_GD Partition: 0 Leader: 0 Replicas: 0,1,2 Isr: 0,1,2
 Topic: JLP_TO_LMIS_GD Partition: 1 Leader: 1 Replicas: 1,2,3 Isr: 1,2,3
 Topic: JLP_TO_LMIS_GD Partition: 2 Leader: 2 Replicas: 2,3,4 Isr: 2,3,4
 Topic: JLP_TO_LMIS_GD Partition: 3 Leader: 3 Replicas: 3,4,0 Isr: 0,3,4
 Topic: JLP_TO_LMIS_GD Partition: 4 Leader: 4 Replicas: 4,0,1 Isr: 0,1,4
 Topic: JLP_TO_LMIS_GD Partition: 5 Leader: 0 Replicas: 0,2,3 Isr: 0,2,3
 Topic: JLP_TO_LMIS_GD Partition: 6 Leader: 1 Replicas: 1,3,4 Isr: 1,3,4
 Topic: JLP_TO_LMIS_GD Partition: 7 Leader: 2 Replicas: 2,4,0 Isr: 0,2,4
 Topic: JLP_TO_LMIS_GD Partition: 8 Leader: 3 Replicas: 3,0,1 Isr: 0,1,3
 Topic: JLP_TO_LMIS_GD Partition: 9 Leader: 4 Replicas: 4,1,2 Isr: 1,2,4
Topic:Parallel_Computing_Bill PartitionCount:10 ReplicationFactor:3 Configs:
 Topic: Parallel_Computing_Bill Partition: 0 Leader: 0 Replicas: 0,1,2 Isr: 0,1,2
 Topic: Parallel_Computing_Bill Partition: 1 Leader: 1 Replicas: 1,2,3 Isr: 1,2,3
 Topic: Parallel_Computing_Bill Partition: 2 Leader: 2 Replicas: 2,3,4 Isr: 2,3,4
 Topic: Parallel_Computing_Bill Partition: 3 Leader: 3 Replicas: 3,4,0 Isr: 0,3,4
 Topic: Parallel_Computing_Bill Partition: 4 Leader: 4 Replicas: 4,0,1 Isr: 0,1,4
 Topic: Parallel_Computing_Bill Partition: 5 Leader: 0 Replicas: 0,2,3 Isr: 0,2,3
 Topic: Parallel_Computing_Bill Partition: 6 Leader: 1 Replicas: 1,3,4 Isr: 1,3,4
 Topic: Parallel_Computing_Bill Partition: 7 Leader: 2 Replicas: 2,4,0 Isr: 0,2,4
 Topic: Parallel_Computing_Bill Partition: 8 Leader: 3 Replicas: 3,0,1 Isr: 0,1,3
 Topic: Parallel_Computing_Bill Partition: 9 Leader: 4 Replicas: 4,1,2 Isr: 1,2,4

4天前
√锋²º¹8ヾ/❤ 回复 無名 kafka入门介绍 中:
谢谢您的回复。
非阻塞和阻塞模式,大概的了解。
我问题中“有没有什么机制能检测kafka的服务是否正常?”--这个意思是假若我们程序连接的kafka是在新网,我们在本地调用新网的xxx:9092,一种情况是我将本地网线拔了;一种是新网的服务停止了。这个时候,在send或者poll的时候,捕获kafka服务的异常?
6天前
发表了 深入理解Java闭包概念 修改
7天前
無名 回复 ighack org.apache.kafka.common.errors.NotLeaderForPartit ionException: This server is not the leader for that topic-partition? 中:
大兄弟,你这集群很异常呢。

## 查询集群描述
bin/kafka-topics.sh --describe --zookeeper 

7天前
無名 回复 √锋²º¹8ヾ/❤ kafka入门介绍 中:
首先,retries设置为0,就不会重试了。
其次,你发送方式属于非阻塞式的,后台发送,可以利用callback来获取发送成功还是失败的异常。
如果你想及时捕捉,可使用阻塞式发送,效率牺牲很大,只需要在发送的时候价格.get()即可,就能实时拿到异常。
producer.send(new ProducerRecord<String, String>("my-topic", Integer.toString(i), Integer.toString(i))).get();

7天前
無名 ZooKeeper宕机后 新版的Kafka会怎么样? 发表评论:
zookeeper充当了kafka集群之间互相发现的角色。所以当zookeeper失效后,集群之间不会再发现新的节点,会维护内部已发现的一套节点列表。另外因为生产者和消费者已经与kafka建立了连接,并也有了一份节点列表,所以还可继续发送和消费。
14天前
Explore 回复 無名 kafka命令大全 中:
啊?用send命令时候,producer.send(topic, key, value),如果kafka没有这个topic的时候,会自动创建吗?
15天前
無名 回复 Explore kafka命令大全 中:
会自动创建,为啥要自己创建呢?
15天前
Explore 回复 無名 kafka命令大全 中:
做的是一个先查询,如果没有这个topic,则去创建topic。
我用网上查找的TopicCommand.main(options);报错运行不出来。。。
15天前
無名 回复 Explore kafka命令大全 中:
topic你要通过api创建,还是查询。如果是查询可以参考KafaOffsetMonitor源码。
15天前
xiehongm 回复 無名 kafka安装和启动 中:
[抱拳]
16天前
無名 回复 xiehongm kafka安装和启动 中:
http://orchome.com/303 这些是官网的例子,后续我会放出来一些实例的。
16天前
世间哪有真情 回复 無名 kafka消费者客户端(0.10.0.1API) 中:
api我看了 确实有这个方法 但是消费者一般使用while循环一直执行的 ,pause方法该如何调用呢

16天前
無名 回复 世间哪有真情 kafka消费者客户端(0.10.0.1API) 中:
pause
17天前
Explore 回复 無名 kafka生产者客户端(0.10.1.1API) 中:
嗯嗯,这个问题修复了,谢谢您
17天前
無名 回复 Explore kafka生产者客户端(0.10.1.1API) 中:
怎么会呢,你的核心逻辑是这个。“my-topic”不同,发送的主题就不同。
producer.send(new ProducerRecord<String, String>("my-topic", Integer.toString(i), Integer.toString(i)));

17天前
Explore 回复 無名 kafka生产者客户端(0.10.1.1API) 中:
emmm,因为我需要在生产者生产数据的同时需要往不同的topic中添加数据,所以我去监控一个配置文件去实时读写,而问题是topic改变之后。新topic有新的数据加入,而替换之前的原topic也有新的数据加入。这是为什么?
18天前
無名 回复 Explore kafka生产者客户端(0.10.1.1API) 中:
什么意思呢?topic实时变更?不理解。
18天前
無名 回复 Explore kafka生产者客户端(0.10.1.1API) 中:
生产端不用啊,命令是随机的,但是java代码是写死的。
18天前
Explore 回复 無名 kafka生产者客户端(0.10.1.1API) 中:
那生产端的代码需要变更吗?
18天前
Explore 关注了 無名
18天前
发表了 以太坊RLPX网络协议 修改
24天前
发表了 椭圆曲线算法secp256k1进行数字签名 - Java 修改
24天前
無名 关注了 半兽人
1月前
無名 收藏了 kafka 主题!
1月前
发表了 java中异或 修改
1月前
发表了 angularjs中切换显示/隐藏 修改
4月前
发表了 基于以太坊的RPC智能合约入门 - ethereumj 修改
4月前
发表了 发布说明 - Kafka - 1.0.1版本 修改
4月前
发表了 以太坊的nonce 修改
5月前
無名 赞了 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年前
無名 赞了 KafkaOffsetMonitor:监控消费者和延迟的队列
1年前
無名 赞了 kafka安装和启动
1年前
無名 赞了 kafka安装和启动
1年前
無名 赞了 kafka安装和启动
1年前
無名 赞了 kafka启动后,关掉控台后,集群就挂了
1年前
無名 赞了 kafka中文教程
1年前
無名 赞了 Kafka Broker配置
1年前
無名 赞了 开始学习kafka
1年前
無名 赞了 KafkaOffsetMonitor:监控消费者和延迟的队列
1年前
無名 赞了 kafka接口API
1年前
無名 赞了 kafka安装和启动
1年前

無名 回复 ighack org.apache.kafka.common.errors.NotLeaderForPartit ionException: This server is not the leader for that topic-partition? 评论:
这样看着是正常的,如果在出异常,你在查询下。
4天前
ighack 回复 無名 org.apache.kafka.common.errors.NotLeaderForPartit ionException: This server is not the leader for that topic-partition? 评论:
由于我重启了,所以现在的输出不知道还有用吗?
Topic:JLP_TO_LMIS_GD PartitionCount:10 ReplicationFactor:3 Configs:
 Topic: JLP_TO_LMIS_GD Partition: 0 Leader: 0 Replicas: 0,1,2 Isr: 0,1,2
 Topic: JLP_TO_LMIS_GD Partition: 1 Leader: 1 Replicas: 1,2,3 Isr: 1,2,3
 Topic: JLP_TO_LMIS_GD Partition: 2 Leader: 2 Replicas: 2,3,4 Isr: 2,3,4
 Topic: JLP_TO_LMIS_GD Partition: 3 Leader: 3 Replicas: 3,4,0 Isr: 0,3,4
 Topic: JLP_TO_LMIS_GD Partition: 4 Leader: 4 Replicas: 4,0,1 Isr: 0,1,4
 Topic: JLP_TO_LMIS_GD Partition: 5 Leader: 0 Replicas: 0,2,3 Isr: 0,2,3
 Topic: JLP_TO_LMIS_GD Partition: 6 Leader: 1 Replicas: 1,3,4 Isr: 1,3,4
 Topic: JLP_TO_LMIS_GD Partition: 7 Leader: 2 Replicas: 2,4,0 Isr: 0,2,4
 Topic: JLP_TO_LMIS_GD Partition: 8 Leader: 3 Replicas: 3,0,1 Isr: 0,1,3
 Topic: JLP_TO_LMIS_GD Partition: 9 Leader: 4 Replicas: 4,1,2 Isr: 1,2,4
Topic:Parallel_Computing_Bill PartitionCount:10 ReplicationFactor:3 Configs:
 Topic: Parallel_Computing_Bill Partition: 0 Leader: 0 Replicas: 0,1,2 Isr: 0,1,2
 Topic: Parallel_Computing_Bill Partition: 1 Leader: 1 Replicas: 1,2,3 Isr: 1,2,3
 Topic: Parallel_Computing_Bill Partition: 2 Leader: 2 Replicas: 2,3,4 Isr: 2,3,4
 Topic: Parallel_Computing_Bill Partition: 3 Leader: 3 Replicas: 3,4,0 Isr: 0,3,4
 Topic: Parallel_Computing_Bill Partition: 4 Leader: 4 Replicas: 4,0,1 Isr: 0,1,4
 Topic: Parallel_Computing_Bill Partition: 5 Leader: 0 Replicas: 0,2,3 Isr: 0,2,3
 Topic: Parallel_Computing_Bill Partition: 6 Leader: 1 Replicas: 1,3,4 Isr: 1,3,4
 Topic: Parallel_Computing_Bill Partition: 7 Leader: 2 Replicas: 2,4,0 Isr: 0,2,4
 Topic: Parallel_Computing_Bill Partition: 8 Leader: 3 Replicas: 3,0,1 Isr: 0,1,3
 Topic: Parallel_Computing_Bill Partition: 9 Leader: 4 Replicas: 4,1,2 Isr: 1,2,4

4天前
√锋²º¹8ヾ/❤ 回复 無名 kafka入门介绍 评论:
谢谢您的回复。
非阻塞和阻塞模式,大概的了解。
我问题中“有没有什么机制能检测kafka的服务是否正常?”--这个意思是假若我们程序连接的kafka是在新网,我们在本地调用新网的xxx:9092,一种情况是我将本地网线拔了;一种是新网的服务停止了。这个时候,在send或者poll的时候,捕获kafka服务的异常?
6天前
無名 回复 ighack org.apache.kafka.common.errors.NotLeaderForPartit ionException: This server is not the leader for that topic-partition? 评论:
大兄弟,你这集群很异常呢。

## 查询集群描述
bin/kafka-topics.sh --describe --zookeeper 

7天前
無名 回复 √锋²º¹8ヾ/❤ kafka入门介绍 评论:
首先,retries设置为0,就不会重试了。
其次,你发送方式属于非阻塞式的,后台发送,可以利用callback来获取发送成功还是失败的异常。
如果你想及时捕捉,可使用阻塞式发送,效率牺牲很大,只需要在发送的时候价格.get()即可,就能实时拿到异常。
producer.send(new ProducerRecord<String, String>("my-topic", Integer.toString(i), Integer.toString(i))).get();

7天前
無名 ZooKeeper宕机后 新版的Kafka会怎么样? 发表评论:
zookeeper充当了kafka集群之间互相发现的角色。所以当zookeeper失效后,集群之间不会再发现新的节点,会维护内部已发现的一套节点列表。另外因为生产者和消费者已经与kafka建立了连接,并也有了一份节点列表,所以还可继续发送和消费。
14天前
Explore 回复 無名 kafka命令大全 评论:
啊?用send命令时候,producer.send(topic, key, value),如果kafka没有这个topic的时候,会自动创建吗?
15天前
無名 回复 Explore kafka命令大全 评论:
会自动创建,为啥要自己创建呢?
15天前
Explore 回复 無名 kafka命令大全 评论:
做的是一个先查询,如果没有这个topic,则去创建topic。
我用网上查找的TopicCommand.main(options);报错运行不出来。。。
15天前
無名 回复 Explore kafka命令大全 评论:
topic你要通过api创建,还是查询。如果是查询可以参考KafaOffsetMonitor源码。
15天前
xiehongm 回复 無名 kafka安装和启动 评论:
[抱拳]
16天前
無名 回复 xiehongm kafka安装和启动 评论:
http://orchome.com/303 这些是官网的例子,后续我会放出来一些实例的。
16天前
世间哪有真情 回复 無名 kafka消费者客户端(0.10.0.1API) 评论:
api我看了 确实有这个方法 但是消费者一般使用while循环一直执行的 ,pause方法该如何调用呢

16天前
無名 回复 世间哪有真情 kafka消费者客户端(0.10.0.1API) 评论:
pause
17天前
Explore 回复 無名 kafka生产者客户端(0.10.1.1API) 评论:
嗯嗯,这个问题修复了,谢谢您
17天前
無名 回复 Explore kafka生产者客户端(0.10.1.1API) 评论:
怎么会呢,你的核心逻辑是这个。“my-topic”不同,发送的主题就不同。
producer.send(new ProducerRecord<String, String>("my-topic", Integer.toString(i), Integer.toString(i)));

17天前
Explore 回复 無名 kafka生产者客户端(0.10.1.1API) 评论:
emmm,因为我需要在生产者生产数据的同时需要往不同的topic中添加数据,所以我去监控一个配置文件去实时读写,而问题是topic改变之后。新topic有新的数据加入,而替换之前的原topic也有新的数据加入。这是为什么?
18天前
無名 回复 Explore kafka生产者客户端(0.10.1.1API) 评论:
什么意思呢?topic实时变更?不理解。
18天前
無名 回复 Explore kafka生产者客户端(0.10.1.1API) 评论:
生产端不用啊,命令是随机的,但是java代码是写死的。
18天前
Explore 回复 無名 kafka生产者客户端(0.10.1.1API) 评论:
那生产端的代码需要变更吗?
18天前

無名 发表了 深入理解Java闭包概念
7天前
無名 发表了 以太坊RLPX网络协议
24天前
無名 发表了 椭圆曲线算法secp256k1进行数字签名 - Java
24天前
無名 发表了 java中异或
1月前
無名 发表了 angularjs中切换显示/隐藏
4月前
無名 发表了 基于以太坊的RPC智能合约入门 - ethereumj
4月前
無名 发表了 发布说明 - Kafka - 1.0.1版本
4月前
無名 发表了 以太坊的nonce
5月前
無名 发表了 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年前

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

無名 关注了 半兽人
1月前