java - 打印 Kafka KTable 数据

Question

我有这个方法，它输入一个 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);
                    }
                });
    }

Answer 1

您还可以使用.peek()方法 inKStream打印具有值的每个键