基本服务器配置 一个基本的代理配置可能看起来像这样。您将看到主题、话题和日志的设置。 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 num.partitions=1 default.replication.factor=3 offsets.topic.replication.factor=3 transaction.state.log.replication.factor=3 transaction.state.log.min.isr=1 log.retention.hours=168 log.segment.bytes=1073741824 log.retention.check.interval.ms=300000 num.network.threads=3 num.io.threads=8 num.recovery.threads.per.data.dir=1 socket.send.buffer.bytes=102400 socket.receive.buffer.bytes=102400

基本生产者配置 1 2 3 4 5 bootstrap.servers=localhost:9092 key.serializer=org.apache.kafka.common.serialization.StringSerializer value.serializer=org.apache.kafka.common.serialization.StringSerializer client.id=my-client compression.type=gzip 此配置指定连接到 Kafka 集群的引导地址，以及将消息的键和值从字符串转换为其相应的原始字节数据表示的序列化程序。 （

基本消费者配置 基本的消费者配置必须有一个host:port引导服务器地址，用于连接到 Kafka 代理。它还需要反序列化器来转换消息键和值。建议使用客户