如何为卡夫卡制作人选择键和偏移量

我在跟踪 here 。同时遵循代码。我提出了两个问题

1. 键和偏移量是否相同?

据谷歌称,

抵消: 卡夫卡主题通过一组分布式的 存储它们的分区。每个分区维护 它按顺序接收到的消息 由一个偏移量标识,也称为位置。

似乎两者对我都很相似。因为offset在分区中维护一条唯一的消息:生产者根据records键将记录发送到分区

2. 为生产商选择键/偏移量的最佳方法是什么?

例如,我上面提供的示例,他们选择时间戳作为键和偏移量。 这总是最好的建议吗?

 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为给定的键值发送实时数据流消息。所以我想用这个键作为分区键和偏移量。但要确保我的想法是正确的。