pip_services3_kafka.connect.KafkaSubscription module

class pip_services3_kafka.connect.KafkaSubscription.KafkaSubscription(topic: Optional[str] = None, group_id: Optional[str] = None, options: Optional[Any] = None, handler: Optional[cimpl.Consumer] = None, listener: Optional[pip_services3_kafka.connect.IKafkaMessageListener.IKafkaMessageListener] = None)

Bases: object

The KafkaSubscription class defines fields for Kafka subscriptions