如何从Dataframe设置消息

import pandas as pd
from kafka import KafkaProducer

data = {'Name': ['John', 'Emma', 'Mike'],
        'Age': [25, 28, 30],
        'City': ['New York', 'London', 'Paris']}
df = pd.DataFrame(data)

json_data = df.to_json(orient='records')

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

producer.send('topic_name', json_data.encode('utf-8'))

import pandas as pd
from kafka import KafkaProducer

# 创建Dataframe
data = {'Name': ['John', 'Emma', 'Mike'],
        'Age': [25, 28, 30],
        'City': ['New York', 'London', 'Paris']}
df = pd.DataFrame(data)

# 转换为JSON格式
json_data = df.to_json(orient='records')

# 创建KafkaProducer对象
producer = KafkaProducer(bootstrap_servers='localhost:9092')

# 发送消息到Kafka主题
producer.send('topic_name', json_data.encode('utf-8'))