Reactive Interaction Gateway v3.0.0-alpha.2

RigKafka.Client.GroupSubscriber (Reactive Interaction Gateway v3.0.0-alpha.2) View Source

The group subscriber process handles messages from none or many partitions.

Link to this section Summary

Types

kafka_headers()

Functions

kafka_message(args \\ [])
kafka_message(record, args)

Link to this section Types

Link to this type

kafka_headers()

View Source

Specs

kafka_headers() :: list()

Link to this section Functions

Link to this macro

kafka_message(args \\ [])

View Source (macro)
Link to this macro

kafka_message(record, args)

View Source (macro)