OrcHome OrcHome
OrcHome个人中心.

久思微

已关注 关注

关注

暂无关注.....

粉丝

暂无粉丝.....


半兽人 回复 久思微 kafka生产者客户端(0.10.1.1API) 中:
不能,生产者和消费者之间是解耦的。无关系的。
3月前
久思微 kafka生产者客户端(0.10.1.1API) 发表评论:
producer发送到kafka,能否通过API检查是否被一个consumer消费完成呢?
3月前
半兽人 回复 久思微 kafka安装和启动 中:
客气,好了就行。
4月前
久思微 回复 半兽人 kafka安装和启动 中:
谢谢了。是环境污染了。我重启了下服务器。再次运行就好了。谢谢回复。很感谢
4月前
久思微 回复 久思微 kafka安装和启动 中:
 奇怪的问题,我直接从apache.org下载后,解压不更改,直接使用,也报这个错误。
4月前
久思微 回复 半兽人 kafka安装和启动 中:
问题在于,这个参数我并没有更改。即使我现在改成3还是错误;附配置文件.
zookeeper.connect=localhost:2181

# Timeout in ms for connecting to zookeeper
zookeeper.connection.timeout.ms=6000

############################# Group Coordinator Settings #############################

# The following configuration specifies the time, in milliseconds, that the GroupCoordinator will delay the initial consumer rebalance.
# The rebalance will be further delayed by the value of group.initial.rebalance.delay.ms as new members join the group, up to a maximum of max.poll.interval.ms.
# The default value for this is 3 seconds.
# We override this to 0 here as it makes for a better out-of-the-box experience for development and testing.
# However, in production environments the default value of 3 seconds is more suitable as this will help to avoid unnecessary, and potentially expensive, rebalances during application startup.
group.initial.rebalance.delay.ms=3

4月前
半兽人 回复 久思微 kafka安装和启动 中:
在config/server.properties.bak20180430中的initial.rebalance.delay.ms,从string转int的时候,格式化错误。
4月前
久思微 回复 半兽人 kafka安装和启动 中:
你好,谢谢回复,但是我还是很明白你说的错误原因。格式化转化错误,你说的是我的配置文件名称格式错误嘛?还是里面的个配置项的格式错误。准确的说,我重启了下服务器,然后就报这个错误了。
4月前
半兽人 回复 久思微 kafka安装和启动 中:
格式化转换错误。config/server.properties.bak20180430,读的是这个
4月前
久思微 kafka安装和启动 发表评论:
group.initial.rebalance.delay.ms=0[root@iZuf692ot9nf1r9fn1unojZ kafka_2.12-1.1.0]# bin/zookeeper-server-start.sh  config/server.properties.bak20180430 
[2018-05-02 19:47:01,914] INFO Reading configuration from: config/server.properties.bak20180430 (org.apache.zookeeper.server.quorum.QuorumPeerConfig)
[2018-05-02 19:47:01,921] ERROR Invalid config, exiting abnormally (org.apache.zookeeper.server.quorum.QuorumPeerMain)
org.apache.zookeeper.server.quorum.QuorumPeerConfig$ConfigException: Error processing config/server.properties.bak20180430
        at org.apache.zookeeper.server.quorum.QuorumPeerConfig.parse(QuorumPeerConfig.java:154)
        at org.apache.zookeeper.server.quorum.QuorumPeerMain.initializeAndRun(QuorumPeerMain.java:101)
        at org.apache.zookeeper.server.quorum.QuorumPeerMain.main(QuorumPeerMain.java:78)
Caused by: java.lang.NumberFormatException: For input string: "initial.rebalance.delay.ms"
        at java.lang.NumberFormatException.forInputString(NumberFormatException.java:65)
        at java.lang.Long.parseLong(Long.java:589)
        at java.lang.Long.parseLong(Long.java:631)
        at org.apache.zookeeper.server.quorum.QuorumPeerConfig.parseProperties(QuorumPeerConfig.java:242)
        at org.apache.zookeeper.server.quorum.QuorumPeerConfig.parse(QuorumPeerConfig.java:150)
        ... 2 more
Invalid config, exiting abnormally
这个是什么错误造成的的。就没改过的就突然报这个错误。很无语。initial.rebalance.delay.ms默认参数都没更改过。
4月前

