+ * IllegalArgumentException when namespace not found
+ * IllegalStateException when failed to grant permission + */ + CompletableFuture
+ * IllegalArgumentException when namespace not found
+ * IllegalStateException when failed to grant permission + */ + CompletableFuture
- Either the max rollover time has been reached
- or max entries have been written to the ledged and at least min-time has passed
+ * IllegalArgumentException when namespace not found
+ * IllegalStateException when failed to grant permission + */ + CompletableFuture
+ * IllegalArgumentException when namespace not found
+ * IllegalStateException when failed to grant permission + */ + CompletableFuture
+
+
+
+
+
+
+
+ );
+ }
+}
+
+module.exports = AdminRestApi;
diff --git a/site2/website/pages/en/contact.js b/site2/website/pages/en/contact.js
new file mode 100644
index 0000000000000000000000000000000000000000..1bda91e19b64e116f1f4ea1a7ee773ff64c92a98
--- /dev/null
+++ b/site2/website/pages/en/contact.js
@@ -0,0 +1,118 @@
+
+const React = require('react');
+
+const CompLibrary = require('../../core/CompLibrary.js');
+const Container = CompLibrary.Container;
+const MarkdownBlock = CompLibrary.MarkdownBlock; /* Used to read markdown */
+const GridBlock = CompLibrary.GridBlock;
+
+const CWD = process.cwd();
+
+const siteConfig = require(`${CWD}/siteConfig.js`);
+
+function docUrl(doc, language) {
+ return siteConfig.baseUrl + 'docs/' + (language ? language + '/' : '') + doc;
+}
+
+class Contact extends React.Component {
+ render() {
+ let language = this.props.language || '';
+ const mailingLists = [
+ {
+ email: 'users@pulsar.incubator.apache.org',
+ desc: 'User-related discussions',
+ subscribe: 'mailto:users@pulsar.incubator.apache.org',
+ unsubscribe: 'mailto:users-unsubscribe@pulsar.incubator.apache.org',
+ archives: 'http://mail-archives.apache.org/mod_mbox/incubator-pulsar-users/'
+ },
+ {
+ email: 'dev@pulsar.incubator.apache.org',
+ desc: 'Development-related discussions',
+ subscribe: 'mailto:dev@pulsar.incubator.apache.org',
+ unsubscribe: 'mailto:dev-unsubscribe@pulsar.incubator.apache.org',
+ archives: 'http://mail-archives.apache.org/mod_mbox/incubator-pulsar-dev/'
+ },
+ {
+ email: 'dev@pulsar.incubator.apache.org',
+ desc: 'All commits to the Pulsar repository',
+ subscribe: 'mailto:commits-subscribe@pulsar.incubator.apache.org',
+ unsubscribe: 'mailto:commits-unsubscribe@pulsar.incubator.apache.org',
+ archives: 'http://mail-archives.apache.org/mod_mbox/incubator-pulsar-commits/'
+ }
+ ]
+
+ const supportLinks = [
+ {
+ content: `Learn more using the [documentation on this site.](${docUrl(
+ 'doc1.html',
+ language
+ )})`,
+ title: 'Browse Docs',
+ },
+ {
+ content: 'Ask questions about the documentation and project',
+ title: 'Join the community',
+ },
+ {
+ content: "Find out what's new with this project",
+ title: 'Stay up to date',
+ },
+ ];
+
+ return (
+
+
+
+
+ );
+ }
+}
+
+module.exports = Contact;
diff --git a/site2/website/pages/en/download.js b/site2/website/pages/en/download.js
new file mode 100644
index 0000000000000000000000000000000000000000..248487446b53900a0214d5d07787a50320a4ee24
--- /dev/null
+++ b/site2/website/pages/en/download.js
@@ -0,0 +1,177 @@
+const React = require('react');
+
+const CompLibrary = require('../../core/CompLibrary');
+const MarkdownBlock = CompLibrary.MarkdownBlock; /* Used to read markdown */
+const Container = CompLibrary.Container;
+const GridBlock = CompLibrary.GridBlock;
+
+const CWD = process.cwd();
+
+const siteConfig = require(`${CWD}/siteConfig.js`);
+const releases = require(`${CWD}/releases.json`);
+
+const archiveRootUrl = siteConfig.archiveRootUrl;
+
+
+function archiveUrl(version, type) {
+ return `${archiveRootUrl}/pulsar-${version}/apache-pulsar-${version}-${type}.tar.gz`
+}
+
+class Download extends React.Component {
+ render() {
+ const latestRelease = releases[0];
+
+ const latestVersion = `${latestRelease}-incubating`
+ const latestArchiveUrl = archiveUrl(latestVersion, 'bin');
+ const latestSrcArchiveUrl = archiveUrl(latestVersion, 'src')
+
+ const releaseInfo = releases.map(r => {
+ const version = `${r}-incubating`;
+ return {
+ version: version,
+ binArchiveUrl: archiveUrl(version, 'bin'),
+ srcArchiveUrl: archiveUrl(version, 'src')
+ }
+ });
+
+ return (
+
+
+
+
+
+
+
+
+
+ The Slack instance is at [https://apache-pulsar.slack.com/](https://apache-pulsar.slack.com/)
+
+
+ You can self-register at [https://apache-pulsar.herokuapp.com/](https://apache-pulsar.herokuapp.com/)
+
+
+ Contact
++
+ There are many ways to get help from the Apache Pulsar community. + The mailing lists are the primary place where all Pulsar committers are present. + Bugs and feature requests can either be discussed on the dev mailing list or + by opening an issue on GitHub. +
+ +Mailing Lists
+| Name | +Scope | ++ | + | + |
|---|---|---|---|---|
| {list.email} | +{list.desc} | +Subscribe | +Unsubscribe | +Archives | +
Slack
+There is a Pulsar slack channel that is used for informal discussions for devs and users.
+
+
+
+
+ );
+ }
+}
+
+module.exports = Download;
diff --git a/site2/website/pages/en/events.js b/site2/website/pages/en/events.js
new file mode 100644
index 0000000000000000000000000000000000000000..c4ef8b08b80ad3c02ab7cc4d8b68099e5a7196a8
--- /dev/null
+++ b/site2/website/pages/en/events.js
@@ -0,0 +1,48 @@
+
+const React = require('react');
+
+const CompLibrary = require('../../core/CompLibrary.js');
+const Container = CompLibrary.Container;
+const MarkdownBlock = CompLibrary.MarkdownBlock; /* Used to read markdown */
+const GridBlock = CompLibrary.GridBlock;
+
+const CWD = process.cwd();
+
+const siteConfig = require(`${CWD}/siteConfig.js`);
+
+const iframeSrc = "https://calendar.google.com/calendar/embed?showTitle=0&showPrint=0&showCalendars=0&mode=AGENDA&height=300&wkst=1&hl=en&bgcolor=%23FFFFFF&src=22kknj432ap5io49lvsjaac71o%40group.calendar.google.com&color=%232952A3&ctz=America%2FLos_Angeles";
+
+class Events extends React.Component {
+ render() {
+
+ return (
+
+
+
+
+
+
+
+
+
+ You must [verify](https://www.apache.org/info/verification.html) the integrity of the downloaded files.
+ We provide OpenPGP signatures for every release file. This signature should be matched against the
+ [KEYS](https://www.apache.org/dist/incubator/pulsar/KEYS) file which contains the OpenPGP keys of
+ Pulsar's Release Managers. We also provide `MD5` and `SHA-512` checksums for every release file.
+ After you download the file, you should calculate a checksum for your download, and make sure it is
+ the same as ours.
+
+
+
+
+ [Release notes](/release-notes) for all Pulsar's versions
+
+
+
+ Once you've downloaded a Pulsar release, instructions on getting up and running with a standalone cluster
+ that you can run on your laptop can be found in the [Run Pulsar locally](/docs/standalone) tutorial.
+
+
+
+
+
+
+
+
+
+ Apache Pulsar downloads
++
Current version (Stable) {latestVersion}
+| Release | +Link | +Crypto files | +
|---|---|---|
| Binary | ++ pulsar-{latestVersion}-bin.tar.gz + | ++ asc, + sha1, + sha512 + | +
| Source | ++ pulsar-{latestVersion}-src.tar.gz + | ++ asc, + sha1, + sha512 + | +
Release Integrity
+Release notes
+Getting started
++ If you need to connect to an existing Pulsar cluster or instance using an officially supported client, + see the client docs for these languages: +
+| Client guide | +API docs | +
|---|---|
| The Pulsar java client | +The Pulsar java client | +
| The Pulsar go client | +The Pulsar go client | +
| The Pulsar python client | +The Pulsar python client | +
| The Pulsar C++ client | +The Pulsar C++ client | +
Older releases
+| Release | +Binary | +Source | +Release notes | +
|---|---|---|---|
| {info.version} | ++ pulsar-{info.version}-bin-tar.gz + + (asc, + sha1, + sha512) + | ++ pulsar-{info.version}-bin-tar.gz + + (asc, + sha1, + sha512) + | ++ Release Notes + | +
+
+
+
+ );
+ }
+}
+
+module.exports = Events;
diff --git a/site2/website/pages/en/index.js b/site2/website/pages/en/index.js
new file mode 100755
index 0000000000000000000000000000000000000000..0ad7d5866eb1e43d4a61a995a1247bc14b0af70d
--- /dev/null
+++ b/site2/website/pages/en/index.js
@@ -0,0 +1,195 @@
+
+const React = require('react');
+
+const CompLibrary = require('../../core/CompLibrary.js');
+const MarkdownBlock = CompLibrary.MarkdownBlock; /* Used to read markdown */
+const Container = CompLibrary.Container;
+const GridBlock = CompLibrary.GridBlock;
+
+const CWD = process.cwd();
+
+const siteConfig = require(`${CWD}/siteConfig.js`);
+
+function imgUrl(img) {
+ return siteConfig.baseUrl + 'img/' + img;
+}
+
+function docUrl(doc, language) {
+ return siteConfig.baseUrl + 'docs/' + (language ? language + '/' : '') + doc;
+}
+
+function pageUrl(page, language) {
+ return siteConfig.baseUrl + (language ? language + '/' : '') + page;
+}
+
+function githubUrl() {
+ return siteConfig.githubUrl;
+}
+
+
+class Button extends React.Component {
+ render() {
+ return (
+
+ );
+ }
+}
+
+Button.defaultProps = {
+ target: '_self',
+};
+
+const SplashContainer = props => (
+
+
+
+
+
+ - [Apache Pulsar Bay Area Meetup Group](https://www.meetup.com/Apache-Pulsar-Meetup-Group/)
+
+
+ - [Japan Pulsar User Group](https://japan-pulsar-user-group.connpass.com/)
+
+
+ Events
++
Calander
+ + + +Groups
+
+
+);
+
+const Logo = props => (
+
+
+ {props.children}
+
+ 
+
+);
+
+const ProjectTitle = props => (
+ + {siteConfig.projectDescription} +
+); + +const PromoSection = props => ( +
+
+);
+
+class HomeSplash extends React.Component {
+ render() {
+ let language = this.props.language || '';
+ return (
+
+
+ {props.children}
+
+
+
+
+
+
+
+
+
+ })
+
+
+ + Apache Pulsar is an effort undergoing incubation at The Apache Software Foundation (ASF) + sponsored by the Apache Incubator PMC. Incubation is required of all newly accepted projects + until a further review indicates that the infrastructure, communications, and decision making + process have stabilized in a manner consistent with other successful ASF projects. + While incubation status is not necessarily a reflection of the completeness or stability of the code, + it does indicate that the project has yet to be fully endorsed by the ASF. + Apache Pulsar (incubating) is available under the Apache License, version 2.0. +
+
+
+ );
+ }
+}
+
+module.exports = Index;
diff --git a/site2/website/pages/en/release-notes.js b/site2/website/pages/en/release-notes.js
new file mode 100644
index 0000000000000000000000000000000000000000..09643e37731494e97a23875c6505cfa8c1389ab0
--- /dev/null
+++ b/site2/website/pages/en/release-notes.js
@@ -0,0 +1,35 @@
+const React = require('react');
+
+const CompLibrary = require('../../core/CompLibrary');
+const MarkdownBlock = CompLibrary.MarkdownBlock; /* Used to read markdown */
+const Container = CompLibrary.Container;
+const GridBlock = CompLibrary.GridBlock;
+
+const CWD = process.cwd();
+
+const siteConfig = require(`${CWD}/siteConfig.js`);
+
+const releaseNotes = require('fs').readFileSync(`${CWD}/release-notes.md`, 'utf8')
+
+class ReleaseNotes extends React.Component {
+ render() {
+
+ return (
+
+
+
+
+
+
+ );
+ }
+}
+
+module.exports = ReleaseNotes;
diff --git a/site2/website/pages/en/resources.js b/site2/website/pages/en/resources.js
new file mode 100644
index 0000000000000000000000000000000000000000..621d748253916a3658abec55d44c0a20b0d54a70
--- /dev/null
+++ b/site2/website/pages/en/resources.js
@@ -0,0 +1,78 @@
+
+
+const React = require('react');
+
+const CompLibrary = require('../../core/CompLibrary.js');
+const Container = CompLibrary.Container;
+
+const CWD = process.cwd();
+
+const siteConfig = require(`${CWD}/siteConfig.js`);
+const resources = require(`${CWD}/data/resources.js`)
+
+class Resources extends React.Component {
+ render() {
+ let language = this.props.language || '';
+
+
+ return (
+
+
+
+
+
+ {releaseNotes}
+
+
+ Apache Pulsar downloads
++
+
+
+
+ );
+ }
+}
+
+module.exports = Resources;
diff --git a/site2/website/pages/en/team.js b/site2/website/pages/en/team.js
new file mode 100644
index 0000000000000000000000000000000000000000..8f6a9b8fe3ca8a618a4ffd040aaf40dba84f2d34
--- /dev/null
+++ b/site2/website/pages/en/team.js
@@ -0,0 +1,96 @@
+
+
+const React = require('react');
+
+const CompLibrary = require('../../core/CompLibrary.js');
+const Container = CompLibrary.Container;
+const MarkdownBlock = CompLibrary.MarkdownBlock; /* Used to read markdown */
+const GridBlock = CompLibrary.GridBlock;
+
+const CWD = process.cwd();
+
+const siteConfig = require(`${CWD}/siteConfig.js`);
+const team = require(`${CWD}/data/team.js`)
+
+class Team extends React.Component {
+ render() {
+ let language = this.props.language || '';
+
+
+ return (
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ Resources
++
Articles
+| Forum | +Link | +
|---|---|
| {a.forum} | +{a.title} | +
Presentations
+| Forum | +Data | +Presenter | +Link | +
|---|---|---|---|
| {p.forum} | +{p.date} | +{p.presenter} | +{p.title} | +
+
+
+
+ );
+ }
+}
+
+module.exports = Team;
diff --git a/site2/website/pages/en/versions.js b/site2/website/pages/en/versions.js
new file mode 100644
index 0000000000000000000000000000000000000000..5aabeb1824a50cf511761c52efe8123aab3c3e51
--- /dev/null
+++ b/site2/website/pages/en/versions.js
@@ -0,0 +1,97 @@
+
+const React = require('react');
+
+const CompLibrary = require('../../core/CompLibrary');
+const Container = CompLibrary.Container;
+const GridBlock = CompLibrary.GridBlock;
+
+const CWD = process.cwd();
+
+const siteConfig = require(`${CWD}/siteConfig.js`);
+//const versions = require(CWD + '/versions.json');
+
+/*
+class Versions extends React.Component {
+ render() {
+ const latestVersion = versions[0];
+ return (
+
+
+
+
+
+
+
+
+
+
+
+
+ Contact
++
+ A successful project requires many people to play many roles. + Some members write code or documentation, while others are valuable as testers, + submitting patches and suggestions. +
++ The team is comprised of Members and Contributors. + Members have direct access to the source of a project and actively evolve the codebase. + Contributors improve the project through submission of patches and + suggestions to the Members. The number of Contributors to the project is unbounded. + Get involved today. All contributions to the project are greatly appreciated. +
+ +Committers
++ The following is a list of developers with commit privileges that have directly + contributed to the project in one way or another. +
+| Name | +Apache Id | +Organization | +Roles | +
|---|---|---|---|
| {c.name} | +{c.apacheId} | +{c.org} | +{c.roles} | +
Mentors
+The following people are the mentors of this incubator project
+| Name | +Apache Id | +
|---|---|
| {m.name} | +{m.apacheId} | +
+
+
+
+ );
+ }
+}
+*/
+
+class Versions extends React.Component {
+ render() {
+ return (
+
+
+
+
+
+
+
+
+
+
+
+ {versions.map(
+ version =>
+ version !== latestVersion && (
+
+
+ {siteConfig.title + ' Versions'}
+New versions of this project are released every so often.
+Current version (Stable)
+| {latestVersion} | ++ Documentation + | ++ Release Notes + | +
|---|
+ This is the version that is configured automatically when you + first install this project. +
+Pre-release versions
+| master | ++ Documentation + | ++ Release Notes + | +
|---|
Other text describing this section.
+Past Versions
+| {version} | ++ Documentation + | ++ Release Notes + | +
|---|
+ You can find past versions of this project{' '} + on GitHub . +
+