How did you solve producer fencing mechanism which was built into Bookkeeper with Kafka (Without considering the write proxy)?