我利用aws-kcl-java库构建了一个自定义使用者，用于消费来自kinesis数据流的数据。我需要为这个消费者为我们的构建管道编写集成测试。localstack似乎是唯一的选项，但提供localstack环境会引发以下错误：

2020-12-24 22:41:48.395 ERROR 1083038 --- [  restartedMain] s.amazon.kinesis.coordinator.Scheduler   : Worker.run caught exception, sleeping for 1000 milli seconds!

java.lang.RuntimeException: software.amazon.awssdk.core.exception.SdkClientException: Illegal length for VALUE_STRING: 2468939540903325029

有没有其他方法可以为kcl编写集成测试？我是否应该使用awsdk编写消费者，并使用abstractkinesisclient编写mock kinesis？