在超级账本结构上使用kafka订购服务创建频道时出现异常行为

问题描述 投票：0回答：1

所以我正在使用cli容器通过命令peer channel create -f config/allarewelcome.tx -o orderer.example.com:7050 -c allarewelcome创建一个通道，并且收到了这些消息。如您所见，最终创建了该通道，但我不知道发生了什么。有人有主意吗？

UTC [channelCmd] InitCmdFactory-> INFO 001 Endorser和orderer连接已初始化

UTC [cli.common] readBlock->信息002获得状态：＆{SERVICE_UNAVAILABLE}

UTC [channelCmd] InitCmdFactory->信息003已初始化Endorser和Orderer连接

UTC [cli.common] readBlock-> INFO 004获得状态：＆{SERVICE_UNAVAILABLE}

UTC [channelCmd] InitCmdFactory-> INFO 005 Endorser和orderer连接已初始化

UTC [cli.common] readBlock-> INFO 006获得状态：＆{SERVICE_UNAVAILABLE}

UTC [channelCmd] InitCmdFactory-> INFO 007 Endorser和orderer连接已初始化

UTC [cli.common] readBlock-> INFO 008获得状态：＆{SERVICE_UNAVAILABLE}

[UTC [channelCmd] InitCmdFactory->信息009已初始化Endorser和Orderer连接

UTC [cli.common] readBlock-> INFO 00a接收到的块：0

这是我的docker-compose.yaml文件上的kafka群集和zookeepers定义：

  kafka0.example.com:
    container_name: kafka0.example.com
    image: hyperledger/fabric-kafka
    restart: always
    environment:
      - KAFKA_MESSAGE_MAX_BYTES=103809024
      - KAFKA_REPLICA_FETCH_MAX_BYTES=103809024
      - KAFKA_UNCLEAN_LEADER_ELECTION_ENABLE=false
      - KAFKA_MIN_INSYNC_REPLICAS=2
      - KAFKA_DEFAULT_REPLICATION_FACTOR=2
      - KAFKA_ZOOKEEPER_CONNECT=zookeeper0.example.com:2181,zookeeper1.example.com:2181,zookeeper2.example.com:2181
      - KAFKA_BROKER_ID=1
    ports:
      - 9092:9092
      - 9093:9093
    networks:
      - basic
    depends_on:
      - zookeeper1.example.com
      - zookeeper2.example.com
      - zookeeper3.example.com

  kafka1.example.com:
    container_name: kafka1.example.com
    image: hyperledger/fabric-kafka
    restart: always
    environment:
      - KAFKA_MESSAGE_MAX_BYTES=103809024
      - KAFKA_REPLICA_FETCH_MAX_BYTES=103809024
      - KAFKA_UNCLEAN_LEADER_ELECTION_ENABLE=false
      - KAFKA_MIN_INSYNC_REPLICAS=2
      - KAFKA_DEFAULT_REPLICATION_FACTOR=2
      - KAFKA_ZOOKEEPER_CONNECT=zookeeper0.example.com:2181,zookeeper1.example.com:2181,zookeeper2.example.com:2181
      - KAFKA_BROKER_ID=2
    ports:
      - 10092:9092
      - 10093:9093
    networks:
      - basic
    depends_on:
      - zookeeper1.example.com
      - zookeeper2.example.com
      - zookeeper3.example.com

  zookeeper1.example.com:
    container_name: zookeeper0.example.com
    image: hyperledger/fabric-zookeeper
    environment: 
      - ZOO_MY_ID=1
      - ZOO_SERVERS=server.1=zookeeper1.example.com:2888:3888 server.2=zookeeper2.example.com:2888:3888 server.3=zookeeper3.example.com:2888:3888
    ports:
      - 2181:2181
      - 2888:2888
      - 3888:3888
    networks:
      - basic

  zookeeper2.example.com:
    container_name: zookeeper1.example.com
    image: hyperledger/fabric-zookeeper
    environment: 
      - ZOO_MY_ID=2
      - ZOO_SERVERS=server.1=zookeeper1.example.com:2888:3888 server.2=zookeeper2.example.com:2888:3888 server.3=zookeeper3.example.com:2888:3888
    ports:
      - 12181:2181
      - 12888:2888
      - 13888:3888
    networks:
      - basic

  zookeeper3.example.com:
    container_name: zookeeper2.example.com
    image: hyperledger/fabric-zookeeper
    environment: 
      - ZOO_MY_ID=3
      - ZOO_SERVERS=server.1=zookeeper1.example.com:2888:3888 server.2=zookeeper2.example.com:2888:3888 server.3=zookeeper3.example.com:2888:3888
    ports:
      - 22181:2181
      - 22888:2888
      - 23888:3888
    networks:
      - basic

这是来自订购者的日志：

UTC [fsblkstorage] newBlockfileMgr->信息014从块存储中获取块信息

UTC [comm.grpc.server] 1-> INFO 015流式呼叫已完成grpc.service = orderer.AtomicBroadcast grpc.method = Broadcast grpc.peer_address = 192.168.0.18：59044 grpc.code = OK grpc.call_duration = 107.803049ms

UTC [orderer.consensus.kafka] newChain->信息016 [频道：allarewele]起始链具有最后一个持久偏移量-3和最后记录的块[0]

UTC [orderer.commmon.multichannel] newChain->信息017创建并启动新链条allarewelcome

UTC [orderer.consensus.kafka] setupTopicForChannel->信息018 [频道：allarewele]设置此频道的主题...

UTC [common.deliver] deliveryBlocks-> WARN 019 [channel：allarewelcome]由于同意者错误，拒绝192.168.0.18:59042的传递请求

UTC [comm.grpc.server] 1->信息01a流式呼叫已完成grpc.service = orderer.AtomicBroadcast grpc.method =传送grpc.peer_address = 192.168.0.18：59042 grpc.code = OK grpc.call_duration = 112.653714ms

UTC [orderer.consensus.kafka] setupProducerForChannel-> INFO 01b [channel：allarewele]为该频道设置生产者...2020-01-08 14：56：58.253 UTC [orderer.consensus.kafka] startThread-> INFO 01c [频道：allarewelcome]成功设置了生产者

UTC [orderer.consensus.kafka] sendConnectMessage-> INFO 01d [频道：allarewele]即将发布CONNECT消息...

UTC [common.deliver] deliveryBlocks-> WARN 01e [channel：allarewelcome]由于同意者错误，拒绝192.168.0.18:59046的传递请求

UTC [comm.grpc.server] 1->信息01f流调用完成grpc.service = orderer.AtomicBroadcast grpc.method =传送grpc.peer_address = 192.168.0.18：59046 grpc.code = OK grpc.call_duration = 186.949863ms

UTC [common.deliver] deliveryBlocks-> WARN 020 [channel：allarewelcome]由于同意者错误，拒绝192.168.0.18:59052的传递请求

UTC [comm.grpc.server] 1->信息021流式呼叫已完成grpc.service = orderer.AtomicBroadcast grpc.method =传送grpc.peer_address = 192.168.0.18：59052 grpc.code = OK grpc.call_duration = 201.05081ms

[UTC [common.deliver] deliveryBlocks-> WARN 022 [channel：allarewelcome]由于同意者错误，拒绝192.168.0.18:59054的传递请求

UTC [comm.grpc.server] 1-> INFO 023流式呼叫已完成grpc.service = orderer.AtomicBroadcast grpc.method =传送grpc.peer_address = 192.168.0.18：59054 grpc.code = OK grpc.call_duration = 201.212849ms

UTC [orderer.consensus.kafka] startThread->信息024 [频道：allarewelcome] CONNECT消息已成功发布

UTC [orderer.consensus.kafka] setupParentConsumerForChannel-> INFO 025 [channel：allarewele]设置此通道的父使用者...

[UTC [orderer.consensus.kafka] startThread->信息026 [频道：allarewelcome]父消费者成功设置

UTC [orderer.consensus.kafka] setupChannelConsumerForChannel-> INFO 027 [channel：allarewele]设置此通道的通道使用者（起始偏移量：-2）...

[UTC [orderer.consensus.kafka] startThread->信息028 [channel：allarewele]成功设置了通道使用者

UTC [orderer.consensus.kafka] startThread-> INFO 029 [channel：allarewele]启动阶段已成功完成

UTC [comm.grpc.server] 1->信息02a流式呼叫已完成grpc.service = orderer.AtomicBroadcast grpc.method =传送grpc.peer_address = 192.168.0.18：59056 grpc.code = OK grpc.call_duration = 203.740188ms

提前感谢！

apache-kafka hyperledger-fabric channel
1个回答
0
投票

如果尚未创建频道，则会出现此错误。在这种情况下，请尝试：

./byfn.sh -m restart -c channelName

如果使用byfn，否则只需重新启动网络以清除数据。

此外，请确保在创建网络并创建通道时，您正在将通道名称传递给对等通道create。

无论如何，这也可能是与Kafka有关的错误。即使我没有使用Kafka，我在创建网络时也收到了此消息，但是我记得我读到一些有关缺少kafka环境变量的问题。考虑到它们是警告，因此您可以继续进行，无论如何您的频道似乎都已创建。

最新问题
© www.soinside.com 2019 - 2024. All rights reserved.