public final class LSPatch public constructor(options: org.json.JSONObject, onDiscovery: (org.json.JSONObject) -> kotlin.Unit, onData: (org.json.JSONObject) -> kotlin.Unit, onStatus: (org.json.JSONObject) -> kotlin.Unit
我应该使用Kafka Streams来实现这一点吗?我是Kafka Streams的新手,任何建议和指导都会很有帮助。jsonObject;
jsonObject = new JSONObject(record);return new KeyValue<String,String>(jsonObject.get("sender").toString(), record);
传统的函数式语言根据初始值和列表上的累加器来考虑reduce。在Java语言中,事情要复杂得多,因为它需要BinaryOperator。我想知道我们是否有更好的方法来编写这种函数: // paths is a list of string(child.get(path) instanceof JsonObject)) {
// We do overri
stacktrace=java.lang.IllegalStateException at org.apache.kafka.streams.processor.internals.ProcessorNode.lambda(SourceNode.java:96)
at org.apache.kafka.