                        课程
                    
                        /后端开发
                        
                            /Java
                        
                        /Kafka流处理平台

关于partition和message的问题？

在您的代码里面，每次发送消息的单位是一个MessageEntity,可不可以将这个MessageEntity理解为一个Partition,存取数据的一个基本单元。

public class MessageEntity {
    private String title;
    private String body;

    @Override
    public String toString() {
        return "MessageEntity{" +
                "title='" + title + '\'' +
                ", body='" + body + '\'' +
                '}';
    }
}