Gravar dados no Amazon Kinesis Data Streams

Um produtor é uma aplicação que grava dados no Amazon Kinesis Data Streams. É possível criar produtores para o Kinesis Data Streams usando o AWS SDK para Java e a Kinesis Producer Library (KPL).

Se este é o primeiro contato com o Kinesis Data Streams, comece familiarizando-se com os conceitos e a terminologia apresentados em O que é o Amazon Kinesis Data Streams? e Use a AWS CLI para realizar operações do Amazon Kinesis Data Streams.

Para colocar dados no fluxo, é necessário especificar o nome do fluxo, uma chave de partição e o blob de dados que serão adicionados ao fluxo. A chave de partição é usada para determinar em que fragmento do fluxo o registro de dados será adicionado.

Todos os dados no fragmento são enviados para o mesmo operador que está processando o fragmento. A chave de partição usada usa depende da lógica do aplicativo. O número de chaves de partição normalmente deve ser muito maior que o número de fragmentos. Isso ocorre porque a chave de partição é usada para determinar como mapear um registro de dados para um determinado fragmento. Se houver um número suficiente de chaves de partição, os dados podem ser distribuídos uniformemente pelos fragmentos de um fluxo.