在命令窗口启动Kafka后，手动创建主题“test”，分区数量为2；使用python编写生产者程序，以通用唯一标识符UUID作为消息，发送到主题“test"。使用python编写消费者程序1，订阅主题的分区0，只消费分区0的数据，使用python编写消费者程序2，订阅主题的分区1，只消费分区1的数据

好的，您需要在命令窗口启动Kafka并手动创建主题“test”，然后使用Python编写生产者程序将消息发送到主题“test”，最后使用Python编写两个消费者程序，分别订阅主题“test”的分区0和分区1，并只消费相应分区的数据，是吗？

以下是实现这些要求的步骤和示例代码：

**启动Kafka并创建主题**

请按照上一个问题中的步骤在命令窗口中启动Kafka并手动创建主题“test”，分区数量为2。

**使用Python编写生产者程序**

以下是一个示例代码，使用Python的kafka-python库编写生产者程序，以通用唯一标识符UUID作为消息，发送到名为“test”的主题：

from kafka import KafkaProducer
import uuid

producer = KafkaProducer(bootstrap_servers=['localhost:9092'])

for i in range(10):
    message = str(uuid.uuid4()).encode('utf-8')
    producer.send('test', message)

producer.close()

**使用Python编写消费者程序1**

以下是一个示例代码，使用Python的kafka-python库编写消费者程序1，订阅主题“test”的分区0，只消费分区0的数据：

from kafka import KafkaConsumer

consumer = KafkaConsumer(
    bootstrap_servers=['localhost:9092'],
    auto_offset_reset='earliest',
    partition_assignment=[{'topic': 'test', 'partition': 0}]
)

for message in consumer:
    print(f"Partition {message.partition} - Offset {message.offset}: {message.value}")

consumer.close()

**使用Python编写消费者程序2**

以下是一个示例代码，使用Python的kafka-python库编写消费者程序2，订阅主题“test”的分区1，只消费分区1的数据：

from kafka import KafkaConsumer

consumer = KafkaConsumer(
    bootstrap_servers=['localhost:9092'],
    auto_offset_reset='earliest',
    partition_assignment=[{'topic': 'test', 'partition': 1}]
)

for message in consumer:
    print(f"Partition {message.partition} - Offset {message.offset}: {message.value}")

consumer.close()

这些代码将订阅主题“test”的分区0和分区1，并分别只消费相应分区的数据。