Fix collector function.
Fix collector function.

stealthly/go_kafka_client,CrowdStrike/go_kafka_client,stealthly/go_kafka_client,CrowdStrike/go_kafka_client,elodina/go_kafka_client,elodina/go_kafka_client