class EnsLib.Kafka.InboundAdapter
extends EnsLib.Messaging.Common, EnsLib.Kafka.Common, EnsLib.PEX.InboundAdapter
• parameter SETTINGS = "Topic:Kafka Settings,GroupID:Kafka Settings,ReceiveSettings:Kafka Settings";
List of properties can be set as settings in the configuration file
format is a comma separated list of property names
• property GroupID
as %String(MAXLEN=100);
Kafka consumer group ID. Within the same group, each message is only read once.
• property ReceiveSettings
as %String(MAXLEN=300);
Parameters to receive messages as JSON string
• property Topic
as %String(MAXLEN=100);
Topic that the messages are read from.
• method OnInit()
as %Status
This user callback method is called just after %OnNew()
