def METHOD_NAME(self, message: Message[KafkaPayload]) -> None:
    self.__producer.produce(
        topic=self.__producer_topic,
        key=None,
        value=message.payload.value,
        on_delivery=partial(self.callback, committable=message.committable),
        headers=message.payload.headers,
    )