AWS托管服务中的Apache Storm可替代方案是Amazon Kinesis Data Streams。
Amazon Kinesis Data Streams是一个可扩展的和可持久化的实时数据流处理服务,可以使用Amazon Kinesis SDK和CLI来进行管理和编程。下面是一个使用Java SDK发送数据到Kinesis Data Streams的示例代码:
import software.amazon.awssdk.auth.credentials.DefaultCredentialsProvider;
import software.amazon.awssdk.regions.Region;
import software.amazon.awssdk.services.kinesis.KinesisClient;
import software.amazon.awssdk.services.kinesis.model.PutRecordRequest;
import software.amazon.awssdk.services.kinesis.model.PutRecordResponse;
public class KinesisProducer {
public static void main(String[] args) {
String streamName = "my-stream";
Region region = Region.US_EAST_1;
String partitionKey = "partitionKey-1";
String data = "Example data";
KinesisClient kinesisClient = KinesisClient.builder()
.region(region)
.credentialsProvider(DefaultCredentialsProvider.create())
.build();
PutRecordRequest request = PutRecordRequest.builder()
.streamName(streamName)
.partitionKey(partitionKey)
.data(data.getBytes())
.build();
PutRecordResponse response = kinesisClient.putRecord(request);
System.out.println("Record sent. Sequence number: " + response.sequenceNumber());
}
}