3. 用pycharm编写Kafka消费者订阅分区 在命令行窗口中启动Kafka后,手动创建主题“assgin tonic”分区就号*2。具体命令1下: .bin\windows kkafka-topics.bat --create--zo0keeper loca 1heet.210renlicatiofEactor 1 --partitions 2 --topic assign_topic 根据上面给出的主题，完成如下操作。 (1)编写生产者程序，以通用唯一标识符UUID作为消息，发送给主题“assign topic”"。 （2）编写消费者程子1，阅主题的分区0,只消费分区0数据。 (3)编写消费者程了2，阅土题的分区1，只消费分区1数据。

好的，我来一步一步回答你的问题。

首先，你需要在 PyCharm 中安装 kafka-python 库，可以通过在终端中运行 `pip install kafka-python` 来安装。

然后，你需要编写 Kafka 生产者程序，代码如下：

from kafka import KafkaProducer
import uuid

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

def on_send_success(record_metadata):
    print(f"Message sent successfully! Topic: {record_metadata.topic}, Partition: {record_metadata.partition}, Offset: {record_metadata.offset}")

def on_send_error(excp):
    print(f"Message failed! {excp}")

for i in range(10):
    message = str(uuid.uuid4()).encode('utf-8')
    producer.send('assign_topic', value=message).add_callback(on_send_success).add_errback(on_send_error)

producer.flush()

这里使用了 Python 的 uuid 库来生成唯一标识符，并将其作为消息发送给主题 "assign_topic"。你需要将 `bootstrap_servers` 参数设置为你的 Kafka 服务器地址，这里假设为 `localhost:9092`。在发送消息时，我们还定义了两个回调函数，一个是在消息发送成功时打印相关信息，一个是在发送失败时打印相关信息。最后，我们通过 `producer.flush()` 来确保所有消息都已经发送完毕。

接下来，你需要编写消费者程序，分别消费主题 "assign_topic" 的两个分区。代码如下：

from kafka import KafkaConsumer

# 消费分区0的消费者
consumer0 = KafkaConsumer('assign_topic', bootstrap_servers=['localhost:9092'], group_id='my-group-0', auto_offset_reset='earliest', enable_auto_commit=True, consumer_timeout_ms=1000)
for message in consumer0:
    if message.partition == 0:
        print(f"Consumer 0: {message.value}")

# 消费分区1的消费者
consumer1 = KafkaConsumer('assign_topic', bootstrap_servers=['localhost:9092'], group_id='my-group-1', auto_offset_reset='earliest', enable_auto_commit=True, consumer_timeout_ms=1000)
for message in consumer1:
    if message.partition == 1:
        print(f"Consumer 1: {message.value}")

这里我们使用了 Kafka 的 Python 客户端库 kafka-python，首先创建了两个消费者对象，分别消费主题 "assign_topic" 的两个分区。在消费数据时，我们使用了 `message.partition` 来判断消息属于哪个分区，并打印相应的消息内容。在创建消费者对象时，我们设置了 `group_id` 参数来区分不同的消费者组，以及 `auto_offset_reset` 参数来设置消费者在启动时从哪个偏移量开始消费。

最后，你需要在命令行中启动 Kafka，并手动创建主题 "assign_topic" 的两个分区。具体命令如下：

.\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 2 --topic assign_topic

注意，这里的命令中的参数值需要根据你的实际情况进行修改。

以上就是用 PyCharm 编写 Kafka 消费者订阅分区的完整流程，希望能对你有所帮助！