Quali parametri di configurazione di Kafka hai utilizzato nel tuo lavoro?

Nel lavoro con Apache Kafka, vengono spesso configurati i seguenti parametri:

• bootstrap.servers — indirizzi dei broker Kafka per la connessione.
• key.serializer / value.serializer — classi per serializzare chiavi e valori dei messaggi (ad esempio, StringSerializer).
• key.deserializer / value.deserializer — per i consumatori, deserializzazione dei messaggi.
• group.id — identificatore del gruppo di consumatori.
• enable.auto.commit — conferma automatica dell'elaborazione dei messaggi.
• auto.offset.reset — comportamento in assenza di offset (ad esempio, earliest o latest).
• acks — livello di conferma della scrittura (ad esempio, all, 1, 0).
• retries — numero di tentativi di reinvio dei messaggi.
• batch.size e linger.ms — parametri per ottimizzare l'invio di messaggi in batch.

Esempio di configurazione di un producer in Java:

Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");
props.put("acks", "all");
props.put("retries", 3);