Vue d'ensemble

confluent-kafka 1.9, publié le 10 mai 2022, améliore l'AdminClient avec de nouvelles opérations d'administration des topics et groupes.

Fonctionnalités principales

AdminClient amélioré

L'AdminClient supporte de nouvelles opérations comme la description des groupes de consommateurs et la gestion des ACL de manière programmatique.

python 
from confluent_kafka.admin import AdminClient, NewTopic

admin = AdminClient({'bootstrap.servers': 'localhost:9092'})

# Créer un topic
topic = NewTopic('mon-topic', num_partitions=3, replication_factor=1)
fs = admin.create_topics([topic])
for t, f in fs.items():
    f.result()  # attendre la création
    print(f'Topic {t} créé')

Producteur et consommateur

Les API Producer et Consumer sont optimisées pour de meilleures performances avec la sérialisation Avro et JSON Schema intégrée.

python 
from confluent_kafka import Producer, Consumer

# Producteur
producer = Producer({'bootstrap.servers': 'localhost:9092'})
producer.produce('mon-topic', key='clé', value='message')
producer.flush()

# Consommateur
consumer = Consumer({
    'bootstrap.servers': 'localhost:9092',
    'group.id': 'mon-groupe',
    'auto.offset.reset': 'earliest',
})
consumer.subscribe(['mon-topic'])

Sources