Module contents

class heizer.HeizerConfig(config=None)

Parameters:

config (Optional[Dict[str, str]]) –

property value: Dict[str, str]

Return kafka configurations

Returns:

config – The dict contains kafka configurations

Return type:

dict

class heizer.HeizerMessage(message)

Parameters:

message (Message) –

formatted_value: Optional[Any] = None

headers: Optional[dict[str, str]]

key: Optional[str]

message: Message

partition: int

topic: Optional[str]

value: Optional[str]

class heizer.HeizerTopic(name, partitions=None)

Parameters:

• name (str) –

• partitions (Optional[List[int]]) –

name: str

property partitions: List[int]

property topic_partitions: List[TopicPartition]

class heizer.consumer(*, topics, config=<heizer.config.HeizerConfig object>, call_once=False, stopper=None, deserializer=None, is_async=False)

A decorator to create a consumer

Parameters:

• topics (List[HeizerTopic]) –

• config (HeizerConfig) –

• call_once (bool) –

• stopper (Optional[Callable[[...], bool]]) –

• deserializer (Optional[Type[BaseModel]]) –

• is_async (bool) –

call_once: bool = False

config: HeizerConfig = <heizer.config.HeizerConfig object>

deserializer: Optional[Type[BaseModel]] = None

is_async: bool = False

stopper: Optional[Callable[[...], bool]] = None

topics: List[HeizerTopic]

class heizer.producer(topics, config=<heizer.config.HeizerConfig object>, message_encoder=<function _default_encoder>, call_back=None, key=None, headers=None)

Parameters:

• topics (List[HeizerTopic]) –

• config (HeizerConfig) –

• message_encoder (Callable[[...], bytes]) –

• call_back (Optional[Callable[[...], Any]]) –

• key (Optional[str]) –

• headers (Optional[Dict[str, str]]) –

call_back: Optional[Callable[[...], Any]] = None

config: HeizerConfig = <heizer.config.HeizerConfig object>

headers: Optional[Dict[str, str]] = None

key: Optional[str] = None

message_encoder()

Parameters:

value (Union[Dict[Any, Any], str, bytes]) –

Returns:

bytes

Return type:

bytes

Default Kafka message encoder, which will encode inputs to bytes

topics: List[HeizerTopic]