Propriétés et commandes de l'adaptateur

Cette section répertorie les propriétés prises en charge par l'adaptateur.

Dans les mappes :

  • Utilisez les commandes d'adaptateur sur les cartes d'entrée et les fonctions GET pour configurer l'adaptateur afin qu'il consomme les messages des sujets Kafka.
  • Utilisez les commandes d'adaptateur sur les cartes de sortie et les fonctions PUT pour configurer l'adaptateur afin de publier des messages dans les sujets Kafka.

De nombreuses commandes d'adaptateur Kafka sont basées sur les configurations du consommateur ou du producteur Apache Kafka. Ces descriptions de commande d'adaptateur incluent le nom de la configuration Apache Kafka associée. Pour plus de détails, voir la documentation Apache Kafka.

Alias de commande d'adaptateur Apache Kafka

Utilisez KAFKA comme alias de commande d'adaptateur sur les cartes d'entrée et de sortie et dans les règles GET et PUT. Par exemple :

Commande d'exécution de remplacement de source d'entrée -IAKAFKA card_num
Commande d'exécution de remplacement de cible de sortie -OAKAFKA card_num

En-têtes pour les charges de données

Vous pouvez spécifier la commande -HDR facultative pour ajouter au début l'une des versions d'en-tête suivantes aux messages. Les nombres entre crochets indiquent le nombre d'octets :
  • [4] est un entier 32 bits
  • [8] est un entier 64 bits
Version
Structure d'en-tête
1

[4]             Total header size (excluding this field): 2*4 + size(key)
[4]             Header Version: 1
[4]key          Key size followed by the key value
2

[4]             Total header size (excluding this field): 4*4 + 2*8 + size(key) + size(topic)
[4]             Header Version: 2
[4]key          Key size followed by the key value
[4]topic        Topic size followed by the topic
[4]             Partition number
[8]             Offset
[8]             Timestamp
3

[4]             Total header size (excluding this field): 4*4 + 2*8 + size(key) + size(topic) + sum(2*4 + size(hkey_i) + size(hvalue_i))
[4]             Header Version: 3
[4]key          Key size followed by the key value
[4]topic        Topic size followed by the topic
[4]             Partition number
[8]             Offset
[8]             Timestamp
[4]             The size of the Kafka headers section (excluding this field), followed by an array of Kafka header key, value pairs in the following format:
   [4]hkey      Kafka header key size followed by Kafka header key 
   [4]hvalue    Kafka header value size followed by Kafka header value
L'en-tête du message est toujours suivi de la taille et du contenu de la charge : 
[4]payload	Payload size followed by payload content