Trabalhei um pouco com o Kafka no passado e, ultimamente, há um requisito para portar parte do pipeline de dados no AWS Kinesis Stream. Agora eu li que o Kinesis é efetivamente um garfo do Kafka e compartilha muitas semelhanças.

No entanto, não consegui ver como podemos fazer com que vários consumidores leiam do mesmo fluxo, cada um com seu deslocamento correspondente. Há um número de sequência fornecido para cada registro de dados, mas não foi possível encontrar nada específico para o consumidor (ID do grupo Kafka?).

É realmente possível ter diferentes consumidores com diferentes taxas de ingestão no mesmo AWS Kinesis Stream?