package orderer

Get desktop application:
View/edit binary Protocol Buffers messages

KafkaMessage is a wrapper type for the messages that the Kafka-based orderer deals with.

• oneof Type

  • KafkaMessageRegular regular = 1

  • KafkaMessageTimeToCut time_to_cut = 2

  • KafkaMessageConnect connect = 3

KafkaMessageConnect is posted by an orderer upon booting up. It is used to prevent the panic that would be caused if we were to consume an empty partition. It is ignored by all orderers when processing the partition.

Used in: KafkaMessage

• bytes payload = 1

KafkaMessageRegular wraps a marshalled envelope.

Used in: KafkaMessage

• bytes payload = 1

• uint64 config_seq = 2

• KafkaMessageRegular.Class class = 3

• int64 original_offset = 4

Used in: KafkaMessageRegular

• UNKNOWN = 0

• NORMAL = 1

• CONFIG = 2

KafkaMessageTimeToCut is used to signal to the orderers that it is time to cut block <block_number>.

Used in: KafkaMessage

• uint64 block_number = 1

KafkaMetadata is encoded into the ORDERER block to keep track of Kafka-related metadata associated with this block.

• int64 last_offset_persisted = 1

  LastOffsetPersisted is the encoded value for the Metadata message which is encoded in the ORDERER block metadata index for the case of the Kafka-based orderer.

• int64 last_original_offset_processed = 2

  LastOriginalOffsetProcessed is used to keep track of the newest offset processed if a message is re-validated and re-ordered. This value is used to deduplicate re-submitted messages from multiple orderer so that we don't bother re-processing it again.

• int64 last_resubmitted_config_offset = 3

  LastResubmittedConfigOffset is used to capture the newest offset of CONFIG kafka message, which is revalidated and resubmitted. By comparing this with LastOriginalOffsetProcessed, we could detemine whether there are still CONFIG messages that have been resubmitted but NOT processed yet. It's used as condition to block ingress messages, so we could reduce the overhead of repeatedly resubmitting messages as config seq keeps advancing.