KafkaEx.Util

Summary

bytes(data)
create_message(value, key \\ nil)
create_message_set(value, key \\ nil)
current_timestamp()
parse_key(crc, attributes, arg3)
parse_message(arg1)
parse_message_set(list, arg2)
parse_value(crc, attributes, key, arg4)

Functions

bytes(data)
create_message(value, key \\ nil)
create_message_set(value, key \\ nil)
current_timestamp()
parse_key(crc, attributes, arg3)
parse_message(arg1)
parse_message_set(list, arg2)
parse_value(crc, attributes, key, arg4)