Skip to main content

Kafka Service

Mit diesemThis SCCM Manager Plug-plug-in wirdis derused to configure the Kafka Message ServiceService. konfiguriert.It Esalso ermöglichtallows auchviewing dasthe Einsehenstatus der Statusinformationen.information.

MitThe denservice Buttonsis controlled with the Start, Stopp,Stop undand NeustartRestart wirdbuttons. derThe Serviceindividual gesteuert.configurations Übercan diebe Comboboxselected danebenvia könnenthe diecombo einzelnenbox Konfigurationennext ausgewähltto werden.it.

KafkaServiceStarten_thumb_580_0.png

DiesesThis Videovideo zeigtshows diethe Grundkonfigurationbasic desconfiguration of the Kafka Service:service:

Video fehlt hier: kafka_service_first_start

Kafka Message

DieThe Kafka-MessagesKafka diemessages vonthat demare Produzerread ausby derthe Producer-Producer from the Producer Inbox gelesenhave werden,the habenfollowing folgendenaming Namenskonventionen:conventions: topicname_id.json

Topicname undand Id müssenmust immeralways mitbe einemseparated Unterstrichwith getrenntan werden,underscore, derthe Topicnametopicname darfmay trotzdemstill Unterstrichecontain enthalten.underscores.

Service Konfigurationconfiguration

DamitIn derorder for the Kafka Serviceservice funktionsfähigto istbe müssenfunctional, einigesome Konfigurationenconfigurations vorgenommenmust werden.be Diemade. wichtigstenThe Konfigurationenmost sindimportant hierconfigurations aufgeführt.are listed here.

Für mehr Informationen besuchen Sie die offizielle Apache Kafka Dokumentation

Kafka-Service-Config_thumb_580_0.png

EigenschaftProperty BeschreibungDescription
Enable Consumer AktiviertActivates denthe Consumerconsumer Service.service.
Enable Producer AktiviertActivates denthe Producerproducer Service.service.
Consumer Config Instance GewählteSelected Konfigurationsinstanzconfiguration instance (nurread lesend)only)
Consumer Topic LegtSets dasthe Themasubject fürfor denreceiving Empfang von Nachrichten fest.messages.
Producer Config Instance GewählteSelected Konfigurationsinstanzconfiguration instance (nurread lesend)only)
Producer File Types LegtSets diethe Dateitypenfile fest,types umto dieidentify zuthe sendendenmessages Nachrichtento zube identifizieren.sent. TrennenSeparate Siemultiple mehreretypes Typenwith mitpipe. Pipe. Beispiel:Example: json|xml
Producer Path LegtSets denthe Posteingangspfadinbox fürpath neufor zunew sendendemessages Nachrichtento fest.be sent.
Producer Processing Max RetieresRetries LegenSet Siethe diemaximum maximalenretries Wiederholungsversuchewhen beian Auftretenerror eines Fehlers fest.occurs.
Producer Processing Retry Timeout LegenSet Siethe dasretry Zeitlimittime fürlimit diewhen Wiederholungan fest,error wenn ein Fehler auftritt.occurs.
Consumer Konfigurationconfiguration

Kafka-Consumer-Config_thumb_580_0.png

EigenschaftProperty BeschreibungDescription
Api Version Request

FordertRequests diethe unterstütztensupported API-VersionenAPI desversions Brokersof an,the umbroker dieto Funktionalitätmatch anthe diefunctionality verfügbarento Protokollfunktionenthe anzupassen.available protocol features.

WennIf aufset „false“to gesetzt,false, oderor wennif derthe Api-Version-Requestapi fehlschlägt,version wirdrequest diefails, Fallback-Versionthe fallback version `broker.version.fallback` verwendet.will be used.
Auto Offset Reset

Aktion,Action dieto ausgeführtbe werdenperformed soll,if wennthere keinis anfänglicherno Offsetinitial imoffset Offset-Speicherin vorhandenthe istoffset odermemory deror gewünschtethe Offsetdesired außerhalboffset desis Bereichsout liegt:of range:

'smallest','earliest' - setztautomatically denresets Offsetthe automatischoffset aufto denthe kleinstensmallest Offset zurückoffset.

'largest','latest' - setztresets denthe Offsetoffset automatischautomatically aufto denthe größtenlargest Offset zurückoffset

