Kafka是一款消息隊列，它可以高效地傳輸數據。在實際應用中，我們常常需要把Kafka中的數據寫入MySQL。下面就來介紹一下如何使用Kafka寫入MySQL。

首先，我們需要先創建一個Kafka消費者，用于消費Kafka中的消息。具體代碼如下所示：

# 創建Kafka消費者
consumer = KafkaConsumer(
'test_topic',  # 消費的主題名稱
group_id='test_group',  # 消費者組名稱
bootstrap_servers=['localhost:9092']  # Kafka服務所在的地址
)

我們可以看到，創建消費者需要指定要消費的主題（test_topic）、消費者組名稱（test_group）以及Kafka服務所在的地址（localhost:9092）。

接下來，我們需要定義一個函數，用于將消費到的消息寫入MySQL。具體代碼如下所示：

import pymysql
# 將消息寫入MySQL
def write_to_mysql(msg):
# 連接MySQL數據庫
conn = pymysql.connect(
host='localhost',  # 數據庫所在的地址
user='root',  # 數據庫用戶名
password='123456',  # 數據庫密碼
db='test_db',  # 數據庫名稱
charset='utf8mb4'  # 編碼格式
)
# 插入數據
sql = "INSERT INTO test_table (message) VALUES (%s)"
cursor = conn.cursor()
cursor.execute(sql, msg)
conn.commit()
# 關閉連接
cursor.close()
conn.close()

在代碼中，我們首先通過pymysql庫連接MySQL數據庫，并定義了一個insert語句，用于將消息寫入指定的表。然后，我們通過cursor對象執行insert語句，提交數據到MySQL數據庫中，并且在最后關閉數據庫連接。

最后，我們需要編寫主程序，使用創建的Kafka消費者實例，消費Kafka中的消息，并將消息寫入MySQL數據庫。具體代碼如下所示：

# 主程序
if __name__ == '__main__':
for msg in consumer:
# 獲取到消費的消息值
message = msg.value.decode('utf-8')
# 將消息寫入MySQL數據庫中
write_to_mysql(message)

在代碼中，我們通過循環遍歷消費者實例，獲取到消費的消息值。然后，我們將消息寫入MySQL數據庫中，由于MySQL中的數據是有存在順序的，所以寫入的順序和讀取的順序是一致的，不必擔心順序問題。