OrcHome OrcHome
OrcHome个人中心.

undefined

已关注 关注

关注

暂无关注.....

粉丝

暂无粉丝.....


undefined 回复 undefined kafka安装和启动 中:
修改一下 kafka-server-start.sh 脚本中的端口

if [ "x$KAFKA_HEAP_OPTS" = "x" ]; then
    export KAFKA_HEAP_OPTS="-Xmx1G -Xms1G"
    export JMX_PORT="9997"
fi

export JMX_PORT="9997"  这个

4月前
愚思 回复 undefined kafka安装和启动 中:
你怎解决的,我也遇到了相同的问题,一模一样?急求解
4月前
千鹤·重弹 回复 undefined kafka安装和启动 中:
通信超过默认的时长,被T除lsr
4月前
undefined 回复 undefined Kafka Broker配置(0.10版) 中:
我明白了,只能删除 old segments
5月前
undefined 回复 無名 Kafka Broker配置(0.10版) 中:
没配置,默认的不就是 delete 吗?
5月前
無名 回复 undefined Kafka Broker配置(0.10版) 中:
策略配置的什么?
5月前
undefined 回复 無名 Kafka Broker配置(0.10版) 中:
我刚刚试了,我配置为 1M , 可是查看日志文件大小都五百多M了 也没删除呢
5月前
無名 回复 undefined Kafka Broker配置(0.10版) 中:
总日志数据存储的最大字节数。超过这个时间会根据`log.cleanup.policy `处理数据。
5月前
undefined Kafka Broker配置(0.10版) 发表评论:
log.retention.bytes  这个参数是指单个日志文件的大小,还是分区所有日志总和大小?
5月前
undefined kafka安装和启动 发表评论:
 Topic: UserInfo Partition: 0 Leader: 0 Replicas: 0,1 Isr: 0
 Topic: UserInfo Partition: 1 Leader: 1 Replicas: 1,2 Isr: 1,2
 Topic: UserInfo        Partition: 2 Leader: 2 Replicas: 2,0 Isr: 2,0
分区 0 存活的节点为什么少了 1,从分区 1 来看 1节点是存活的啊,这是为什么?
7月前
半兽人 回复 undefined kafka安装和启动 中:
重新恢复broker才行。
7月前
undefined kafka安装和启动 发表评论:
请教一下大佬,如果我有 5 个 broker,配置了一个 topic 有 2 份备份,现在刚好这两个备份所在机器挂了,如何能恢复数据?
7月前
半兽人 回复 undefined kafka安装和启动 中:

7月前
undefined 回复 undefined kafka安装和启动 中:
已经解决了
7月前
undefined kafka安装和启动 发表评论:
我在同一台机器上启动第2个broker 的时候报错了,是什么情况?

错误: 代理抛出异常错误: java.rmi.server.ExportException: Port already in use: 9999; nested exception is:
 java.net.BindException: 地址已在使用 (Bind failed)

7月前
半兽人 回复 undefined kafka入门介绍 中:
对,相同的消费者组中的消费者数量不能比分区的数量多。
1年前
undefined kafka入门介绍 发表评论:
相同的消费者组中不能有比分区更多的消费者,否则多出的消费者一直处于空等待,不会收到消息

这一句有些难以理解啊,什么是 相同的消费者组,是不是应该是 一个消费者组啊

1年前

undefined 回复 undefined kafka安装和启动 评论:
修改一下 kafka-server-start.sh 脚本中的端口

if [ "x$KAFKA_HEAP_OPTS" = "x" ]; then
    export KAFKA_HEAP_OPTS="-Xmx1G -Xms1G"
    export JMX_PORT="9997"
fi

export JMX_PORT="9997"  这个

4月前
愚思 回复 undefined kafka安装和启动 评论:
你怎解决的,我也遇到了相同的问题,一模一样?急求解
4月前
千鹤·重弹 回复 undefined kafka安装和启动 评论:
通信超过默认的时长,被T除lsr
4月前
undefined 回复 undefined Kafka Broker配置(0.10版) 评论:
我明白了,只能删除 old segments
5月前
undefined 回复 無名 Kafka Broker配置(0.10版) 评论:
没配置,默认的不就是 delete 吗?
5月前
無名 回复 undefined Kafka Broker配置(0.10版) 评论:
策略配置的什么?
5月前
undefined 回复 無名 Kafka Broker配置(0.10版) 评论:
我刚刚试了,我配置为 1M , 可是查看日志文件大小都五百多M了 也没删除呢
5月前
無名 回复 undefined Kafka Broker配置(0.10版) 评论:
总日志数据存储的最大字节数。超过这个时间会根据`log.cleanup.policy `处理数据。
5月前
undefined Kafka Broker配置(0.10版) 发表评论:
log.retention.bytes  这个参数是指单个日志文件的大小,还是分区所有日志总和大小?
5月前
undefined kafka安装和启动 发表评论:
 Topic: UserInfo Partition: 0 Leader: 0 Replicas: 0,1 Isr: 0
 Topic: UserInfo Partition: 1 Leader: 1 Replicas: 1,2 Isr: 1,2
 Topic: UserInfo        Partition: 2 Leader: 2 Replicas: 2,0 Isr: 2,0
分区 0 存活的节点为什么少了 1,从分区 1 来看 1节点是存活的啊,这是为什么?
7月前
半兽人 回复 undefined kafka安装和启动 评论:
重新恢复broker才行。
7月前
undefined kafka安装和启动 发表评论:
请教一下大佬,如果我有 5 个 broker,配置了一个 topic 有 2 份备份,现在刚好这两个备份所在机器挂了,如何能恢复数据?
7月前
半兽人 回复 undefined kafka安装和启动 评论:

7月前
undefined 回复 undefined kafka安装和启动 评论:
已经解决了
7月前
undefined kafka安装和启动 发表评论:
我在同一台机器上启动第2个broker 的时候报错了,是什么情况?

错误: 代理抛出异常错误: java.rmi.server.ExportException: Port already in use: 9999; nested exception is:
 java.net.BindException: 地址已在使用 (Bind failed)

7月前
半兽人 回复 undefined kafka入门介绍 评论:
对,相同的消费者组中的消费者数量不能比分区的数量多。
1年前
undefined kafka入门介绍 发表评论:
相同的消费者组中不能有比分区更多的消费者,否则多出的消费者一直处于空等待,不会收到消息

这一句有些难以理解啊,什么是 相同的消费者组,是不是应该是 一个消费者组啊

1年前