问题描述
我已经写了一个Kinesis使用者,并且试图在本地运行它。关于运动学的工作,我不了解两个部分:
- 为什么要运行kinesis流需要dynamoDB端点?
- 当我的使用者代码启动时,我添加了调试点以获取确切的失败位置,因此在“同步Kinesis碎片信息”作为控制台消息之后,它将引发异常。请求对象看起来像: “ POST空/标头:(内容长度:42,X-Amz目标:Kinesis_20131202.DescribeStream,内容类型:application / x-amz-json-1.1,)”
我不确定哪里出了问题,但是在第一次尝试后它显示: 控制台上的“无法识别的令牌'不能':期望(JSON字符串,数字,数组,对象或令牌'null','true'或'false')”。
一些错误日志::
INFO [2020-09-21 06:05:31,106] org.eclipse.jetty.server.Server: Started @138321ms
INFO [2020-09-21 06:05:33,618] com.amazonaws.services.kinesis.clientlibrary.lib.worker.Worker: Initialization attempt 1
INFO [2020-09-21 06:05:33,618] com.amazonaws.services.kinesis.clientlibrary.lib.worker.Worker: Initializing LeaseCoordinator
INFO [2020-09-21 06:05:35,936] com.amazonaws.services.kinesis.clientlibrary.lib.worker.Worker: Syncing Kinesis shard info
INFO [2020-09-21 06:23:54,801] com.amazonaws.protocol.json.JsonContent: Unable to parse HTTP response content
! com.fasterxml.jackson.core.JsonParseException: Unrecognized token 'Cannot': was expecting (JSON String,Number,Array,Object or token 'null','true' or 'false')
! at [Source: (byte[])"Cannot POST /local/
! "; line: 1,column: 8]
.
.
.
ERROR [2020-09-21 06:23:55,138] com.amazonaws.services.kinesis.clientlibrary.lib.worker.ShardSyncTask: Caught exception while sync'ing Kinesis shards and leases
! com.amazonaws.services.kinesis.model.AmazonKinesisException: null (Service: AmazonKinesis; Status Code: 404; Error Code: null; Request ID: null)
! at com.amazonaws.http.AmazonHttpClient$RequestExecutor.handleErrorResponse(AmazonHttpClient.java:1639)
! at com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeOneRequest(AmazonHttpClient.java:1304)
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)