Use AWS SDK V2 Kinesis with localstack.

kinesis-v2-localstack.sc

import $ivy.`software.amazon.awssdk:kinesis:2.5.31`
import $ivy.`software.amazon.awssdk:netty-nio-client:2.5.31`

def localAwsClient[Builder <: AwsClientBuilder[Builder, _]](builder: Builder, endpoint: String): Builder = {
  val creds = AwsBasicCredentials.create("dummy", "dummy")
  builder
    .endpointOverride(URI.create(endpoint))
    .region(Region.US_EAST_1)
    .credentialsProvider(StaticCredentialsProvider.create(creds))
}

val kinesisClient = localAwsClient(
  KinesisAsyncClient
    .builder()
    .httpClient(NettyNioAsyncHttpClient.builder().protocol(Protocol.HTTP1_1)
    .buildWithDefaults(
      AttributeMap
        .builder()
        .put(SdkHttpConfigurationOption.TRUST_ALL_CERTIFICATES, java.lang.Boolean.TRUE)
        .build()
     )),
  "http://localhost:4568"
).build()