Como integrou o Apache Kafka na sua aplicação Java?

Para integrar o Apache Kafka numa aplicação Java, utilizei o cliente oficial Kafka, fornecido pela biblioteca kafka-clients. Os passos principais incluíram:

1. Adicionar a dependência no pom.xml (Maven) ou build.gradle (Gradle).
2. Configurar as propriedades do produtor e do consumidor, como os endereços dos brokers, os serializadores/deserializadores de chaves e valores.
3. Criar instâncias de KafkaProducer e KafkaConsumer.
4. Enviar mensagens usando producer.send() e receber mensagens através de consumer.poll().

Exemplo de envio de mensagem:

Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");

KafkaProducer<String, String> producer = new KafkaProducer<>(props);
producer.send(new ProducerRecord<>("topicName", "key", "value"));
producer.close();

Também é importante tratar corretamente as exceções e gerir o ciclo de vida do consumidor para evitar perda de mensagens.