Я пытаюсь отправить использованные данные Kafka во внешний интерфейс (JavaScript) через Spring-Websockets в проекте Spring MVC.
Чтобы установить связь между сервером и клиентом, у меня есть следующее.
Клиент (app.js)
function connect() {
var socket = new SockJS('/kafka-data-websocket');
stompClient = Stomp.over(socket);
stompClient.connect({}, function (frame) {
console.log('Connected: ' + frame);
stompClient.send("/app/fetchData");
stompClient.subscribe('/data/records', function (message) {
console.log(JSON.parse(message.body).content);
});
});
}
Сервер (KafkaController.java)
@Controller
public class KafkaController {
@MessageMapping("/fetchData")
@SendTo("/data/records")
public String fetchMetrics() {
//...
}
}
Чтобы использовать данные из определенной темы Kafka, я использую аннотацию @KafkaListener следующим образом:
public class KafkaReceiver {
@KafkaListener(topics = "mytopic")
public void receive(ConsumerRecord<?, ?> record) {
MyRecord m = new MyRecord(new Long(record.offset()), record.key().toString(), record.value().toString());
//...
}
}
И у меня есть подходящий класс KafkaConfig со всеми необходимыми bean-компонентами (как описано здесь < / а>).
