Странное поведение при создании канала с сервисом заказа кафки на фабрике гиперледжеров - PullRequest
Новая
       5

Странное поведение при создании канала с сервисом заказа кафки на фабрике гиперледжеров

0 голосов
/ 08 января 2020

Итак, я создавал канал, используя контейнер cli с командой peer channel create -f config/allarewelcome.tx -o orderer.example.com:7050 -c allarewelcome, и я получаю эти сообщения. Канал в итоге создается, как вы видите, но мне интересно, что происходит. У кого-нибудь есть идея?

UT C [channelCmd] InitCmdFactory -> INFO 001 Инициализированные соединения с заказчиком и заказчиком

UT C [cli.common] readBlock -> ИНФОРМАЦИЯ 002 Получен статус: & {SERVICE_UNAVAILABLE}

UT C [channelCmd] InitCmdFactory -> ИНФО 003 Инициализированные соединения с заказчиком и заказчиком

UT C [cli.common] readBlock -> ИНФОРМАЦИЯ 004 Получен статус: & {SERVICE_UNAVAILABLE}

UT C [channelCmd] InitCmdFactory -> ИНФО 005 Инициализированы соединения индоссатора и заказчика

UT C [cli.common] readBlock -> ИНФОРМАЦИЯ 006 Получен статус: & {SERVICE_UNAVAILABLE}

UT C [channelCmd] InitCmdFactory -> ИНФО 007 Инициализированы соединения с индоссантом и заказчиком

UT C [cli.common] readBlock -> ИНФОРМАЦИЯ 008 Получил статус: & {SERVICE_UNAVAILABLE}

UT C [channelCmd] InitCmdFactory -> ИНФО 009 Инициализированы соединения индоссатора и заказчика

UT C [cli.common] readBlock -> ИНФОРМАЦИЯ 00а Полученный блок: 0

Вот мои определения кластеров kafka и zookeepers в моем файле docker -compose.yaml: 

  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

А вот мои журналы от заказчика:

UT C [fsblkstorage] newBlockfileMgr -> INFO 014 Получение информации о блоке из хранилища блоков

UT C [comm.grp c .server] 1 -> потоковый вызов INFO 015 выполнено grp c .service = orderer.AtomicBroadcast grp c .method = Broadcast grp c .peer_address = 192.168.0.18: 59044 grp c .code = OK grp c .call_duration = 107.803049ms

UT C [orderer.consensus.kafka] newChain -> INFO 016 [channel: allarewelcome] Стартовая цепочка с последним постоянным смещением -3 и последним записанным блоком [0]

UT C [orderer.commmon.multichannel] newChain -> INFO 017 Создание и запуск новой цепочки allarewelcome

UT C [orderer.consensus.kafka] setupTopicForChannel -> INFO 018 [channel: allarewelcome] Настройка topi c для этого канала ...

UT C [common.deliver ] deliveryBlocks -> WARN 019 [channel: allarewelcome] Отклонение запроса на доставку для 192.168.0.18:59042 из-за ошибки согласия

UT C [comm.grp c .server] 1 -> Потоковая передача INFO 01a вызов завершен grp c .service = orderer.AtomicBroadcast grp c .method = доставить grp c .peer_address = 192.168.0.18: 59042 grp c .code = OK grp c .call_duration = 112.653714ms

UT C [orderer.consensus.kafka] setupProducerForChannel -> INFO 01b [channel: allarewelcome] Настройка производителя для этого канала ... 2020-01-08 14: 56: 58.253 UT C [orderer.consensus.kafka] startThread -> INFO 01 c [channel: allarewelcome] Производитель успешно настроен

UT C [orderer.consensus.kafka] sendConnectMessage -> INFO 01d [канал: allarewelcome ] Собирается опубликовать сообщение CONNECT ...

UT C [common.deliver] deliveryBlocks -> WARN 01e [channel: allarewelcome] Отклонение запроса на доставку для 192.168.0.18:59046 из-за ошибки согласного

UT C [co mm.grp c .server] 1 -> INFO 01f потоковый вызов завершен grp c .service = orderer.AtomicBroadcast grp c .method = доставить grp c .peer_address = 192.168.0.18: 59046 grp c .code = OK grp c .call_duration = 186.949863ms

UT C [common.deliver] deliveryBlocks -> WARN 020 [channel: allarewelcome] Отклонение запроса на доставку для 192.168.0.18:59052 из-за ошибка согласователя

UT C [comm.grp c .server] 1 -> INFO 021 потоковый вызов завершен grp c .service = orderer.AtomicBroadcast grp c .method = Deliver grp c .peer_address = 192.168.0.18: 59052 grp c .code = OK grp c .call_duration = 201.05081ms

UT C [общ. Delivery] DeliveryBlocks -> WARN 022 [channel: allarewelcome] Отклонение запроса на доставку для 192.168.0.18:59054 из-за ошибки согласного

UT C [comm.grp c .server] 1 -> INFO 023 потоковый вызов завершен grp c .service = orderer.AtomicBroadcast grp c .method = доставить grp c .peer_address = 192.168.0.18: 59054 grp c .code = OK grp c .call_duration = 201.212849ms

UT C [orderer.consensus.kafka] startThread -> INFO 024 [канал: allarewelcome] Сообщение CONNECT успешно отправлено

UT C [orderer.consensus.kafka] setupParentConsumerForChannel - > INFO 025 [channel: allarewelcome] Настройка родительского потребителя для этого канала ...

UT C [orderer.consensus.kafka] startThread -> INFO 026 [channel: allarewelcome] Настройка родительского потребителя успешно

UT C [orderer.consensus.kafka] setupChannelConsumerForChannel -> INFO 027 [channel: allarewelcome] Настройка потребителя канала для этого канала (начальное смещение: -2) ... * 1 068 *

UT C [orderer.consensus.kafka] startThread -> INFO 028 [channel: allarewelcome] Потребитель канала успешно настроен

UT C [orderer.consensus.kafka] startThread - > INFO 029 [channel: allarewelcome] Стартовая фаза успешно завершена

UT C [comm.grp c .server] 1 -> INFO 02a потоковый вызов завершен grp c .service = orderer.AtomicBroadcast grp c .method = доставить grp c .peer_address = 192.168.0.18: 59056 grp c .code = OK grp c .call_duration = 203.740188ms

Заранее спасибо!

1 Ответ

1 голос
/ 09 января 2020

Вы можете получить эту ошибку, если канал еще не создан. В этом случае попробуйте: 

./byfn.sh -m restart -c channelName

, если вы используете byfn, в противном случае просто перезапустите сеть, очистив данные.

Кроме того, убедитесь, что при создании сети и создании channel, вы передаете имя канала равноправному каналу create.

В любом случае, это также может быть ошибка, связанная с Kafka. Я лично тоже получил это сообщение при создании сети, даже если я не использую Kafka, но я помню, что прочитал кое-что об этой проблеме, связанной с отсутствующей переменной среды kafka. Учтите, что они предупреждают, поэтому вы можете продолжить, ваш канал в любом случае создается.

...