mattcasters opened a new issue, #21948: URL: https://github.com/apache/beam/issues/21948
### What happened? The javadoc for class KinesisIO is not up-to-date with respect to the writing of messages. https://beam.apache.org/releases/javadoc/current/org/apache/beam/sdk/io/aws2/kinesis/KinesisIO.html Specifically this part is causing (me) some confusion: ``` data.apply(KinesisIO.write() .withStreamName("streamName") .withPartitionKey(KV::getKey) .withSerializer(KV::getValue); ``` That is to say that the `withSerializer` method simply doesn't exist. From the KinesisIO source it appears that Write expects a `PCollection<byte[]>`, not a KV of sorts. ### Issue Priority Priority: 0 ### Issue Component Component: io-java-kinesis -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: github-unsubscr...@beam.apache.org.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
