1. Em có thể tham khả source code đơn giản này nhé
2. Nó chỉ đơn giản là tạo ra 1 topic hello-world, sau đó publisher sẽ gửi message có dạng

{
  "type" : "hello",
  "payload" : "Hello World"
}

Vào topic "hello-world". Lúc này message sẽ nằm ở Kafka. Sau đó consumer sẽ gọi lên Kafka để lấy message từ topic "hello-world" dó và truyền cho lớp HelloMessageHandler để thực hiện việc in ra console thôi em ạ.

3. Về giao tiếp với DB thì nó cũng chỉ cần thêm lớp repository vào lớp HelloMessageHandler và save data vào DB thế là xong em ạ.