Jaa


Confluent Kafka -lähteen lisääminen tapahtumavirtaan

Tässä artikkelissa kerrotaan, miten Confluent Kafka -lähde lisätään tapahtumavirtaan.

Confluent Cloud Kafka on suoratoistoympäristö, joka tarjoaa tehokkaita tietojen suoratoisto- ja käsittelytoimintoja Apache Kafkan avulla. Integroimalla Confluent Cloud Kafkan lähteeksi tapahtumavirtaasi voit käsitellä reaaliaikaisia tietovirtoja saumattomasti, ennen kuin reitität ne useisiin kohteisiin Fabricissa.

Muistiinpano

Tätä lähdettä ei tueta seuraavilla työtilakapasiteettisi alueilla: Länsi-YHDYSVALLAT3, Sveitsi, läntinen.

Edellytykset

  • Työtilan käyttöoikeus Fabric-kapasiteetin käyttöoikeustilassa (tai) kokeiluversion käyttöoikeustilassa Osallistuja-oikeudella tai korkeammilla käyttöoikeuksilla.
  • Confluent Cloud Kafka -klusteri ja ohjelmointirajapinta-avain.
  • Confluent Cloud Kafka -klusterin on oltava julkisesti käytettävissä, eikä se saa olla palomuurin takana tai suojattu näennäisverkossa.
  • Jos sinulla ei ole tapahtumastreamia, luo tapahtumavirta.

Käynnistä ohjattu Tietolähteen valitseminen -toiminto

Jos et ole vielä lisännyt lähdettä tapahtumavirtaan, valitse Käytä ulkoista lähderuutua .

Näyttökuvassa näkyy Käytä ulkoista lähderuutua -valinta.

Jos lisäät lähteen jo julkaistuun tapahtumavirtaan, vaihda Muokkaa-tilaan , valitse valintanauhasta Lisää lähde ja valitse sitten Ulkoiset lähteet.

Näyttökuvassa näkyy Lisää lähde ulkoisiin lähteisiin -valikko.

Confluent Kafkan määrittäminen ja siihen yhdistäminen

  1. Valitse Valitse tietolähde -sivulla Confluent.

    Näyttökuvassa näkyy Confluent lähdetyyppinä ohjatussa Hae tapahtumat -toiminnossa.

  2. Jos haluat luoda yhteyden Confluent Cloud Kafka -lähteeseen, valitse Uusi yhteys.

    Näyttökuvassa näkyy uusi yhteyslinkki ohjatun tapahtumien luomisen toimintotoiminnon Yhdistä-sivulla.

  3. Syötä Yhteysasetukset-osioon Confluent Bootstrap Server. Siirry Confluent Cloud -aloitussivulle, valitse Klusteriasetukset ja kopioi osoite Bootstrap-palvelimeesi.

  4. Jos sinulla on Yhteyden tunnistetiedot -osiossa aiemmin luotu yhteys Confluent-klusteriin, valitse se Connection-kohdan avattavasta luettelosta. Muutoin toimi seuraavasti:

    1. Anna yhteyden nimi Yhteyden nimi -kohtaan.
    2. Vahvista todennuslajiksi, että Neuvottelupilviavain on valittuna.
    3. Ohjelmointirajapinta-avaimelle ja ohjelmointirajapinnan avaimen salauskoodille:
      1. Siirry Confluent Cloud -pilvipalveluun.

      2. Valitse sivuvalikosta Ohjelmointirajapinta-avaimet .

      3. Luo uusi ohjelmointirajapinta-avain valitsemalla Lisää avain- painike.

      4. Kopioi ohjelmointirajapinnan avain ja salainen koodi.

      5. Liitä nämä arvot ohjelmointirajapinnan avaimen ja ohjelmointirajapinnan avaimen salasana -kenttiin.

      6. Valitse Yhdistä

        Näyttökuvassa näkyy Confluent-yhteysasetusten ensimmäinen sivu.

  5. Siirry sivun kohtaan Konfiguroi neuvottelutietolähde. Anna tiedot Confluent-tietolähteen määrityksen viimeistelemiseksi.

    1. Kirjoita Aihe-kohtaan Confluent Cloudin aiheen nimi. Voit luoda aiheesi tai hallita sitä Confluent Cloud Console -konsolissa.
    2. Kuluttajaryhmä-kohtaan Syötä Confluent Cloudin kuluttajaryhmä. Se tarjoaa erityisen kuluttajaryhmän Confluent Cloud -klusterin tapahtumien noutamiseen.
    3. Valitse Automaattisen siirtymän nollaaminen -asetukseksi jokin seuraavista arvoista:
      • Aikaisin – aikaisin Confluent-klusterista käytettävissä olevat tiedot

      • Viimeisimmät – uusimmat saatavilla olevat tiedot

      • Ei mitään – älä määritä siirtymää automaattisesti.

        Näyttökuvassa näkyy Confluent-tietolähdesivun toinen sivu, Confluent-yhteysasetukset.

  6. Valitse Seuraava. Tarkista yhteenveto Ja luo -näytössä ja valitse sitten Lisää.

Näet, että Confluent Cloud Kafka -lähde lisätään tapahtumavirtaasi pohjalla Muokkaa-tilassa. Jos haluat ottaa käyttöön tämän äskettäin lisätyn Confluent Cloud Kafka -lähteen, valitse valintanauhasta Julkaise .

Näyttökuvassa on Confluent Kafka -lähde Muokkaa-näkymässä.

Kun olet suorittanut nämä vaiheet, Confluent Cloud Kafka -lähde on visualisoitavissa reaaliaikaisessa näkymässä.

Näyttökuvassa näkyy Confluent Kafka -lähde reaaliaikaisessa näkymässä.

Rajoitukset

  • Confluent Kafka ja JSON- ja Avro-muodot, jotka käyttävät skeemarekisteriä, eivät ole tällä hetkellä tuettuja.
  • Tietojen koodaamista Confluent Kafkasta Confluent Schema Registryn avulla ei tueta tällä hetkellä.

Muistiinpano

Yhden tapahtumavirran lähteiden ja kohteiden enimmäismäärä on 11.

Muut liittimet: