7,540
edits
Changes
→Logback.xml
===Logback.xml===
A kulcsok kitöltése nem kötelező, de szintén hatással lehet a performanciára. Ha a kulcs minden üzenetben ugyan az, akkor az összes üzenet ugyan abba logback-ek Kafka topic-okba a partícióba fog kerülni, ami nem a legjobb, de cserébe tuti hogy megtartja sorrendjét. <source lang="xml"><keyingStrategy class="'''com.github.danielwegener.logback.kafka.keying.NoKeyKeyingStrategy" />VAGY<keyingStrategy class="com.github.danielwegenerKafkaAppender''' osztállyal lehet írni ami egy szabványos Logback appender.logback.kafka.keying.HostNameKeyingStrategy" /></source> Nagyon fontos, hogy ugyan azzal a host névvel tegyük ezt ide, mint ahogy a swarm-ban létrehoztuk, és az Teljes leírás itt megadott nevet fel kell venni a hosts-ba. <source lang="xml"> <producerConfig>bootstrap.servers=kafka:9092</producerConfig></source>* producer configs are documented here: https://kafkagithub.apache.orgcom/danielwegener/documentation.html#newproducerconfigslogback-kafka-appender
<br>
logback.xml
</appender>
</source>
A kulcs kezelési stratégiát a '''keyingStrategy''' paraméterben kell definiálni. A kulcsok kitöltése nem kötelező, de szintén hatással lehet a performanciára. Ha a kulcs minden üzenetben ugyan az, akkor az összes üzenet ugyanabba a partícióba fog kerülni, ami nem a legjobb, de cserébe sorrendtartó lesz. Több kulcskezelési stratégia közül választhatunk. A '''NoKeyKeyingStrategy''' hatására nem fog kulcsot generálni, így round robin módon fog mindig egy új partíciót választani. Ha a '''HostNameKeyingStrategy''' stratégiát választjuk, akkor a host név lesz a kulcs, tehát az azonos hostról érkező logsorok mindig ugyan abba a partícióba fognak kerülni.
<source lang="xml">
<keyingStrategy class="com.github.danielwegener.logback.kafka.keying.NoKeyKeyingStrategy" />
VAGY
<keyingStrategy class="com.github.danielwegener.logback.kafka.keying.HostNameKeyingStrategy" />
</source>
A Kafka brókerek listáját a '''bootstrap.servers''' producerConfig paraméterben kell megadni. Nagyon fontos, hogy ugyan azzal a host névvel tegyük ezt ide, mint ahogy a swarm-ban létrehoztuk, és az itt megadott nevet fel kell venni a hosts-ba. A producerConfig-ok teljes listája itt olvasható: ttps://kafka.apache.org/documentation.html#producerconfigs
<source lang="xml">
<producerConfig>bootstrap.servers=kafka:9092</producerConfig>
</source>
<br>
<br>
==Logstash producer with logback ==
