guillotina_kafka:用于Guillotina应用程序的Kafka集成

guillotina_kafka文件 该软件包提供了一个guillotina插件，使您的guillotina应用程序支持kafka。 从本质上讲，它提供了两个API，一个用于生产Kafka，另一个用于从Kafka使用。 生产者 您可以按以下方式获取生产者实用程序： from guillotina_kafka . utilities import get_kafka_producer producer = get_kafka_producer () 然后根据您的要求设置生产者。 您可以在找到配置选项的详尽列表 await producer . setup ( request_timeout_ms = 5000 , value_serializer = lambda data : json . dumps ( data ). encode ( 'utf-8' ),