All, I've shared with you a link below to a document detailing a limitation of Beam's metric system, and its impact on KafkaIO and Kafka clients as a whole. I have outlined a handful of proposed solutions, and I'd greatly appreciate your time looking at this. Thank you all in advance!
Best, Ozzie Fernandez https://docs.google.com/document/d/19JyO-5NnWJMVtnPq0T1ZIo9T2AWpA1rZsYuIVMlCVyM/edit?usp=sharing