Intercept broker operation in Kafka

[ravi singh]

How do I intercept Kakfa broker operation so that features such as
security,logging,etc can be implemented as a pluggable filter. For example
we have "BrokerFilter" class in ActiveMQ , Is there anything similar in
Kafka?

-- 
*Regards,*
*Ravi*