Message message = new Message(key, offset, timestamp, chatMessageTo.getText());
ChatRoomData chatRoomData = this.chatRoomData[partition].get(chatRoomId);
Message message = new Message(key, offset, timestamp, chatMessageTo.getText());
ChatRoomData chatRoomData = this.chatRoomData[partition].get(chatRoomId);