2017-12-06 7 views
1

私は私のlocahostでZookeeperとKafka(それぞれ1インスタンス)を実行しています。Kafka + Zookeeper:ノード-1への接続を確立できませんでした。ブローカーが利用できない可能性があります

./bin/kafka-topics.sh --zookeeper localhost:2181 --create --replication-factor 1 --partitions 1 --topic Hello-Nicola 

Created topic "Hello-Nicola". 

カフカがショー記録します:

私はカフカから正常にトピックを作成し

[2017-12-06 16:00:17,753] INFO [KafkaServer id=0] started (kafka.server.KafkaServer) 
[2017-12-06 16:03:19,347] INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions Hello-Nicola-0 (kafka.server.ReplicaFetcherManager) 
[2017-12-06 16:03:19,393] INFO Loading producer state from offset 0 for partition Hello-Nicola-0 with message format version 2 (kafka.log.Log) 
[2017-12-06 16:03:19,406] INFO Completed load of log Hello-Nicola-0 with 1 log segments, log start offset 0 and log end offset 0 in 35 ms (kafka.log.Log) 
[2017-12-06 16:03:19,408] INFO Created log for partition [Hello-Nicola,0] in /tmp/kafka-logs with properties {compression.type -> producer, message.format.version -> 1.0-IV0, file.delete.delay.ms -> 60000, max.message.bytes -> 1000012, min.compaction.lag.ms -> 0, 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 -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.ms -> 604800000, segment.bytes -> 1073741824, retention.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760, flush.messages -> 9223372036854775807}. (kafka.log.LogManager) 
[2017-12-06 16:03:19,409] INFO [Partition Hello-Nicola-0 broker=0] No checkpointed highwatermark is found for partition Hello-Nicola-0 (kafka.cluster.Partition) 
[2017-12-06 16:03:19,411] INFO Replica loaded for partition Hello-Nicola-0 with initial high watermark 0 (kafka.cluster.Replica) 
[2017-12-06 16:03:19,413] INFO [Partition Hello-Nicola-0 broker=0] Hello-Nicola-0 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) 

しかし、飼育係はショーログに記録します。

2017-12-06 16:03:19,299 [myid:] - INFO [ProcessThread(sid:0 cport:2181)::[email protected]] - Got user-level KeeperException when processing sessionid:0x1000177fb3d0001 type:create cxid:0x43 zxid:0x26 txntype:-1 reqpath:n/a Error Path:/brokers/topics/Hello-Nicola/partitions/0 Error:KeeperErrorCode = NoNode for /brokers/topics/Hello-Nicola/partitions/0 
2017-12-06 16:03:19,302 [myid:] - INFO [ProcessThread(sid:0 cport:2181)::[email protected]] - Got user-level KeeperException when processing sessionid:0x1000177fb3d0001 type:create cxid:0x44 zxid:0x27 txntype:-1 reqpath:n/a Error Path:/brokers/topics/Hello-Nicola/partitions Error:KeeperErrorCode = NoNode for /brokers/topics/Hello-Nicola/partitions 

私がメッセージを生成しようとした場合:

(カフカ中)210の

server.propertiesです:

broker.id=0 
listeners=PLAINTEXT://mylocal-0:9092 
num.network.threads=3 
num.io.threads=8 
socket.send.buffer.bytes=102400 
socket.receive.buffer.bytes=102400 
socket.request.max.bytes=104857600 
num.partitions=1 
num.recovery.threads.per.data.dir=1 
offsets.topic.replication.factor=1 
transaction.state.log.replication.factor=1 
transaction.state.log.min.isr=1 
log.retention.hours=168 
log.segment.bytes=1073741824 
log.retention.check.interval.ms=300000 
zookeeper.connect=localhost:2181 
zookeeper.connection.timeout.ms=6000 
group.initial.rebalance.delay.ms=0 

飼育係がどのブローカーをregistrerなかったようです。

お願いします。

+0

ブローカのログから、すべて正常に表示され、トピックの作成が検出され、ディスク上のログが正常に作成されました。ブローカーの設定を投稿してください。 –

+0

私はそれらの情報を投稿に追加しました。どうも –

答えて

1

エラーが見つかりました。サーバの起動時に 観察飼育係のログは、私が気づいた:

server.1=mylocal-0.:2888:3888 

をホスト名の後にドットで(。)。

私はDOMAINが満たされていないことがわかり内飼育係のconfigを生成するスクリプトが https://github.com/kubernetes/contrib/blob/master/statefulsets/zookeeper/zkGenConfig.sh

が探している相手からである:

HOST=`hostname -s` 
DOMAIN=`hostname -d` 

function print_servers() { 
    for ((i=1; i<=$ZK_REPLICAS; i++)) 
    do 
     echo "server.$i=$NAME-$((i-1)).$DOMAIN:$ZK_SERVER_PORT:$ZK_ELECTION_PORT" 
    done 
} 

私の場合(ローカルホスト)私はドメインを必要としないため、そう私はその変数を削除しました。

今、動物園とカフカはエラーなしで通信します。

関連する問題