我正在尝试使用Eclipse Paho创建一个Java Mqtt客户端,它可以使用AwsIotWebSocketUrlSigner的getSignedUrl方法生成的SigV4预签名网址连接到亚马逊网络服务(ExceptionHelper.java:38) at java.lang.Thread.run(Thread.j
对于这一点,使用beam.sdk.transforms.Distinct来读取带有distinct的记录。但却在错误之下 at org.apache.beam.sdk.transforms.GroupByKey.expand(GroupByKey.java:193)
at org.apache.beam.sdk</e