other consumers are connected.

changes on active consumer.

Commands to probe the state of connection.

/ Create a new Producer on a topic, assigning the given producer_id, / all messages sent with this producer_id will be persisted on the topic.

/ Response from CommandProducer.

Message sent by broker to client when a topic has been forcefully terminated and there are no more messages left to consume.

Reset an existing consumer to a particular message id.

Acks can contain a flag to indicate the consumer received an invalid message that got discarded before being passed on to the application.

Each protocol version identify new features that are incrementally added to the protocol.