Refactored Kafka Producer and Consumer bridges to avoid leaking resources during crashes at creation.