写一段flume提取kafka到hdfs的脚本

以下是一个简单的Flume配置文件，用于从Kafka读取消息并将其写入HDFS：

# Name the components on this agent
agent.sources = kafka-source
agent.sinks = hdfs-sink
agent.channels = memory-channel

# Configure the Kafka source
agent.sources.kafka-source.type = org.apache.flume.source.kafka.KafkaSource
agent.sources.kafka-source.kafka.bootstrap.servers = localhost:9092
agent.sources.kafka-source.kafka.topics = my_topic
agent.sources.kafka-source.kafka.consumer.group.id = flume

# Configure the HDFS sink
agent.sinks.hdfs-sink.type = hdfs
agent.sinks.hdfs-sink.hdfs.path = /path/to/hdfs/directory/
agent.sinks.hdfs-sink.hdfs.fileType = DataStream
agent.sinks.hdfs-sink.hdfs.writeFormat = Text

# Use a memory channel to buffer events
agent.channels.memory-channel.type = memory

# Bind the source and sink to the channel
agent.sources.kafka-source.channels = memory-channel
agent.sinks.hdfs-sink.channel = memory-channel

在上面的配置文件中，我们指定了Kafka source的类型为 `org.apache.flume.source.kafka.KafkaSource`。我们还指定了Kafka broker的地址、要消费的Kafka topic以及消费者组的ID。

我们将HDFS sink的类型指定为 `hdfs`，并指定要写入的HDFS目录的路径、文件类型和写入格式。

最后，我们使用内存通道来缓冲事件，并将Kafka source和HDFS sink绑定到通道上。

您可以使用以下命令来启动Flume代理：

$ bin/flume-ng agent -n agent -c conf -f /path/to/flume-conf.properties

这里，`/path/to/flume-conf.properties`是您的Flume配置文件的路径。请确保Kafka和Hadoop集群在运行并可访问。