Notas prácticas de Apache Kafka - 4.5 Producer Interceptor

Los interceptores de Kafka pueden funcionar tanto en el lado del productor como en el del consumidor. Echemos un vistazo rápido al interceptor del productor.

Para los productores, los interceptores brindan a los usuarios la oportunidad de personalizar el mensaje, como modificarlo, antes de que se envíe el mensaje y antes de la lógica de devolución de llamada del productor. Se pueden definir múltiples interceptores para formar una cadena.

Cuando desarrollamos un interceptor, necesitamos implementar la interfaz org.apache.kafka.clients.producer.ProducerInterceptor, que tiene 2 métodos principales:

Definimos 2 Interceptores:

Interceptor1:

Interceptor2:

Puede ver que después de serializar el mensaje, tiene la oportunidad antes de enviar el mensaje y producir Realizar algunas personalizaciones antes de llamar a la devolución de llamada lógica.

Puedes ver el objeto de usuario serializado.