kafe_consumer_subscriber.md

Module kafe_consumer_subscriber

• Data Types
• Function Index
• Function Details

Behaviours: gen_server.

This module defines the kafe_consumer_subscriber behaviour.
Required callback functions: init/4, handle_message/2.

Data Types

message()

message() = #message{}

Function Index

message/2

Get message attributes.

Function Details

message/2

message(Message, Field) -> any()

Get message attributes.

Example:

 Topic = kafe_consumer_subscriber:message(Message, topic).