Apache Kafka

Napsauta projektipuuta hiiren oikealla painikkeella ▸ Lisää ▸ Kafka-pyyntö.

Kafka-välilehti Kuluta-tilassa: välittäjäluettelo, aihe, ryhmätunnus, aloitusoffset ”earliest” ja partitiosuodatin

Yhteinen kokoonpano

Kenttä	Tehtävä
URL	Välittäjien luettelo pilkuin eroteltuna: `hote1:9092,hote2:9092` — koko merkkijono ratkaistaan Handlebarsilla ennen pilkkomista
Asiakastunnus	Välittäjille ilmoitettu `clientId`
Aihe	Aihe, tilasta riippumatta
Tila	`produce`, `consume` tai `browse`

Todennus

Kenttä	Arvot
SASL-mekanismi	`none`, `plain`, `scram-sha-256`, `scram-sha-512`
SASL-käyttäjätunnus / SASL-salasana	Salasana hyväksyy Salaisuus-tyyppisen arvon
TLS	Otetaan käyttöön erikseen — TLS-välittäjä ilman SASL:ia toimii mekanismilla `none`

Tila `produce`

Avain, arvo, tietueotsakkeet ja valinnaisesti partitio. Ilman nimenomaista partitiota käytetään asiakaskirjaston oletuspartitioijaa. Vastaus palauttaa kirjoitetun tietueen metatiedot: aihe, partitio ja offset.

Tila `consume`

Kenttä	Tehtävä
Ryhmä	Kuluttajan `groupId`
Aloitusoffset	`earliest`, `latest` tai `specific`
Tietty offset	Merkkijono — Kafkan offsetit ovat 64-bittisiä kokonaislukuja
Partitiot	Suodatin asiakaspuolella: partitioiden jako pysyy ryhmän tehtävänä

Tila `browse`

Tarkastelee partitiota ilman kuluttajaryhmää: Restorm poimii sieltä rajatun määrän viestejä ja katkaisee sitten yhteyden. Partitio on pakollinen tässä tilassa.

Tämä on oikea työkalu, kun haluat katsoa aiheen sisältöä luomatta ryhmää ja siirtämättä offsetteja.

Skenaariossa

Kafka produce — yksittäinen toiminto, joka palauttaa tietueen metatiedot
Kafka consume — tilaa kuluttajaryhmän kautta ja lähettää yhden tapahtuman viestiä kohti
Sulje Kafka-yhteys — pysäyttää kulutuksen

Katso Yhteydet ja virrat.

Koodinpätkät

Viisi kohdetta: JavaScript (kafkajs, tuotantoon ja kulutukseen) ja kcat (tuotanto, kulutus ja tarkastelu ilman ryhmää).