为了读取已写入主题（在使用者启动之前）的主题消息，需要将offset值设置为尽可能小的值（相当于 --from-beginning ). 根据rkafka文件 autoOffseetReset 参数默认为 largest 自动偏移集
最小：自动将偏移重置为最小偏移
最大：自动将偏移量重置为最大偏移量
其他：向消费者抛出异常
required:optional
type:string
default:largest
为了能够使用消息，您需要设置 autoOffsetReset 至 "smallest" .

consumer1=rkafka.createConsumer("127.0.0.1:2181","test", autoOffsetReset="smallest")

更新：此代码适用于：

library(rkafka)

prod1=rkafka.createProducer("127.0.0.1:9092")
rkafka.send(prod1,"test","127.0.0.1:9092","Testing once")
rkafka.send(prod1,"test","127.0.0.1:9092","Testing twice")

rkafka.closeProducer(prod1)
consumer1=rkafka.createConsumer("127.0.0.1:2181","test",groupId = "test-consumer- 
group",zookeeperConnectionTimeoutMs = "100000",autoCommitEnable = "NULL", 
autoCommitInterval = "NULL",autoOffsetReset = "NULL")

print(rkafka.read(consumer1))
print(rkafka.readPoll(consumer1))
rkafka.closeConsumer(consumer1)

关键是删除kafka生成的日志后重新启动它。