如果采用上述方法，如何将主题1中的特定消息Map到主题2中的特定消息。有没有办法在topic1和topic2中提供相同的消息ID？
要在同一kafka集群中的主题之间Map或连接特定消息，kafka流和ksql可能是一个很好的方向。你能在这里找到参考资料吗。
有很多方法可以使对象唯一，我建议在向topic1和topic2发送消息时使用父实体id。java代码示例如下：

ProducerRecord<String, ParentEntity> record = new ProducerRecord<>(topic1, 
ParentEntity.getId(), ParentEntity);
ListenableFuture<SendResult<String, ParentEntity>> future = 
kafkaTemplate.send(record);
future.addCallback(new ListenableFutureCallback<SendResult<String, 
ParentEntity>>() {
    @Override
    public void onSuccess(SendResult<String, ParentEntity> result) {}

    @Override
    public void onFailure(Throwable ex) {
        //print out error log 
    }
});

ProducerRecord<String, ChildEntity> record = new ProducerRecord<>(topic2, 
ChildEntity.getParentEntityId(), ChildEntity);
ListenableFuture<SendResult<String, ChildEntity>> future = 
kafkaTemplate.send(record);
future.addCallback(new ListenableFutureCallback<SendResult<String, 
ChildEntity>>() {
    @Override
    public void onSuccess(SendResult<String, ChildEntity> result) {}

    @Override
    public void onFailure(Throwable ex) {
        //print out error log 
    }
});

如果我只使用一个主题，有没有办法解决这个问题？
您可以在数据库中创建一个新表（称为a）来存储要发送用于索引的完整消息。每次用户创建或更新数据时，也会将消息插入/更新到表a中。最后，您的kafka客户机从表a中提取消息对象，并生成kafka集群中的唯一主题。
有没有更好的设计/方法来解决上述问题？
你可以试试Kafka流和ksql，正如我上面提到的。