## providers.mongokafka.MongoKafkaDaoPublisherFactory

<span id="hexkit.providers.mongokafka.MongoKafkaDaoPublisherFactory"></span>


A provider implementing the DaoPublisherFactoryProtocol based on MongoDB and


Usage

``` python
providers.mongokafka.MongoKafkaDaoPublisherFactory(
    *, config, event_publisher, db_client
)
```


Apache Kafka.


## Methods

| Name | Description |
|----|----|
| [__init__()](#__init__) | Please do not call directly! Should be called by the [construct](providers.mongodb.MongoDbDaoFactory.md#hexkit.providers.mongodb.MongoDbDaoFactory.construct) method. |
| [construct()](#construct) | Setup and teardown an instance of the provider. |

<span id="__init__"></span>

<span id="hexkit.providers.mongokafka.MongoKafkaDaoPublisherFactory.__init__"></span>


#### \_\_init\_\_()


Please do not call directly! Should be called by the [construct](providers.mongodb.MongoDbDaoFactory.md#hexkit.providers.mongodb.MongoDbDaoFactory.construct) method.


Usage

``` python
__init__(*, config, event_publisher, db_client)
```


<span id="hexkit.providers.mongokafka.MongoKafkaDaoPublisherFactory.construct"></span>

------------------------------------------------------------------------


#### construct()


Setup and teardown an instance of the provider.


Usage

``` python
construct(*, config, kafka_producer_cls=AIOKafkaProducer)
```


This method will automatically close the DB connection upon exit.


##### Parameters


`config: MongoKafkaConfig`  
MongoDB-specific config parameters.


##### Returns


`AsyncGenerator[MongoKafkaDaoPublisherFactory, None]`  
An instance of the provider.