Struct KafkaHandler 

pub struct KafkaHandler;

Trait Implementations

impl ProtocolHandler for KafkaHandler

fn parse_request(&self, buf: &[u8]) -> Option<String>

Parse request bytes → summary for event list

fn extract_full_command(&self, buf: &[u8]) -> Option<String>

Extract full command from request (for Detail panel, copy, edit)

fn parse_response(&self, buf: &[u8]) -> Option<String>

Parse response bytes → short summary

fn format_response_detail(&self, buf: &[u8]) -> Option<String>

Format response detail (for Detail panel)

fn needs_request_buffering(&self) -> bool

Does this protocol need request buffering across reads?

fn needs_response_buffering(&self) -> bool

Does this protocol need response buffering across reads?

fn request_complete(&self, buf: &[u8]) -> bool

Is the request buffer complete?

fn response_complete(&self, buf: &[u8]) -> bool

Is the response buffer complete?

fn default_port(&self) -> u16

Default port for this protocol.

fn to_replay_command(&self, ev: &ProxyEvent) -> String

Generate a replayable command string (for yank/copy)

fn is_frame_based(&self) -> bool

Is this a frame-based protocol with custom proxy logic? (AMQP)

fn message_length(&self, _buf: &[u8]) -> Option<usize>

Length of the first complete message in buf (for discarding unparseable messages). The length should include any header bytes (i.e., total bytes to drain). Returns None if the protocol doesn’t have self-describing message boundaries.

fn capture_handshake( &self, _payload: &[u8], _direction: Direction, ) -> HandshakeAction

In capture mode, should this packet be skipped? (e.g., connection handshake) handshake_done is false until this method returns HandshakeAction::Done.