将对象转换为ByteBuffer

Question

我的情况是，在spring.boot.version = 1.4.2上开发无法升级我们的引导版本(我们的服务是如此庞大)。

我们的服务需要卡夫卡。

因此，我使用spring-cloud-stream-binder-kafka实现了这个特性。

spring-cloud-stream-binder-kafka:1.1.2.RELEASE支持SpringBootVersion1.4.6，所以我可以实现这个特性。

到现在为止，情况还不错。

但是我们在我们的服务上使用AWS，您知道在AWS中没有kafka。

所以我试着使用spring-cloud-stream-binder-kinesis:1.0.0.RELEASE。

但是不幸的是，spring-cloud-stream-binder-kinesis:1.0.0.RELEASE版本支持bootVersion 2.0.0。

所以我必须使用Kinesis Producer Library来实现这个特性。

(我指https://github.com/awslabs/amazon-kinesis-producer/blob/master/java/amazon-kinesis-producer-sample/src/com/amazonaws/services/kinesis/producer/sample/SampleProducer.java)

我必须将Java发布到kinesis，因此我应该将Java传递给KinesisProducer.addUserRecord的data参数。

那么，如何将Java Object转换为ByteBuffer呢？

Answer 1

您需要首先将其转换为byte[]，然后在该数组上调用ByteBuffer.wrap()。

您可以使用Java序列化来实现这一点，但我强烈建议使用某种形式的JSON序列化。这将使其他消费者很容易使用这些记录，这也是首先使用类似Kinesis的原因之一。

而且，AWS确实提供了一个卡夫卡管理服务。我没有使用过它，所以无法与一个自我管理的Kafka集群相比，也不知道它是否在所有地区都可用。但是如果你已经有了使用卡夫卡的工具和经验，这可能是一个更好的选择。