Печать данных Kafka KTable

У меня есть этот метод, который вводит полезную нагрузку JSON. Я хочу создать K-таблицу из этой полезной нагрузки, прочитать из нее данные и распечатать ее.

Пока что я должен создать KTable, но когда я перебираю его, элемент управления пропускает его.

Пожалуйста, может кто-нибудь помочь мне/направить меня, где я ошибаюсь или что мне не хватает?

Спасибо.

 public void twilioKTable(JsonNode payloadJson) throws JsonProcessingException {
        String payload = payloadJson.toString();
        final StreamsBuilder builder = new StreamsBuilder();
        final KTable<String, String> kTable = builder.table("testktable");

        kTable.toStream().map((key, value) -> new KeyValue<>(key, value))
                .foreach(new ForeachAction<String, String>() {
                    public void apply(String key, String value) {
                        System.out.println("From MAP " + key + ": Value " +
                                value);
                    }
                });
    }

person anmol    schedule 23.07.2021    source источник
comment
@OneCricketeer Нужно ли конвертировать в KStream? В обычной базе данных мы можем читать данные таблицы, используя первичный ключ. Здесь что-то подобное можно сделать?   -  person anmol    schedule 24.07.2021
comment
Если у вас есть доступ к KeyValueStore (что невозможно с методами DSL), вы можете повторить его. В противном случае звучит так, будто вам нужен ksqlDB.   -  person OneCricketeer    schedule 25.07.2021