У меня есть этот метод, который вводит полезную нагрузку 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);
}
});
}
.print()
, который вы можете использовать вместо него - person OneCricketeer   schedule 24.07.2021