TsgcWSPClient_Kafka › Events › OnKafkaMessage

OnKafkaMessage Event

Fires for each record returned while consuming.

Syntax

property OnKafkaMessage: TsgcKafkaMessageEvent;
// procedure(Sender: TObject; const aMessage: TsgcKafkaMessage) of object

Default Value

—

Remarks

Fires for each record returned while consuming (Poll/FetchMessages). The aMessage argument exposes Topic, Partition, Offset, GetKeyString and GetValueString.

Example

procedure TForm1.KafkaMessage(Sender: TObject; const aMessage: TsgcKafkaMessage);
begin
  Log(aMessage.GetValueString);
end;

Back to Events