Código fuente de la plantilla de arranque
Eliminar los comentarios configurados en oyentes y oyentes anunciados. Puede configurar la IP externa y el número de puerto del servidor conectado según sea necesario. Aquí demuestro la selección del host local local y el puerto predeterminado 9092.
KafkaTemplate Esta clase incluye un productor y proporciona una manera conveniente de enviar datos a temas de Kafka.
El código fuente del método send() La clase KafkaTemplate también sobrecarga muchos métodos send(). Puedes echar un vistazo al código fuente si es necesario.
Envía datos a través de la clase de plantilla KafkaTemplate.
Kafka template.send (tema de cadena, clave k, datos v), el primer parámetro es el tema, el segundo parámetro es el objeto enviado y el tercer parámetro son los datos enviados. Configure temas de escucha de usuarios a través de la anotación @KafkaListener.
Bootstrap-servers: dirección del servidor kafka (pueden ser múltiples)
Consumer.group-id: especifica el nombre del grupo predeterminado.
Si no se especifica, se informará.
1. Más temprano: cuando se envía una compensación en cada partición, el consumo comienza desde la compensación enviada; cuando no se envía ninguna compensación, el consumo comienza desde cero;
2. Más reciente: cuando hay un desplazamiento comprometido en cada partición, el consumo comenzará a partir del desplazamiento enviado; cuando no hay un desplazamiento comprometido, se consumirán los datos recién generados en la partición.
3.Ninguno: cuando el desplazamiento comprometido existe en cada partición del tema, el consumo comenzará después del desplazamiento, siempre que la partición no tenga un desplazamiento comprometido, se generará una excepción.
Esta propiedad también debe configurarse, de lo contrario se informará un error.
Cuando se utiliza Kafka para enviar y recibir mensajes, el productor necesita serializar y el consumidor necesita deserializar. Debido a que el byte [] se transmite desde la red, el contenido real del mensaje enviado por el productor solo se puede obtener mediante deserialización. Para que los mensajes puedan transmitirse a través de la red.
Consumer.key-deserializer y consumer.value-deserializer son deserializadores de clave/valor de consumidor.
Producer.key-deserializer y Producer.value-deserializer son serializaciones de claves/valores de productor.
StringDeserializer es un deserializador de cadenas incorporado.
StringSerializer es un método de serialización de cadenas integrado. El paquete de código fuente de
org también tiene muchos tipos de métodos de serialización y deserialización. Apache. Kafka.com mon.Serialization
Para personalizar el método de serialización, debe implementar el serializador de interfaz.
Para personalizar el método de deserialización, es necesario implementar el deserializador de interfaz.
Consulte el sitio web para obtener más detalles.
/shiru kai/article/details/82152172
Esta es la información de configuración del consumidor de Kafka. Cada consumidor generará esta información de configuración.
Visite http://localhost:8080/kafka y podrá ver los mensajes impresos en la consola.