TsgcWSPClient_Kafka › Events › OnKafkaRebalance

OnKafkaRebalance Event

Fires when the consumer group is (re)assigned.

Syntax

property OnKafkaRebalance: TsgcKafkaRebalanceEvent;
// procedure(Sender: TObject; const aGroupId, aMemberId: string; aGenerationId: Integer) of object

Default Value

—

Remarks

Fires when the consumer group is (re)assigned, after JoinGroup/SyncGroup when partitions are assigned to this member.

Example

procedure TForm1.KafkaRebalance(Sender: TObject; const aGroupId, aMemberId: string;
  aGenerationId: Integer);
begin
  Log(Format('Rebalance group=%s member=%s generation=%d',
    [aGroupId, aMemberId, aGenerationId]));
end;

Back to Events