Skip to content

Commit

Permalink
restore double dict
Browse files Browse the repository at this point in the history
  • Loading branch information
didimelli committed Aug 12, 2024
1 parent a2c100f commit de62daf
Showing 1 changed file with 5 additions and 3 deletions.
8 changes: 5 additions & 3 deletions faust/transport/drivers/aiokafka.py
Original file line number Diff line number Diff line change
Expand Up @@ -1242,9 +1242,11 @@ def _new_producer(
self, transactional_id: Optional[str] = None
) -> aiokafka.AIOKafkaProducer:
return self._producer_type(
**self._settings_default(),
**self._settings_auth(),
**self._settings_extra(),
**{
**self._settings_default(),
**self._settings_auth(),
**self._settings_extra(),
}
transactional_id=transactional_id,
)

Expand Down

0 comments on commit de62daf

Please sign in to comment.