7,540
edits
Changes
→Logback producer
....
</dependencies>
</source>
===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 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.danielwegener.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 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://kafka.apache.org/documentation.html#newproducerconfigs
<source lang="xml">
<appender name="kafkaAppender" class="com.github.danielwegener.logback.kafka.KafkaAppender">
<!-- https://gquintana.github.io/2017/12/01/Structured-logging-with-SL-FJ-and-Logback.html -->
<encoder class="net.logstash.logback.encoder.LogstashEncoder">
<customFields>{"application":"log-odyssey"}</customFields>
</encoder>
<topic>adam</topic>
<keyingStrategy class="com.github.danielwegener.logback.kafka.keying.HostNameKeyingStrategy" />
<deliveryStrategy class="com.github.danielwegener.logback.kafka.delivery.AsynchronousDeliveryStrategy" />
<appendTimestamp>true</appendTimestamp>
<producerConfig>bootstrap.servers=kafka:9092</producerConfig>
</appender>
</source>