Kokius Kafka konfigūracijos parametrus naudojote savo darbe?

Dirbant su Apache Kafka dažnai konfigūruojami šie parametrai:

• bootstrap.servers — Kafka brokerių adresai jungimuisi.
• key.serializer / value.serializer — klasės, skirtos raktų ir pranešimų reikšmių serializavimui (pvz., StringSerializer).
• key.deserializer / value.deserializer — vartotojams, pranešimų deserializavimui.
• group.id — vartotojų grupės identifikatorius.
• enable.auto.commit — automatinis pranešimų patvirtinimas.
• auto.offset.reset — elgsena, jei nėra offset (pvz., earliest arba latest).
• acks — įrašymo patvirtinimo lygis (pvz., all, 1, 0).
• retries — bandymų skaičius pranešimų siuntimui iš naujo.
• batch.size ir linger.ms — parametrai, skirti optimizuoti pranešimų siuntimą partijos.

Java pavyzdys, kaip konfigūruoti gamintoją:

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);