KafkaSubscription

Description

The KafkaSubscription class defines fields for Kafka subscriptions.

Properties

Topic

Topic

public string Topic { get; set; }

GroupId

Group id

public string GroupId { get; set; }

Handler

Handler

public IConsumer<byte[],byte[]> Handler { get; set; }

Listener

Listener

public IKafkaMessageListener Listener { get; set; }

Token

Token

public CancellationTokenSource Token { get; set; }