我跟着这里。跟着代码。我提出了两个问题
键和偏移相同吗？
谷歌称，
偏移量：kafka主题通过存储消息的分布式分区集接收消息。每个分区都按顺序维护它接收到的消息，这些消息由偏移量（也称为位置）标识。
对我来说似乎两者都很相似。因为offset在分区中维护唯一的消息：生产者根据记录的键将记录发送到分区
为制作者选择关键帧/偏移量的最佳方法是什么？
对于我上面提供的示例，他们选择时间戳作为键和偏移量。这总是最好的推荐吗？

class IRCMessageListener extends IRCEventAdapter {
    @Override
    public void onPrivmsg(String channel, IRCUser u, String msg) {
        IRCMessage event = new IRCMessage(channel, u, msg);
        //FIXME kafka round robin default partitioner seems to always publish to partition 0 only (?)
        long ts = event.getInt64("timestamp");
        Map<String, ?> srcOffset = Collections.singletonMap(TIMESTAMP_FIELD, ts);
        Map<String, ?> srcPartition = Collections.singletonMap(CHANNEL_FIELD, channel);
        SourceRecord record = new SourceRecord(srcPartition, srcOffset, topic, KEY_SCHEMA, ts, IRCMessage.SCHEMA, event);
        queue.offer(record);
    }

因为我实际上是在尝试创建一个定制的kafka连接器来从第三方websocketapi获取数据。api为给定的键值发送实时数据流消息。所以我想用这个键作为我的分区键和偏移量。但我得确定我的想法是对的。