kafka_ex v0.13.0

View Source KafkaEx.Protocol.Common (kafka_ex v0.13.0)

A collection of common request generation and response parsing functions for the Kafka wire protocol.

Link to this section Summary

Functions

encode_nullable_string(text)
encode_string(text)
map_encode(elems, function)
parse_topics(topics_size, arg2, mod)
read_array(num_items, data_after_array, read_one)
topic_data(list)

Generate the wire representation for a list of topics.

Link to this section Functions

Link to this function

encode_nullable_string(text)

View Source 
@spec encode_nullable_string(String.t()) :: binary()
Link to this function

encode_string(text)

View Source 
@spec encode_string(String.t()) :: binary()
Link to this function

map_encode(elems, function)

View Source
Link to this function

parse_topics(topics_size, arg2, mod)

View Source
Link to this function

read_array(num_items, data_after_array, read_one)

View Source
Link to this function

topic_data(list)

View Source

Generate the wire representation for a list of topics.