半兽人 回复 久思微 kafka生产者客户端(0.10.1.1API) 评论:
不能,生产者和消费者之间是解耦的。无关系的。
3月前
久思微 kafka生产者客户端(0.10.1.1API) 发表评论:
producer发送到kafka,能否通过API检查是否被一个consumer消费完成呢?
3月前
半兽人 回复 久思微 kafka安装和启动 评论:
客气,好了就行。
4月前
久思微 回复 半兽人 kafka安装和启动 评论:
谢谢了。是环境污染了。我重启了下服务器。再次运行就好了。谢谢回复。很感谢
4月前
久思微 回复 久思微 kafka安装和启动 评论:
 奇怪的问题,我直接从apache.org下载后,解压不更改,直接使用,也报这个错误。
4月前
久思微 回复 半兽人 kafka安装和启动 评论:
问题在于,这个参数我并没有更改。即使我现在改成3还是错误;附配置文件.
zookeeper.connect=localhost:2181

# Timeout in ms for connecting to zookeeper
zookeeper.connection.timeout.ms=6000

############################# Group Coordinator Settings #############################

# The following configuration specifies the time, in milliseconds, that the GroupCoordinator will delay the initial consumer rebalance.
# The rebalance will be further delayed by the value of group.initial.rebalance.delay.ms as new members join the group, up to a maximum of max.poll.interval.ms.
# The default value for this is 3 seconds.
# We override this to 0 here as it makes for a better out-of-the-box experience for development and testing.
# However, in production environments the default value of 3 seconds is more suitable as this will help to avoid unnecessary, and potentially expensive, rebalances during application startup.
group.initial.rebalance.delay.ms=3

4月前
半兽人 回复 久思微 kafka安装和启动 评论:
在config/server.properties.bak20180430中的initial.rebalance.delay.ms,从string转int的时候,格式化错误。
4月前
久思微 回复 半兽人 kafka安装和启动 评论:
你好,谢谢回复,但是我还是很明白你说的错误原因。格式化转化错误,你说的是我的配置文件名称格式错误嘛?还是里面的个配置项的格式错误。准确的说,我重启了下服务器,然后就报这个错误了。
4月前
半兽人 回复 久思微 kafka安装和启动 评论:
格式化转换错误。config/server.properties.bak20180430,读的是这个
4月前
久思微 kafka安装和启动 发表评论:
group.initial.rebalance.delay.ms=0[root@iZuf692ot9nf1r9fn1unojZ kafka_2.12-1.1.0]# bin/zookeeper-server-start.sh  config/server.properties.bak20180430 
[2018-05-02 19:47:01,914] INFO Reading configuration from: config/server.properties.bak20180430 (org.apache.zookeeper.server.quorum.QuorumPeerConfig)
[2018-05-02 19:47:01,921] ERROR Invalid config, exiting abnormally (org.apache.zookeeper.server.quorum.QuorumPeerMain)
org.apache.zookeeper.server.quorum.QuorumPeerConfig$ConfigException: Error processing config/server.properties.bak20180430
        at org.apache.zookeeper.server.quorum.QuorumPeerConfig.parse(QuorumPeerConfig.java:154)
        at org.apache.zookeeper.server.quorum.QuorumPeerMain.initializeAndRun(QuorumPeerMain.java:101)
        at org.apache.zookeeper.server.quorum.QuorumPeerMain.main(QuorumPeerMain.java:78)
Caused by: java.lang.NumberFormatException: For input string: "initial.rebalance.delay.ms"
        at java.lang.NumberFormatException.forInputString(NumberFormatException.java:65)
        at java.lang.Long.parseLong(Long.java:589)
        at java.lang.Long.parseLong(Long.java:631)
        at org.apache.zookeeper.server.quorum.QuorumPeerConfig.parseProperties(QuorumPeerConfig.java:242)
        at org.apache.zookeeper.server.quorum.QuorumPeerConfig.parse(QuorumPeerConfig.java:150)
        ... 2 more
Invalid config, exiting abnormally
这个是什么错误造成的的。就没改过的就突然报这个错误。很无语。initial.rebalance.delay.ms默认参数都没更改过。
4月前