Estoy empezando a aprender Kafka para propósitos de soluciones empresariales.

Durante mis lecturas, me vinieron a la mente algunas preguntas:

Cuando un productor está produciendo un mensaje: especificará eltema quiere enviar el mensaje a, ¿es así? ¿Le importan las particiones?Cuando se ejecuta un suscriptor: ¿especifica su ID de grupo para que pueda formar parte de un grupo de consumidores del mismo tema o de varios temas en los que este grupo de consumidores está interesado?

¿Cada grupo de consumidores tiene una partición correspondiente en el corredor o cada consumidor tiene una?

Como las particiones creadas por el corredor, por lo tanto, no es una preocupación para los consumidores?

Dado que esta es una cola con un desplazamiento para cada partición, ¿es responsabilidad del consumidor especificar qué mensajes quiere leer? ¿Necesita salvar su estado?

¿Qué sucede cuando un mensaje se elimina de la cola? - Por ejemplo: la retención fue de 3 horas, luego pasa el tiempo, ¿cómo se maneja el desplazamiento en ambos lados?