diff --git a/client/src/components/Table/Table.jsx b/client/src/components/Table/Table.jsx
index e6308c282..0d8ab5841 100644
--- a/client/src/components/Table/Table.jsx
+++ b/client/src/components/Table/Table.jsx
@@ -43,7 +43,8 @@ class Table extends Component {
   };
 
   renderHeader() {
-    const { has2Headers, firstHeader, columns, actions, data } = this.props;
+    const { has2Headers, firstHeader, columns, actions, data, loading, updateCheckbox, isChecked } =
+      this.props;
     return (
       <>
         {has2Headers && (
@@ -74,7 +75,19 @@ class Table extends Component {
                 return (
                   <th className="header-text" key={`secondHead${column.colName}${index}`}>
                     <div className="header-content">
-                      {column.colName}
+                      {!loading && data && data.length > 0 && column.id === 'checkboxes' ? (
+                        <>
+                          <input
+                            type="checkbox"
+                            checked={isChecked}
+                            onChange={e => {
+                              updateCheckbox(e);
+                            }}
+                          />
+                        </>
+                      ) : (
+                        column.colName
+                      )}
                       {column.sortable && (
                         <i
                           className="fa fa-sort clickable"
@@ -535,6 +548,7 @@ class Table extends Component {
 Table.propTypes = {
   title: PropTypes.string,
   has2Headers: PropTypes.bool,
+  isChecked: PropTypes.bool,
   firstHeader: PropTypes.arrayOf(
     PropTypes.shape({
       colName: PropTypes.string,
@@ -562,6 +576,7 @@ Table.propTypes = {
   onRestart: PropTypes.func,
   onShare: PropTypes.func,
   onDownload: PropTypes.func,
+  updateCheckbox: PropTypes.func,
   onCopy: PropTypes.func,
 
   idCol: PropTypes.string,
diff --git a/client/src/containers/Topic/Topic/Topic.jsx b/client/src/containers/Topic/Topic/Topic.jsx
index 756d6ab9d..d3505c44d 100644
--- a/client/src/containers/Topic/Topic/Topic.jsx
+++ b/client/src/containers/Topic/Topic/Topic.jsx
@@ -1,5 +1,6 @@
 import React from 'react';
 import Header from '../../Header';
+import Dropdown from 'react-bootstrap/Dropdown';
 import TopicData from './TopicData';
 import TopicPartitions from './TopicPartitions';
 import TopicGroups from './TopicGroups';
@@ -24,7 +25,11 @@ class Topic extends Root {
     compactMessageToDelete: '',
     roles: JSON.parse(sessionStorage.getItem('roles')),
     topicInternal: false,
-    configs: []
+    configs: [],
+    isAllTopicDataSelected: false,
+    downloadFormat: 'Select',
+    downloadOptions: ['Select', 'csv', 'json'],
+    messages: []
   };
 
   tabs = ['data', 'partitions', 'groups', 'configs', 'acls', 'logs'];
@@ -32,6 +37,7 @@ class Topic extends Root {
   constructor(props) {
     super(props);
     this.topicData = React.createRef();
+    this._handleSelectAllCheckboxChange = this._handleSelectAllCheckboxChange.bind(this);
   }
 
   static getDerivedStateFromProps(props, state) {
@@ -73,6 +79,51 @@ class Topic extends Root {
     });
   }
 
+  _handleSelectAllCheckboxChange = (isAllTopicDataSelected, messages) => {
+    this.setState({ isAllTopicDataSelected: isAllTopicDataSelected, messages: messages });
+  };
+
+  _renderDownloadFormat = isChecked => {
+    const { downloadOptions } = this.state;
+
+    let renderedOptions = [];
+    for (let option of downloadOptions) {
+      renderedOptions.push(
+        <Dropdown.Item
+          key={option}
+          se
+          disabled={isChecked === false}
+          onClick={() =>
+            this.setState({ downloadFormat: option }, () => {
+              this._handleDownloadAll(option);
+            })
+          }
+        >
+          <i className="fa fa-fw pull-left" aria-hidden="true" /> {option}
+        </Dropdown.Item>
+      );
+    }
+    return renderedOptions;
+  };
+
+  _handleDownloadAll(option) {
+    let messages = this.state.messages;
+    if (this.state.isAllTopicDataSelected && option !== 'Select') {
+      let allData = [];
+      messages.map(tableData => {
+        allData.push(tableData.value);
+        allData.push('\n');
+      });
+      const a = document.createElement('a');
+      const type = 'text/' + option;
+      a.href = URL.createObjectURL(new Blob([allData], { type: type }));
+      a.download = `file.${option}`;
+
+      a.click();
+      a.remove();
+    }
+  }
+
   showDeleteModal = deleteMessage => {
     this.setState({ showDeleteModal: true, deleteMessage });
   };
@@ -136,7 +187,14 @@ class Topic extends Root {
     switch (selectedTab) {
       case 'data':
         return (
-          <TopicData ref={this.topicData} history={history} match={match} location={location} />
+          <TopicData
+            ref={this.topicData}
+            history={history}
+            match={match}
+            location={location}
+            isAllTopicDataSelected={this.state.isAllTopicDataSelected}
+            onSelectAllCheckboxChange={this._handleSelectAllCheckboxChange}
+          />
         );
       case 'partitions':
         return <TopicPartitions clusterId={clusterId} topic={topicId} history={history} />;
@@ -236,6 +294,18 @@ class Topic extends Root {
         {selectedTab !== 'configs' && roles.topic && roles.topic['topic/data/insert'] && (
           <aside>
             <li className="aside-button">
+              {this.state.isAllTopicDataSelected && (
+                <div className="btn mr-2">
+                  <Dropdown>
+                    <Dropdown.Toggle>
+                      <strong>Download Format:</strong> ({this.state.downloadFormat})
+                    </Dropdown.Toggle>
+                    <Dropdown.Menu>
+                      <div>{this._renderDownloadFormat(this.state.isAllTopicDataSelected)}</div>
+                    </Dropdown.Menu>
+                  </Dropdown>
+                </div>
+              )}
               {this.canEmptyTopic() ? (
                 <div
                   onClick={() => {
diff --git a/client/src/containers/Topic/Topic/TopicData/TopicData.jsx b/client/src/containers/Topic/Topic/TopicData/TopicData.jsx
index c52f70891..eb9811f69 100644
--- a/client/src/containers/Topic/Topic/TopicData/TopicData.jsx
+++ b/client/src/containers/Topic/Topic/TopicData/TopicData.jsx
@@ -90,6 +90,11 @@ class TopicData extends Root {
 
   eventSource;
 
+  constructor(props) {
+    super(props);
+    this._handleCheckbox = this._handleCheckbox.bind(this);
+  }
+
   componentDidMount = () => {
     this._checkProps();
   };
@@ -407,6 +412,10 @@ class TopicData extends Root {
     a.remove();
   }
 
+  _handleCheckbox(e) {
+    this.props.onSelectAllCheckboxChange(e.target.checked, this.state.messages);
+  }
+
   async _handleOnDateTimeFormatChanged(newDateTimeFormat) {
     const { clusterId } = this.props.match.params;
     this.setState({
@@ -953,7 +962,21 @@ class TopicData extends Root {
             history={history}
             reduce={true}
             firstHeader={firstColumns}
+            isChecked={this.props.isAllTopicDataSelected}
             columns={[
+              {
+                id: 'checkboxes',
+                accessor: 'checkboxes',
+                colName: 'Download all',
+                type: 'checkbox',
+                expand: true,
+                cell: () => {
+                  return (
+                    <input type="checkbox" checked={this.props.isAllTopicDataSelected} readOnly />
+                  );
+                },
+                readOnly: true
+              },
               {
                 id: 'key',
                 accessor: 'key',
@@ -1097,6 +1120,9 @@ class TopicData extends Root {
             updateData={data => {
               this.setState({ messages: data });
             }}
+            updateCheckbox={e => {
+              this._handleCheckbox(e);
+            }}
             onDelete={row => {
               this._handleOnDelete(row);
             }}