要在AWS Lambda中使用MSK主题作为事件源，并读取Kafka消息，您可以使用以下代码示例来解决这个问题：

import boto3
import json

def lambda_handler(event, context):
    # 创建Kafka客户端
    kafka_client = boto3.client('kafka')

    # 获取从事件中传入的主题ARN
    topic_arn = event['Records'][0]['eventSourceARN']
    
    # 获取主题名称
    topic_name = topic_arn.split(':')[-1]
    
    # 获取Kafka集群的ARN
    cluster_arn = topic_arn.split(':')[0] + ':' + topic_arn.split(':')[1] + ':' + topic_arn.split(':')[2] + ':' + topic_arn.split(':')[3] + ':' + topic_arn.split(':')[4] + ':cluster/' + topic_arn.split(':')[5]
    
    # 获取Kafka集群的Bootstrap服务器
    response = kafka_client.get_bootstrap_brokers(ClusterArn=cluster_arn)
    bootstrap_servers = response['BootstrapBrokerString']
    
    # 创建Kafka消费者
    from kafka import KafkaConsumer
    consumer = KafkaConsumer(bootstrap_servers=bootstrap_servers,
                             auto_offset_reset='earliest',
                             consumer_timeout_ms=1000)
    
    # 订阅主题
    consumer.subscribe([topic_name])
    
    # 读取消息
    for message in consumer:
        # 处理消息
        print(json.loads(message.value))
    
    # 关闭消费者
    consumer.close()

请确保已安装kafka-python库。您可以使用以下命令来安装它：

pip install kafka-python

在代码中，我们首先使用boto3库创建了一个Kafka客户端，然后从事件中获取了主题的ARN。接下来，我们解析ARN以获取主题名称和Kafka集群的ARN。然后，我们使用Kafka客户端获取Kafka集群的Bootstrap服务器。最后，我们使用kafka-python库创建一个Kafka消费者，并订阅主题。在for循环中，我们可以处理收到的消息。

请注意，在Lambda函数的执行角色中，您需要为其提供适当的权限，以便访问MSK主题。

希望这个代码示例能够帮助您在AWS Lambda中使用MSK主题作为事件源，并读取Kafka消息。