使用GQLAlchemy创建Kafka流时哪些参数为必填项？

必填参数（创建时必须指定，否则会报错） #

• name：流的唯一标识名称，不能和现有流重复
• topics：要订阅的Kafka主题集合，至少需要指定一个主题，格式为列表（比如["topic1", "topic2"]）
• kafka_bootstrap_servers：Kafka集群的引导服务器地址，格式为"host1:port1,host2:port2"
• transformation_module：负责解析Kafka消息并转换为图数据的Python模块路径，比如"transformers.my_kafka_transformer"

可选参数（可根据需求选择配置，有默认值或非强制要求） #

• consumer_group：Kafka消费者组ID，不指定时会自动生成唯一ID
• batch_interval：批量处理消息的时间间隔（单位：毫秒），默认值为1000
• batch_size：单次批量处理的最大消息数量，默认值为1000
• auto_offset_reset：无有效偏移量时的重置策略，可选"earliest"（从最早消息开始）或"latest"（从最新消息开始），默认"latest"
• security_protocol：Kafka连接的安全协议，比如"SSL"、"SASL_PLAINTEXT"，默认不启用安全连接
• SASL认证相关参数：sasl_mechanism、sasl_plain_username、sasl_plain_password，仅在使用SASL认证时需要配置
• ssl_check_hostname：SSL连接时是否验证主机名，默认值为True

如果创建流时遇到参数缺失的报错，可以直接对照上述列表排查，也可以查看GQLAlchemy中KafkaStream类的定义来确认参数要求。

内容的提问来源于stack exchange，提问作者KWriter