KAFKA_API::clients::Interceptors Class Reference

Interceptors for Kafka clients. More...

#include <Interceptors.h>

Public Types
using	ThreadStartCb = std::function< void(const std::string &, const std::string &)>
	Callback type for thread-start interceptor.
using	ThreadExitCb = std::function< void(const std::string &, const std::string &)>
	Callback type for thread-exit interceptor.
using	BrokerStateChangeCb = std::function< void(int, const std::string &, const std::string &, int, const std::string &)>
	Callback type for broker-state-change interceptor.

Public Member Functions
Interceptors &	onThreadStart (ThreadStartCb cb)
	Set interceptor for thread start.
Interceptors &	onThreadExit (ThreadExitCb cb)
	Set interceptor for thread exit.
Interceptors &	onBrokerStateChange (BrokerStateChangeCb cb)
	Set interceptor for broker state change.
ThreadStartCb	onThreadStart () const
	Get interceptor for thread start.
ThreadExitCb	onThreadExit () const
	Get interceptor for thread exit.
BrokerStateChangeCb	onBrokerStateChange () const
	Get interceptor for broker state change.
bool	empty () const
	Check if there's no interceptor.

Detailed Description

Interceptors for Kafka clients.

---

The documentation for this class was generated from the following file:

• /home/runner/work/modern-cpp-kafka/modern-cpp-kafka/include/kafka/Interceptors.h