我在kafka定义了一个 topic 默认 6 个分片 1个副本。分布在三个节点 但是向它写入数据,它只用了两个分片存储数据。 不管怎么调都不行,真是不解。
这是它报出的一些 INFO 信息。 我不太明白是否和这个问题相关。
[2017-05-24 14:57:53,462] INFO Partition [applog,5] on broker 1: No checkpointed highwatermark is found for partition [applog,5] (kafka.cluster.Partition)
[2017-05-24 14:57:53,484] INFO Completed load of log applog-2 with log end offset 0 (kafka.log.Log)
[2017-05-24 14:57:53,485] INFO Created log for partition [applog,2] in /usr/local/kafka/kafka_2.11-0.10.0.1/data with properties {compression.type -> producer, message.format.version -> 0.10.0-IV1, file.delete.delay.ms -> 60000, max.message.bytes -> 1000012, message.timestamp.type -> CreateTime, min.insync.replicas -> 1, segment.jitter.ms -> 0, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> true, retention.bytes -> -1, delete.retention.ms -> 86400000, cleanup.policy -> delete, flush.ms -> 9223372036854775807, segment.ms -> 604800000, segment.bytes -> 1073741824, retention.ms -> 216000000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760, flush.messages -> 9223372036854775807}. (kafka.log.LogManager)
[2017-05-24 14:57:53,492] INFO Partition [applog,2] on broker 1: No checkpointed highwatermark is found for partition [applog,2] (kafka.cluster.Partition)
[2017-05-24 15:04:52,832] INFO [Group Metadata Manager on Broker 1]: Removed 0 expired offsets in 0 milliseconds. (kafka.coordinator.GroupMetadataManager)
[2017-05-24 15:14:52,831] INFO [Group Metadata Manager on Broker 1]: Removed 0 expired offsets in 0 milliseconds. (kafka.coordinator.GroupMetadataManager)