Kafka Connect-Konfiguration erstellen

• Konsole
• CLI
• API

• 1. Wählen Sie auf der Listenseite Kafka Connect-Konfigurationen die Option Kafka Connect-Konfigurationen erstellen aus. Wenn Sie Hilfe beim Suchen der Listenseite benötigen, finden Sie weitere Informationen unter Kafka Connect-Konfigurationen auflisten.
     Das Dialogfeld Kafka Connect-Konfiguration erstellen wird geöffnet.
  2. Wählen Sie ein Compartment aus der Liste Compartment aus.
  3. Geben Sie im Feld Kafka Connect-Konfigurationsname einen Namen für die Konfiguration ein. Geben Sie dabei keine vertraulichen Informationen ein.
  4. (Optional) Fügen Sie der Kafka Connect-Konfiguration mindestens ein Tag hinzu: Wählen Sie Erweiterte Optionen anzeigen aus, um den Abschnitt Tags hinzufügen anzuzeigen.
     Wenn Sie über Berechtigungen zum Erstellen einer Ressource verfügen, sind Sie auch berechtigt, Freiform-Tags auf diese Ressource anzuwenden. Um ein definiertes Tag anzuwenden, müssen Sie über die Berechtigungen verfügen, den Tag-Namespace zu verwenden. Weitere Informationen zum Tagging finden Sie unter Ressourcentags. Wenn Sie nicht sicher sind, ob Sie Tags anwenden sollen, überspringen Sie diese Option, oder fragen Sie einen Administrator. Sie können Tags später anwenden.
  5. Wählen Sie Kafka Connect-Konfiguration erstellen aus.
     Die Detailseite für die neue Kafka Connect-Konfiguration wird geöffnet. In einem schreibgeschützten Textfeld mit der Bezeichnung Kafka Connect-Speicherthemen wird die Connector-Konfiguration aufgeführt.
  6. Wählen Sie Kopieren aus, um die Connector-Konfiguration zu kopieren, damit Sie sie in die Datei connect-distributed.properties für Ihren Kafka-Connector einfügen können.
     Weitere Informationen finden Sie in der offiziellen Dokumentation für Kafka Connect.

• Verwenden Sie den Befehl oci streaming admin connect-harness create und die erforderlichen Parameter, um eine Kafka Connect-Konfiguration zu erstellen:

  oci streaming admin connect-harness create --name <kafka_connect_configuration_name> --compartment-id <compartment_OCID>

  Beispiel:

  oci streaming admin connect-harness create --name MyKafkaConnectConfig --compartment-id exampleuniqueID
  {
    "data": {
      "compartment-id": "ocid1.tenancy.oc1..exampleuniqueID",
      "defined-tags": {},
      "freeform-tags": {},
      "id": "ocid1.connectharness.oc1.phx.exampleuniqueID",
      "lifecycle-state": "CREATING",
      "lifecycle-state-details": null,
      "name": "MyKafkaConnectConfig",
      "time-created": "2020-11-04T17:36:44.323000+00:00"
    },
    "etag": "\"48886b1f-333f-4142-a335-ed42e88b37f8-0e7d329d-c6df-47fc-b814-f1237b414281\""
  }

  Eine vollständige Liste der Parameter und Werte für CLI-Befehle finden Sie in der CLI-Befehlsreferenz.

• Führen Sie den Vorgang CreateConnectHarness aus, um eine Kafka Connect-Konfiguration zu erstellen.

CreateConnectHarnessDetails createConnectHarnessDetails = CreateConnectHarnessDetails.builder()
    .compartmentId(compartment) //compartment where you want to create connect harness
    .name("myConnectHarness") //connect harness name
    .build();
 
CreateConnectHarnessRequest connectHarnessRequest = CreateConnectHarnessRequest.builder()
    .createConnectHarnessDetails(createConnectHarnessDetails)
    .build();
 
CreateConnectHarnessResponse createConnectHarnessResponse = streamAdminClient.createConnectHarness(connectHarnessRequest);
ConnectHarness connectHarness = createConnectHarnessResponse.getConnectHarness();
 
while (connectHarness.getLifecycleState() != ConnectHarness.LifecycleState.Active && connectHarness.getLifecycleState() != ConnectHarness.LifecycleState.Failed) {
    GetConnectHarnessRequest getConnectHarnessRequest = GetConnectHarnessRequest.builder().connectHarnessId(connectHarness.getId()).build();
     connectHarness = streamAdminClient.getConnectHarness(getConnectHarnessRequest).getConnectHarness();
}