'error' - lösttriggers einenan Fehlererror aus,determined derby durchconsuming Konsumierenmessages vonand Nachrichten und Prüfen vonchecking 'message->err' ermittelt wird..
Bootstrap Servers AnfänglicheInitial Listelist vonof Brokernbrokers alsas CSV-ListeCSV vonlist Broker-Hostfrom oderbroker Host:Port.host Dieor Anwendunghost:port. kannThe auchapplication can also use `rd_kafka_brokers_add()` verwenden,to umadd denthe Brokerbroker währendat der Laufzeit hinzuzufügen.runtime.
Client Id DieThe Client-ID.
Enable Auto Commit Aktiviert/deaktiviertEnables/disables automatischesautomatic Festlegensetting vonof Offsetsoffsets imin Hintergrund.the background.
Enable Auto Offset Store

Aktiviert/deaktiviertEnables/disables diethe Speicherungstorage desof Offsetsthe deroffset letztenof Nachricht,the dielast empfangenmessage wurde.received.

DerThe Offset-Speicheroffset istmemory einis interneran Speicherinternal fürmemory denfor nächstenthe Offset,next deroffset fürthat jedeis Partitiontransmitted (automatisch)automatically) übertragenfor wird.each partition.
Enable Partition Eof Aktiviert/deaktiviertEnables/disables dassending Senden derthe RD_KAFKA_RESP_ERR__PARTITION_EOF Message,message wennwhen derthe Verbraucherconsumer dasreaches Endethe einerend Partitionof erreicht.a partition.
Groud Id String derof Client-Gruppen-the client group ID. AlleAll Clientsclients mitwith derthe gleichensame group.id gehörenbelong zurto gleichenthe Gruppe.same group.
Isolation Level Steuert,Controls wiehow transaktionaltransactionally geschriebenewritten Nachrichtenmessages gelesenshould werdenbe sollen:read: `read_committed` - gibtreturns nuronly transaktionaletransactional Nachrichtenmessages zurück,that diehave bestätigtbeen wurden.committed. `read_uncommitted` - gibtreturns alleall Nachrichtenmessages, zurück,including auchtransactional Transaktionsnachrichten,messages diethat abgebrochenhave wurden.been aborted.
Max Poll Interval Ms MaximalMaximum zulässigetime Zeitallowed zwischenbetween Aufrufencalls zumto Konsumierenconsume vonmessages Nachrichtenfor fürhigh-level High-Level-Consumer.consumers. WennIf diesesthis Intervallinterval überschrittenis wird,exceeded, giltthe derconsumer Konsumentis alsconsidered fehlgeschlagenfailed undand diethe Gruppegroup wirdis neurebalanced ausbalanciert,to umreassign diethe Partitionenpartitions einemto anderenanother Mitgliedmember derof Konsumentengruppethe neuconsumer zuzuweisen.group.
Secruity Protocol Protokoll,Protocol dasused fürfor diecommunication Kommunikationwith mit Brokern verwendet wird.brokers.
Session Timeout Ms

ZeitüberschreitungTimeout fürfor Client-Gruppensitzungenclient undgroup Fehlererkennung.sessions and error detection.

DerThe Consumer sendetsends periodischeperiodic Heartbeatsheartbeats (heartbeat.interval.ms), umto demindicate to the Broker seinethat Betriebsbereitschaftit anzuzeigen.is Wennready derfor Brokeroperation. innerhalbIf desthe Sitzungs-Timeoutsbroker keinedoes Heartbeatsnot fürreceive einheartbeats Gruppenmitgliedfor empfängt,a entferntgroup dermember Brokerwithin denthe Consumersession austimeout, derthe Gruppebroker undremoves löstthe einenconsumer Neuabgleichfrom aus.the group and triggers a rebalance.
Statistics Interval Ms

librdkafka Statistikstatistics -Messagemessage Sendeintervall.send Derinterval. WertThe value 0 deaktiviertdisables das Senden.sending.
Producer Konfigurationconfiguration

Kafka-Producer-Config_thumb_580_0.png

EigenschaftProperty BeschreibungDescription
ApiAPI Version Request

FordertRequests diethe unterstütztensupported API-VersionenAPI desversions Brokersof an,the umbroker dieto Funktionalitätmatch anthe diefunctionality verfügbarento Protokollfunktionenthe anzupassen.available protocol features.

WennIf aufset „false“to gesetzt,false, oderor derthe Api-Version-Requestapi fehlschlägt,version wirdrequest diefails, Fallback-Versionthe fallback version `broker.version.fallback` verwendet.is used.
Bootstrap Servers AnfänglicheInitial Listelist vonof Brokernbrokers alsas CSV-ListeCSV vonlist Broker-Hostfrom oderbroker Host:Port.host Dieor Anwendunghost:port. kannThe auchapplication can also use `rd_kafka_brokers_add()` verwenden,to umadd denthe Brokerbroker währendat der Laufzeit hinzuzufügen.runtime.
Client IdID DieThe Client-ID.
Enable Idempotence Aktiviert/deaktiviert,Enables/disables dassmessages Nachrichtento genaube einmalsuccessfully undcreated exactly once and in derthe ursprünglichenoriginal Erzeugungsreihenfolgecreation erfolgreich erzeugt werden.order.
Linger Msms

WartezeitWaiting time in Millisekunden,milliseconds diefor gewartetmessages wirdto bis sich die Nachrichtenaccumulate in derthe Producer-WarteschlangeProducer angesammeltqueue habenand undbe alssent Nachrichtenstapelto (MessageSets) an denthe Broker den gesendetas werden.message batches (MessageSets).

EinA höhererhigher Wertvalue ermöglichtallows diethe Akkumulationaccumulation größererof undlarger effektivererand more effective (wenigerless Overhead,overhead, verbesserteimproved Komprimierung)compression) Nachrichtenstapelmessage aufbatches Kostenat einerthe erhöhtencost Latenzzeitof beiincreased dermessage Nachrichtenübermittlung.delivery latency.
Message Send Max Retires AnzahlNumber derof Wiederholungsversucheretries beimwhen Sendensending einera fehlgeschlagenenfailed Nachricht.message.
Message Timeout Ms LokaleLocal Zeitüberschreitungmessage fürtimeout. Nachrichten.This Dieservalue Wertapplies giltonly nurlocally lokaland undlimits begrenztthe dietime Zeit,a dieproduced einemessage produziertewaits Nachrichtfor aufsuccessful diedelivery. erfolgreicheWith Zustellungthe wartet.value Bei0, demthe Wertwaiting 0time istis dieunlimited. WartezeitA unbegrenzt.delivery Einerror Zustellungsfehleroccurs trittwhen auf,either wennthe entwedernumber dieof Anzahlretries deror Wiederholungsversuchethe odermessage dietimeout Zeitüberschreitungis der Nachricht überschritten wird.exceeded.
Partitioner

`random` - zufälligerandom Verteilungdistribution

`consistent` - CRC32 hash of key (Empty undand NULL Keyskeys sindare einerassigned einzelnento Partitiona zugewiesen)single partition)

`consistent_random` - CRC32 hash of key (Empty undand NULL Keyskeys werdenare zufälligpartitioned partitioniert)randomly)

`murmur2` - Java Producer compatible Murmur2 hash of key (NULL Keyskeys werdenare einerassigned einzelnento Partitiona zugewiesen)single partition)

`murmur2_random` - Java Producer kompatiblecompatible Murmur2 hash of key (NULL Keyskeys werdenare zufälligpartitioned partitioniert.randomly. DiesThis istis funktionalfunctionally äquivalentequivalent zumto Standard-Partitioniererthe imdefault partitioner in Java Producer.)Producer).
Queue Buffering Max KbyteskBytes MaximalMaximum zulässigetotal Gesamtsummemessage dersize Nachrichtengrößeallowed in derthe Producer-Warteschlange.Producer Diesequeue. WarteschlangeThis wirdqueue vonis allenshared Topicsby undall Partitionentopics gemeinsamand genutzt.partitions. DieseThis Eigenschaftproperty hathas einea höherehigher Prioritätpriority alsthan queue.buffering.max.messages. 
Queue Buffering Max Messages MaximaleMaximum Anzahlnumber vonof Nachrichten,messages dieallowed in derthe Producer-WarteschlangeProducer erlaubtqueue. sind.This Diesequeue Warteschlangeis wirdshared vonby allenall Thementopics undand Partitionen gemeinsam genutzt.partitions.
Security Protocol Protokoll,Protocol dasused fürfor diecommunication Kommunikationwith mit Brokern verwendet wird.brokers.
Statistics Interval Msms librdkafka Statistikstatistics -Messagemessage Sendeinterval.send Derinterval. WertThe value 0 deaktiviertdisables das Senden.sending.



Back to top