Angepasste Avro-Serialisierungsmethode angeben

Sie können einen benutzerdefinierten Avro-Serialisierer anstelle des Avro-Serialisierers „ Confluent Kafka “ angeben, der standardmäßig mit allen Avro-kompatiblen integrierten benutzerdefinierten Operationsprozessoren (KCOPs) von Kafka verwendet wird.

Informationen zu dieser Task

Eine angepasste Avro-Serialisierungsmethodenklasse muss in einem Klassenpfad angegeben werden. Sie können einen angepassten Klassenpfad für KCOPs angeben , um alle erforderlichen externen Abhängigkeiten bereitzustellen.

Vorgehensweise

Fügen Sie die Eigenschaft serializer.class zu einer KCOP-Konfigurationsdatei hinzu. Der Wert sollte dem vollständig qualifizierten Namen einer Klasse entsprechen, die die Schnittstelle org.apache.kafka.common.serialization.Serializer implementiert.

Wenn Sie Eigenschaften angeben möchten, die an eine angepasste Avro-Serialisierungsmethode übergeben werden sollen, verwenden Sie das Präfix serializer.property . Im folgenden Beispiel verwenden alle Avro-kompatiblen integrierten KCOPs die Klasse com.ibm.serializer.AvroSerializer als Avro-Serialisierungsmethode und übergeben bei der Konfiguration der Klasse die Eigenschaften serializerproperty1 und serializerproperty2 :

serializer.class=com.ibm.serializer.AvroSerializer
serializer.property.serializerproperty1=value1
serializer.property.serializerproperty2=value2