OrcHome OrcHome
OrcHome个人中心.
Marseille 修改资料 更换头像
关注(0) 粉丝(0) 积分(0)
关注

暂无关注.....

粉丝

暂无粉丝.....


ighack 回复 Marseille consumer指定位置消费offset的用法 中:
Properties props = new Properties();
props.put("bootstrap.servers", bootstrapServers);
props.put("group.id", groupId);
props.put("enable.auto.commit", false);
props.put("auto.commit.interval.ms", "1000");
props.put("session.timeout.ms", "30000");
props.put("max.poll.records", maxPollRecords);
props.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
props.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);
//consumer.subscribe(Arrays.asList(topic));

TopicPartition p = new TopicPartition(topic,2);
consumer.assign(Arrays.asList(p));
consumer.seek(p,488430);
//while (true) {
ConsumerRecords<String, String> records = consumer.poll(100);
for (ConsumerRecord<String, String> record : records) {
String V = record.value();
}
// }

没有报错。但还是查不出数据啊

7月前
我是谁 回复 Marseille broker-server.log不停报错 中:
请问,你的这个broker和分区关系错乱是怎么查出来的?
10月前
Marseille kafka-manager的leader选举功能 发表评论:
Manager的首选副本选举功能在partition状态异常时,可以执行。正常时无法执行
1年前
发表了 kafka无法获取ReplicaFetcherThread

1年前
发表了 topic的某个partition的ISR缺失该如何处理?

1年前
無名 回复 Marseille kafka-manager的leader选举功能 中:
是最新的manager吗?
1年前
Marseille 回复 無名 kafka-manager的leader选举功能 中:
2个副本,读写都正常。用sh脚本可以执行选举。
1年前
发表了 kafka-manager的leader选举功能

1年前
Marseille consumer指定位置消费offset的用法 发表评论:
问题原因:手动指定消费位置,无法自动负载均衡,所以要手动注册,才能消费
consumer.assign(Arrays.asList(topicPartition));

1年前
Marseille 赞了 broker-server.log不停报错
1年前
发表了 consumer指定位置消费offset的用法

1年前
無名 回复 Marseille broker-server.log不停报错 中:
手动改分区,http://orchome.com/36
1年前
Marseille broker-server.log不停报错 发表评论:
kafka0.10.0.0版本问题:问题已经找到了,是broker1和分区0对应关系错乱导致,但是我想知道这种问题如何解决?手动改分区吗?还有没有更好的方式
1年前
发表了 broker-server.log不停报错

1年前

ighack 回复 Marseille consumer指定位置消费offset的用法 评论:
Properties props = new Properties();
props.put("bootstrap.servers", bootstrapServers);
props.put("group.id", groupId);
props.put("enable.auto.commit", false);
props.put("auto.commit.interval.ms", "1000");
props.put("session.timeout.ms", "30000");
props.put("max.poll.records", maxPollRecords);
props.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
props.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);
//consumer.subscribe(Arrays.asList(topic));

TopicPartition p = new TopicPartition(topic,2);
consumer.assign(Arrays.asList(p));
consumer.seek(p,488430);
//while (true) {
ConsumerRecords<String, String> records = consumer.poll(100);
for (ConsumerRecord<String, String> record : records) {
String V = record.value();
}
// }

没有报错。但还是查不出数据啊

7月前
我是谁 回复 Marseille broker-server.log不停报错 评论:
请问,你的这个broker和分区关系错乱是怎么查出来的?
10月前
Marseille kafka-manager的leader选举功能 发表评论:
Manager的首选副本选举功能在partition状态异常时,可以执行。正常时无法执行
1年前
無名 回复 Marseille kafka-manager的leader选举功能 评论:
是最新的manager吗?
1年前
Marseille 回复 無名 kafka-manager的leader选举功能 评论:
2个副本,读写都正常。用sh脚本可以执行选举。
1年前
Marseille consumer指定位置消费offset的用法 发表评论:
问题原因:手动指定消费位置,无法自动负载均衡,所以要手动注册,才能消费
consumer.assign(Arrays.asList(topicPartition));

1年前
無名 回复 Marseille broker-server.log不停报错 评论:
手动改分区,http://orchome.com/36
1年前
Marseille broker-server.log不停报错 发表评论:
kafka0.10.0.0版本问题:问题已经找到了,是broker1和分区0对应关系错乱导致,但是我想知道这种问题如何解决?手动改分区吗?还有没有更好的方式
1年前