[kafka-site] branch asf-site updated: MINOR Fix download links (#450)
This is an automated email from the ASF dual-hosted git repository. davidarthur pushed a commit to branch asf-site in repository https://gitbox.apache.org/repos/asf/kafka-site.git The following commit(s) were added to refs/heads/asf-site by this push: new 07b610ed MINOR Fix download links (#450) 07b610ed is described below commit 07b610ed89f8be2183c952fe1ad3ed7aac7c42e8 Author: David Arthur AuthorDate: Wed Sep 28 20:54:43 2022 -0400 MINOR Fix download links (#450) Reviewers: Ismael Juma --- documentation.html | 2 +- documentation/index.html | 2 +- documentation/streams/architecture.html| 2 +- documentation/streams/core-concepts.html | 2 +- .../streams/developer-guide/app-reset-tool.html| 2 +- .../streams/developer-guide/config-streams.html| 2 +- .../streams/developer-guide/datatypes.html | 2 +- documentation/streams/developer-guide/dsl-api.html | 2 +- .../developer-guide/dsl-topology-naming.html | 2 +- documentation/streams/developer-guide/index.html | 2 +- .../developer-guide/interactive-queries.html | 2 +- .../streams/developer-guide/manage-topics.html | 2 +- .../streams/developer-guide/memory-mgmt.html | 2 +- .../streams/developer-guide/processor-api.html | 2 +- .../streams/developer-guide/running-app.html | 2 +- .../streams/developer-guide/security.html | 2 +- documentation/streams/developer-guide/testing.html | 2 +- .../streams/developer-guide/write-streams.html | 2 +- documentation/streams/index.html | 2 +- documentation/streams/quickstart.html | 2 +- documentation/streams/upgrade-guide.html | 2 +- downloads.html | 57 +++--- intro.html | 2 +- protocol.html | 2 +- quickstart.html| 2 +- uses.html | 2 +- 26 files changed, 31 insertions(+), 76 deletions(-) diff --git a/documentation.html b/documentation.html index de631f9a..1eea2c2d 100644 --- a/documentation.html +++ b/documentation.html @@ -1,2 +1,2 @@ - + diff --git a/documentation/index.html b/documentation/index.html index e6239cd4..d27e366a 100644 --- a/documentation/index.html +++ b/documentation/index.html @@ -1,2 +1,2 @@ - + diff --git a/documentation/streams/architecture.html b/documentation/streams/architecture.html index 0fb921d3..a4515030 100644 --- a/documentation/streams/architecture.html +++ b/documentation/streams/architecture.html @@ -1,2 +1,2 @@ - + diff --git a/documentation/streams/core-concepts.html b/documentation/streams/core-concepts.html index 43f2744f..2b21f219 100644 --- a/documentation/streams/core-concepts.html +++ b/documentation/streams/core-concepts.html @@ -1,2 +1,2 @@ - + diff --git a/documentation/streams/developer-guide/app-reset-tool.html b/documentation/streams/developer-guide/app-reset-tool.html index 470c8b6f..66ca1562 100644 --- a/documentation/streams/developer-guide/app-reset-tool.html +++ b/documentation/streams/developer-guide/app-reset-tool.html @@ -1,2 +1,2 @@ - + diff --git a/documentation/streams/developer-guide/config-streams.html b/documentation/streams/developer-guide/config-streams.html index 70890fba..8a8c2514 100644 --- a/documentation/streams/developer-guide/config-streams.html +++ b/documentation/streams/developer-guide/config-streams.html @@ -1,2 +1,2 @@ - + diff --git a/documentation/streams/developer-guide/datatypes.html b/documentation/streams/developer-guide/datatypes.html index bfaf0bbc..77ab12a5 100644 --- a/documentation/streams/developer-guide/datatypes.html +++ b/documentation/streams/developer-guide/datatypes.html @@ -1,2 +1,2 @@ - + diff --git a/documentation/streams/developer-guide/dsl-api.html b/documentation/streams/developer-guide/dsl-api.html index be4f0e6f..c39991b9 100644 --- a/documentation/streams/developer-guide/dsl-api.html +++ b/documentation/streams/developer-guide/dsl-api.html @@ -1,2 +1,2 @@ - + diff --git a/documentation/streams/developer-guide/dsl-topology-naming.html b/documentation/streams/developer-guide/dsl-topology-naming.html index 43efc099..f102220a 100644 --- a/documentation/streams/developer-guide/dsl-topology-naming.html +++ b/documentation/streams/developer-guide/dsl-topology-naming.html @@ -1,2 +1,2 @@ - + diff --git a/documentation/streams/developer-guide/index.html b/documentation/streams/developer-guide/index.html index 407ef106..6534f78e 100644 --- a/documentation/streams/developer-guide/index.html +++ b/documentation/streams/developer-guide/index.html @@ -1,2 +1,2 @@ - + diff --git a/documentation/streams/developer-guide/interactive-queries.html b/documentation/streams/developer-guide/interactive-queries.html index 463871c2..3cacc044 100644 ---
[kafka-site] 01/01: Fix links
This is an automated email from the ASF dual-hosted git repository. davidarthur pushed a commit to branch minor-fix-download-links in repository https://gitbox.apache.org/repos/asf/kafka-site.git commit ee80d79dc1e0294e388b193c77fb9cf1d11a72d1 Author: David Arthur AuthorDate: Wed Sep 28 20:50:34 2022 -0400 Fix links --- documentation.html | 2 +- documentation/index.html | 2 +- documentation/streams/architecture.html| 2 +- documentation/streams/core-concepts.html | 2 +- .../streams/developer-guide/app-reset-tool.html| 2 +- .../streams/developer-guide/config-streams.html| 2 +- .../streams/developer-guide/datatypes.html | 2 +- documentation/streams/developer-guide/dsl-api.html | 2 +- .../developer-guide/dsl-topology-naming.html | 2 +- documentation/streams/developer-guide/index.html | 2 +- .../developer-guide/interactive-queries.html | 2 +- .../streams/developer-guide/manage-topics.html | 2 +- .../streams/developer-guide/memory-mgmt.html | 2 +- .../streams/developer-guide/processor-api.html | 2 +- .../streams/developer-guide/running-app.html | 2 +- .../streams/developer-guide/security.html | 2 +- documentation/streams/developer-guide/testing.html | 2 +- .../streams/developer-guide/write-streams.html | 2 +- documentation/streams/index.html | 2 +- documentation/streams/quickstart.html | 2 +- documentation/streams/upgrade-guide.html | 2 +- downloads.html | 57 +++--- intro.html | 2 +- protocol.html | 2 +- quickstart.html| 2 +- uses.html | 2 +- 26 files changed, 31 insertions(+), 76 deletions(-) diff --git a/documentation.html b/documentation.html index de631f9a..1eea2c2d 100644 --- a/documentation.html +++ b/documentation.html @@ -1,2 +1,2 @@ - + diff --git a/documentation/index.html b/documentation/index.html index e6239cd4..d27e366a 100644 --- a/documentation/index.html +++ b/documentation/index.html @@ -1,2 +1,2 @@ - + diff --git a/documentation/streams/architecture.html b/documentation/streams/architecture.html index 0fb921d3..a4515030 100644 --- a/documentation/streams/architecture.html +++ b/documentation/streams/architecture.html @@ -1,2 +1,2 @@ - + diff --git a/documentation/streams/core-concepts.html b/documentation/streams/core-concepts.html index 43f2744f..2b21f219 100644 --- a/documentation/streams/core-concepts.html +++ b/documentation/streams/core-concepts.html @@ -1,2 +1,2 @@ - + diff --git a/documentation/streams/developer-guide/app-reset-tool.html b/documentation/streams/developer-guide/app-reset-tool.html index 470c8b6f..66ca1562 100644 --- a/documentation/streams/developer-guide/app-reset-tool.html +++ b/documentation/streams/developer-guide/app-reset-tool.html @@ -1,2 +1,2 @@ - + diff --git a/documentation/streams/developer-guide/config-streams.html b/documentation/streams/developer-guide/config-streams.html index 70890fba..8a8c2514 100644 --- a/documentation/streams/developer-guide/config-streams.html +++ b/documentation/streams/developer-guide/config-streams.html @@ -1,2 +1,2 @@ - + diff --git a/documentation/streams/developer-guide/datatypes.html b/documentation/streams/developer-guide/datatypes.html index bfaf0bbc..77ab12a5 100644 --- a/documentation/streams/developer-guide/datatypes.html +++ b/documentation/streams/developer-guide/datatypes.html @@ -1,2 +1,2 @@ - + diff --git a/documentation/streams/developer-guide/dsl-api.html b/documentation/streams/developer-guide/dsl-api.html index be4f0e6f..c39991b9 100644 --- a/documentation/streams/developer-guide/dsl-api.html +++ b/documentation/streams/developer-guide/dsl-api.html @@ -1,2 +1,2 @@ - + diff --git a/documentation/streams/developer-guide/dsl-topology-naming.html b/documentation/streams/developer-guide/dsl-topology-naming.html index 43efc099..f102220a 100644 --- a/documentation/streams/developer-guide/dsl-topology-naming.html +++ b/documentation/streams/developer-guide/dsl-topology-naming.html @@ -1,2 +1,2 @@ - + diff --git a/documentation/streams/developer-guide/index.html b/documentation/streams/developer-guide/index.html index 407ef106..6534f78e 100644 --- a/documentation/streams/developer-guide/index.html +++ b/documentation/streams/developer-guide/index.html @@ -1,2 +1,2 @@ - + diff --git a/documentation/streams/developer-guide/interactive-queries.html b/documentation/streams/developer-guide/interactive-queries.html index 463871c2..3cacc044 100644 --- a/documentation/streams/developer-guide/interactive-queries.html +++ b/documentation/streams/developer-guide/interactive-queries.html @@ -1,2 +1,2 @@ - + diff --git
[kafka-site] branch minor-fix-download-links created (now ee80d79d)
This is an automated email from the ASF dual-hosted git repository. davidarthur pushed a change to branch minor-fix-download-links in repository https://gitbox.apache.org/repos/asf/kafka-site.git at ee80d79d Fix links This branch includes the following new commits: new ee80d79d Fix links The 1 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference.
[kafka-site] branch asf-site updated: Fix another missing code tag (#449)
This is an automated email from the ASF dual-hosted git repository. davidarthur pushed a commit to branch asf-site in repository https://gitbox.apache.org/repos/asf/kafka-site.git The following commit(s) were added to refs/heads/asf-site by this push: new f3fe7e48 Fix another missing code tag (#449) f3fe7e48 is described below commit f3fe7e48ecccb2e9397b4fd6609ded00d611ce36 Author: David Arthur AuthorDate: Wed Sep 28 19:44:47 2022 -0400 Fix another missing code tag (#449) Reviewers: Jason Gustafson --- 33/ops.html | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/33/ops.html b/33/ops.html index db6a0e53..470fd7e0 100644 --- a/33/ops.html +++ b/33/ops.html @@ -3474,7 +3474,7 @@ CurrentObservers: [0,1,2] Metadata Shell - The kafka-metadata-shell tool can be used to interactively inspect the state of the cluster metadata partition: + The kafka-metadata-shell tool can be used to interactively inspect the state of the cluster metadata partition: bin/kafka-metadata-shell.sh --snapshot metadata_log_dir/__cluster_metadata-0/.log
[kafka-site] branch minor-fix-code-tag-3 created (now cd81931d)
This is an automated email from the ASF dual-hosted git repository. davidarthur pushed a change to branch minor-fix-code-tag-3 in repository https://gitbox.apache.org/repos/asf/kafka-site.git at cd81931d Fix another missing code tag This branch includes the following new commits: new cd81931d Fix another missing code tag The 1 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference.
[kafka-site] 01/01: Fix another missing code tag
This is an automated email from the ASF dual-hosted git repository. davidarthur pushed a commit to branch minor-fix-code-tag-3 in repository https://gitbox.apache.org/repos/asf/kafka-site.git commit cd81931d60e4ada4e4115d294e61f984a8a56b22 Author: David Arthur AuthorDate: Wed Sep 28 19:42:31 2022 -0400 Fix another missing code tag --- 33/ops.html | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/33/ops.html b/33/ops.html index db6a0e53..470fd7e0 100644 --- a/33/ops.html +++ b/33/ops.html @@ -3474,7 +3474,7 @@ CurrentObservers: [0,1,2] Metadata Shell - The kafka-metadata-shell tool can be used to interactively inspect the state of the cluster metadata partition: + The kafka-metadata-shell tool can be used to interactively inspect the state of the cluster metadata partition: bin/kafka-metadata-shell.sh --snapshot metadata_log_dir/__cluster_metadata-0/.log
[kafka-site] branch asf-site updated: fix errant code elements (#448)
This is an automated email from the ASF dual-hosted git repository. davidarthur pushed a commit to branch asf-site in repository https://gitbox.apache.org/repos/asf/kafka-site.git The following commit(s) were added to refs/heads/asf-site by this push: new 3ffa9ed3 fix errant code elements (#448) 3ffa9ed3 is described below commit 3ffa9ed356e41c03a7bdedaf52074011f2027c79 Author: David Arthur AuthorDate: Wed Sep 28 19:36:53 2022 -0400 fix errant code elements (#448) Reviewers: Niket Goel , Ismael Juma --- 33/ops.html | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/33/ops.html b/33/ops.html index e41d2746..db6a0e53 100644 --- a/33/ops.html +++ b/33/ops.html @@ -3408,7 +3408,7 @@ for built-in state stores, currently we have: Process Roles - In KRaft mode each Kafka server can be configured as a controller, a broker, or both using the process.roles property. This property can have the following values: + In KRaft mode each Kafka server can be configured as a controller, a broker, or both using the process.roles property. This property can have the following values: If process.roles is set to broker, the server acts as a broker. @@ -3438,7 +3438,7 @@ node.id=1 listeners=CONTROLLER://controller1.example.com:9093 controller.quorum.voters=1...@controller1.example.com:9093,2...@controller2.example.com:9093,3...@controller3.example.com:9093 - Every broker and controller must set the controller.quorum.voters property. The node ID supplied in the controller.quorum.voters property must match the corresponding id on the controller servers. For example, on controller1, node.id must be set to 1, and so forth. Each node ID must be unique across all the servers in a particular cluster. No two servers can have the same node ID regardless of their process.roles values. + Every broker and controller must set the controller.quorum.voters property. The node ID supplied in the controller.quorum.voters property must match the corresponding id on the controller servers. For example, on controller1, node.id must be set to 1, and so forth. Each node ID must be unique across all the servers in a particular cluster. No two servers can have the same node ID regardless of their process.roles values. Storage Tool
[kafka] branch trunk updated (d2f900b055d -> d62a42df2e2)
This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git from d2f900b055d MINOR: Small update docs/design.html grammar and typo (#12691) add d62a42df2e2 KAFKA-10199: Integrate Topology Pause/Resume with StateUpdater (#12659) No new revisions were added by this update. Summary of changes: .../processor/internals/DefaultStateUpdater.java | 109 - .../streams/processor/internals/StateUpdater.java | 42 ++-- .../streams/processor/internals/StreamThread.java | 5 +- .../streams/processor/internals/TaskAndAction.java | 16 +-- .../internals/DefaultStateUpdaterTest.java | 75 +++--- .../processor/internals/TaskAndActionTest.java | 40 .../org/apache/kafka/test/StreamsTestUtils.java| 19 7 files changed, 110 insertions(+), 196 deletions(-)
[kafka-site] 01/01: fix errant code elements
This is an automated email from the ASF dual-hosted git repository. davidarthur pushed a commit to branch minor-fix-code-elements in repository https://gitbox.apache.org/repos/asf/kafka-site.git commit 711e71181ea26227fed72b770f32d7816e9ff063 Author: David Arthur AuthorDate: Wed Sep 28 19:23:24 2022 -0400 fix errant code elements --- 33/ops.html | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/33/ops.html b/33/ops.html index e41d2746..db6a0e53 100644 --- a/33/ops.html +++ b/33/ops.html @@ -3408,7 +3408,7 @@ for built-in state stores, currently we have: Process Roles - In KRaft mode each Kafka server can be configured as a controller, a broker, or both using the process.roles property. This property can have the following values: + In KRaft mode each Kafka server can be configured as a controller, a broker, or both using the process.roles property. This property can have the following values: If process.roles is set to broker, the server acts as a broker. @@ -3438,7 +3438,7 @@ node.id=1 listeners=CONTROLLER://controller1.example.com:9093 controller.quorum.voters=1...@controller1.example.com:9093,2...@controller2.example.com:9093,3...@controller3.example.com:9093 - Every broker and controller must set the controller.quorum.voters property. The node ID supplied in the controller.quorum.voters property must match the corresponding id on the controller servers. For example, on controller1, node.id must be set to 1, and so forth. Each node ID must be unique across all the servers in a particular cluster. No two servers can have the same node ID regardless of their process.roles values. + Every broker and controller must set the controller.quorum.voters property. The node ID supplied in the controller.quorum.voters property must match the corresponding id on the controller servers. For example, on controller1, node.id must be set to 1, and so forth. Each node ID must be unique across all the servers in a particular cluster. No two servers can have the same node ID regardless of their process.roles values. Storage Tool
[kafka-site] branch minor-fix-code-elements created (now 711e7118)
This is an automated email from the ASF dual-hosted git repository. davidarthur pushed a change to branch minor-fix-code-elements in repository https://gitbox.apache.org/repos/asf/kafka-site.git at 711e7118 fix errant code elements This branch includes the following new commits: new 711e7118 fix errant code elements The 1 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference.
[kafka-site] branch asf-site updated: Update and publish docs for 3.3 (#447)
This is an automated email from the ASF dual-hosted git repository. davidarthur pushed a commit to branch asf-site in repository https://gitbox.apache.org/repos/asf/kafka-site.git The following commit(s) were added to refs/heads/asf-site by this push: new 2a08851e Update and publish docs for 3.3 (#447) 2a08851e is described below commit 2a08851ee005cecfa7974d34c7bdfe6f732f207e Author: David Arthur AuthorDate: Wed Sep 28 19:15:54 2022 -0400 Update and publish docs for 3.3 (#447) Reviewers: Bill Bejeck , Niket Goel , Colin P. McCabe --- 33/design.html | 36 +++-- 33/generated/connect_metrics.html | 4 +- 33/ops.html| 119 ++- 33/security.html | 167 ++--- documentation.html | 2 +- documentation/index.html | 2 +- documentation/streams/architecture.html| 2 +- documentation/streams/core-concepts.html | 2 +- .../streams/developer-guide/app-reset-tool.html| 2 +- .../streams/developer-guide/config-streams.html| 2 +- .../streams/developer-guide/datatypes.html | 2 +- documentation/streams/developer-guide/dsl-api.html | 2 +- .../developer-guide/dsl-topology-naming.html | 2 +- documentation/streams/developer-guide/index.html | 2 +- .../developer-guide/interactive-queries.html | 2 +- .../streams/developer-guide/manage-topics.html | 2 +- .../streams/developer-guide/memory-mgmt.html | 2 +- .../streams/developer-guide/processor-api.html | 2 +- .../streams/developer-guide/running-app.html | 2 +- .../streams/developer-guide/security.html | 2 +- documentation/streams/developer-guide/testing.html | 2 +- .../streams/developer-guide/write-streams.html | 2 +- documentation/streams/index.html | 2 +- documentation/streams/quickstart.html | 2 +- documentation/streams/upgrade-guide.html | 2 +- downloads.html | 57 ++- intro.html | 2 +- protocol.html | 2 +- quickstart.html| 2 +- uses.html | 2 +- 30 files changed, 370 insertions(+), 63 deletions(-) diff --git a/33/design.html b/33/design.html index 6e32b2d7..9485ab9c 100644 --- a/33/design.html +++ b/33/design.html @@ -322,18 +322,33 @@ Followers consume messages from the leader just as a normal Kafka consumer would and apply them to their own log. Having the followers pull from the leader has the nice property of allowing the follower to naturally batch together log entries they are applying to their log. -As with most distributed systems automatically handling failures requires having a precise definition of what it means for a node to be "alive". For Kafka node liveness has two conditions +As with most distributed systems, automatically handling failures requires a precise definition of what it means for a node to be "alive." In Kafka, a special node +known as the "controller" is responsible for managing the registration of brokers in the cluster. Broker liveness has two conditions: -A node must be able to maintain its session with ZooKeeper (via ZooKeeper's heartbeat mechanism) -If it is a follower it must replicate the writes happening on the leader and not fall "too far" behind + Brokers must maintain an active session with the controller in order to receive regular metadata updates. + Brokers acting as followers must replicate the writes from the leader and not fall "too far" behind. -We refer to nodes satisfying these two conditions as being "in sync" to avoid the vagueness of "alive" or "failed". The leader keeps track of the set of "in sync" nodes. If a follower dies, gets stuck, or falls -behind, the leader will remove it from the list of in sync replicas. The determination of stuck and lagging replicas is controlled by the replica.lag.time.max.ms configuration. + +What is meant by an "active session" depends on the cluster configuration. For KRaft clusters, an active session is maintained by +sending periodic heartbeats to the controller. If the controller fails to receive a heartbeat before the timeout configured by +broker.session.timeout.ms expires, then the node is considered offline. + +For clusters using Zookeeper, liveness is determined indirectly through the existence of an ephemeral node which is created by the broker on +initialization of its Zookeeper session. If the broker loses its session after failing to send heartbeats to Zookeeper before expiration of +zookeeper.session.timeout.ms, then the node gets
svn commit: r57061 - in /release/kafka/3.3.0: ./ 3.3.0/
Author: bbejeck Date: Wed Sep 28 22:49:14 2022 New Revision: 57061 Log: Fix 3.3.0 artifact directory Added: release/kafka/3.3.0/RELEASE_NOTES.html - copied unchanged from r57060, release/kafka/3.3.0/3.3.0/RELEASE_NOTES.html release/kafka/3.3.0/kafka-3.3.0-src.tgz - copied unchanged from r57060, release/kafka/3.3.0/3.3.0/kafka-3.3.0-src.tgz release/kafka/3.3.0/kafka-3.3.0-src.tgz.asc - copied unchanged from r57060, release/kafka/3.3.0/3.3.0/kafka-3.3.0-src.tgz.asc release/kafka/3.3.0/kafka-3.3.0-src.tgz.md5 - copied unchanged from r57060, release/kafka/3.3.0/3.3.0/kafka-3.3.0-src.tgz.md5 release/kafka/3.3.0/kafka-3.3.0-src.tgz.sha1 - copied unchanged from r57060, release/kafka/3.3.0/3.3.0/kafka-3.3.0-src.tgz.sha1 release/kafka/3.3.0/kafka-3.3.0-src.tgz.sha512 - copied unchanged from r57060, release/kafka/3.3.0/3.3.0/kafka-3.3.0-src.tgz.sha512 release/kafka/3.3.0/kafka_2.12-3.3.0-site-docs.tgz - copied unchanged from r57060, release/kafka/3.3.0/3.3.0/kafka_2.12-3.3.0-site-docs.tgz release/kafka/3.3.0/kafka_2.12-3.3.0-site-docs.tgz.asc - copied unchanged from r57060, release/kafka/3.3.0/3.3.0/kafka_2.12-3.3.0-site-docs.tgz.asc release/kafka/3.3.0/kafka_2.12-3.3.0-site-docs.tgz.md5 - copied unchanged from r57060, release/kafka/3.3.0/3.3.0/kafka_2.12-3.3.0-site-docs.tgz.md5 release/kafka/3.3.0/kafka_2.12-3.3.0-site-docs.tgz.sha1 - copied unchanged from r57060, release/kafka/3.3.0/3.3.0/kafka_2.12-3.3.0-site-docs.tgz.sha1 release/kafka/3.3.0/kafka_2.12-3.3.0-site-docs.tgz.sha512 - copied unchanged from r57060, release/kafka/3.3.0/3.3.0/kafka_2.12-3.3.0-site-docs.tgz.sha512 release/kafka/3.3.0/kafka_2.12-3.3.0.tgz - copied unchanged from r57060, release/kafka/3.3.0/3.3.0/kafka_2.12-3.3.0.tgz release/kafka/3.3.0/kafka_2.12-3.3.0.tgz.asc - copied unchanged from r57060, release/kafka/3.3.0/3.3.0/kafka_2.12-3.3.0.tgz.asc release/kafka/3.3.0/kafka_2.12-3.3.0.tgz.md5 - copied unchanged from r57060, release/kafka/3.3.0/3.3.0/kafka_2.12-3.3.0.tgz.md5 release/kafka/3.3.0/kafka_2.12-3.3.0.tgz.sha1 - copied unchanged from r57060, release/kafka/3.3.0/3.3.0/kafka_2.12-3.3.0.tgz.sha1 release/kafka/3.3.0/kafka_2.12-3.3.0.tgz.sha512 - copied unchanged from r57060, release/kafka/3.3.0/3.3.0/kafka_2.12-3.3.0.tgz.sha512 release/kafka/3.3.0/kafka_2.13-3.3.0-site-docs.tgz - copied unchanged from r57060, release/kafka/3.3.0/3.3.0/kafka_2.13-3.3.0-site-docs.tgz release/kafka/3.3.0/kafka_2.13-3.3.0-site-docs.tgz.asc - copied unchanged from r57060, release/kafka/3.3.0/3.3.0/kafka_2.13-3.3.0-site-docs.tgz.asc release/kafka/3.3.0/kafka_2.13-3.3.0-site-docs.tgz.md5 - copied unchanged from r57060, release/kafka/3.3.0/3.3.0/kafka_2.13-3.3.0-site-docs.tgz.md5 release/kafka/3.3.0/kafka_2.13-3.3.0-site-docs.tgz.sha1 - copied unchanged from r57060, release/kafka/3.3.0/3.3.0/kafka_2.13-3.3.0-site-docs.tgz.sha1 release/kafka/3.3.0/kafka_2.13-3.3.0-site-docs.tgz.sha512 - copied unchanged from r57060, release/kafka/3.3.0/3.3.0/kafka_2.13-3.3.0-site-docs.tgz.sha512 release/kafka/3.3.0/kafka_2.13-3.3.0.tgz - copied unchanged from r57060, release/kafka/3.3.0/3.3.0/kafka_2.13-3.3.0.tgz release/kafka/3.3.0/kafka_2.13-3.3.0.tgz.asc - copied unchanged from r57060, release/kafka/3.3.0/3.3.0/kafka_2.13-3.3.0.tgz.asc release/kafka/3.3.0/kafka_2.13-3.3.0.tgz.md5 - copied unchanged from r57060, release/kafka/3.3.0/3.3.0/kafka_2.13-3.3.0.tgz.md5 release/kafka/3.3.0/kafka_2.13-3.3.0.tgz.sha1 - copied unchanged from r57060, release/kafka/3.3.0/3.3.0/kafka_2.13-3.3.0.tgz.sha1 release/kafka/3.3.0/kafka_2.13-3.3.0.tgz.sha512 - copied unchanged from r57060, release/kafka/3.3.0/3.3.0/kafka_2.13-3.3.0.tgz.sha512 Removed: release/kafka/3.3.0/3.3.0/
[kafka-site] branch asf-site updated: MINOR: Fix errant "code" tags (#446)
This is an automated email from the ASF dual-hosted git repository. davidarthur pushed a commit to branch asf-site in repository https://gitbox.apache.org/repos/asf/kafka-site.git The following commit(s) were added to refs/heads/asf-site by this push: new 842c52bf MINOR: Fix errant "code" tags (#446) 842c52bf is described below commit 842c52bf953de680783603feda167084dea67553 Author: David Arthur AuthorDate: Wed Sep 28 18:15:23 2022 -0400 MINOR: Fix errant "code" tags (#446) Reviewers: Bill Bejeck --- 33/ops.html | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/33/ops.html b/33/ops.html index 0b25384e..5a8260e7 100644 --- a/33/ops.html +++ b/33/ops.html @@ -1388,7 +1388,7 @@ $ bin/kafka-acls.sh \ bin/kafka-storage.sh format --cluster-id uuid --config server_properties - It is possible for the bin/kafka-storage.sh format command above to fail with a message like Log directory ... is already formatted. This can happend when combined mode is used and only the metadata log directory was lost but not the others. In that case and only in that case, can you run the kafka-storage.sh format command with the --ignore-formatted option. + It is possible for the bin/kafka-storage.sh format command above to fail with a message like Log directory ... is already formatted. This can happend when combined mode is used and only the metadata log directory was lost but not the others. In that case and only in that case, can you run the kafka-storage.sh format command with the --ignore-formatted option. Start the KRaft controller after formatting the log directories.
[kafka-site] branch 3.3-doc-publish updated (971c1e48 -> c608ca62)
This is an automated email from the ASF dual-hosted git repository. davidarthur pushed a change to branch 3.3-doc-publish in repository https://gitbox.apache.org/repos/asf/kafka-site.git from 971c1e48 update remaining includes add 842c52bf MINOR: Fix errant "code" tags (#446) add c608ca62 Merge remote-tracking branch 'origin/asf-site' into 3.3-doc-publish No new revisions were added by this update. Summary of changes: 33/ops.html | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-)
[kafka-site] branch 3.3-doc-publish updated (27efcb86 -> 971c1e48)
This is an automated email from the ASF dual-hosted git repository. davidarthur pushed a change to branch 3.3-doc-publish in repository https://gitbox.apache.org/repos/asf/kafka-site.git from 27efcb86 Add a few release notes for 3.3.0 add 971c1e48 update remaining includes No new revisions were added by this update. Summary of changes: documentation/index.html | 2 +- documentation/streams/architecture.html| 2 +- documentation/streams/core-concepts.html | 2 +- documentation/streams/developer-guide/app-reset-tool.html | 2 +- documentation/streams/developer-guide/config-streams.html | 2 +- documentation/streams/developer-guide/datatypes.html | 2 +- documentation/streams/developer-guide/dsl-api.html | 2 +- documentation/streams/developer-guide/dsl-topology-naming.html | 2 +- documentation/streams/developer-guide/index.html | 2 +- documentation/streams/developer-guide/interactive-queries.html | 2 +- documentation/streams/developer-guide/manage-topics.html | 2 +- documentation/streams/developer-guide/memory-mgmt.html | 2 +- documentation/streams/developer-guide/processor-api.html | 2 +- documentation/streams/developer-guide/running-app.html | 2 +- documentation/streams/developer-guide/security.html| 2 +- documentation/streams/developer-guide/testing.html | 2 +- documentation/streams/developer-guide/write-streams.html | 2 +- documentation/streams/index.html | 2 +- documentation/streams/quickstart.html | 2 +- documentation/streams/upgrade-guide.html | 2 +- intro.html | 2 +- protocol.html | 2 +- quickstart.html| 2 +- uses.html | 2 +- 24 files changed, 24 insertions(+), 24 deletions(-)
svn commit: r57060 - in /release/kafka/3.3.0: ./ 3.3.0/
Author: cmccabe Date: Wed Sep 28 22:07:20 2022 New Revision: 57060 Log: release 3.3.0 Added: release/kafka/3.3.0/ release/kafka/3.3.0/3.3.0/ release/kafka/3.3.0/3.3.0/RELEASE_NOTES.html release/kafka/3.3.0/3.3.0/kafka-3.3.0-src.tgz (with props) release/kafka/3.3.0/3.3.0/kafka-3.3.0-src.tgz.asc release/kafka/3.3.0/3.3.0/kafka-3.3.0-src.tgz.md5 release/kafka/3.3.0/3.3.0/kafka-3.3.0-src.tgz.sha1 release/kafka/3.3.0/3.3.0/kafka-3.3.0-src.tgz.sha512 release/kafka/3.3.0/3.3.0/kafka_2.12-3.3.0-site-docs.tgz (with props) release/kafka/3.3.0/3.3.0/kafka_2.12-3.3.0-site-docs.tgz.asc release/kafka/3.3.0/3.3.0/kafka_2.12-3.3.0-site-docs.tgz.md5 release/kafka/3.3.0/3.3.0/kafka_2.12-3.3.0-site-docs.tgz.sha1 release/kafka/3.3.0/3.3.0/kafka_2.12-3.3.0-site-docs.tgz.sha512 release/kafka/3.3.0/3.3.0/kafka_2.12-3.3.0.tgz (with props) release/kafka/3.3.0/3.3.0/kafka_2.12-3.3.0.tgz.asc release/kafka/3.3.0/3.3.0/kafka_2.12-3.3.0.tgz.md5 release/kafka/3.3.0/3.3.0/kafka_2.12-3.3.0.tgz.sha1 release/kafka/3.3.0/3.3.0/kafka_2.12-3.3.0.tgz.sha512 release/kafka/3.3.0/3.3.0/kafka_2.13-3.3.0-site-docs.tgz (with props) release/kafka/3.3.0/3.3.0/kafka_2.13-3.3.0-site-docs.tgz.asc release/kafka/3.3.0/3.3.0/kafka_2.13-3.3.0-site-docs.tgz.md5 release/kafka/3.3.0/3.3.0/kafka_2.13-3.3.0-site-docs.tgz.sha1 release/kafka/3.3.0/3.3.0/kafka_2.13-3.3.0-site-docs.tgz.sha512 release/kafka/3.3.0/3.3.0/kafka_2.13-3.3.0.tgz (with props) release/kafka/3.3.0/3.3.0/kafka_2.13-3.3.0.tgz.asc release/kafka/3.3.0/3.3.0/kafka_2.13-3.3.0.tgz.md5 release/kafka/3.3.0/3.3.0/kafka_2.13-3.3.0.tgz.sha1 release/kafka/3.3.0/3.3.0/kafka_2.13-3.3.0.tgz.sha512 Added: release/kafka/3.3.0/3.3.0/RELEASE_NOTES.html == --- release/kafka/3.3.0/3.3.0/RELEASE_NOTES.html (added) +++ release/kafka/3.3.0/3.3.0/RELEASE_NOTES.html Wed Sep 28 22:07:20 2022 @@ -0,0 +1,182 @@ +Release Notes - Kafka - Version 3.3.0 +Below is a summary of the JIRA issues addressed in the 3.3.0 release of Kafka. For full documentation of the +release, a guide to get started, and information about the project, see the https://kafka.apache.org/;>Kafka +project site. + +Note about upgrades: Please carefully review the +https://kafka.apache.org/33/documentation.html#upgrade;>upgrade documentation for this release thoroughly +before upgrading your cluster. The upgrade notes discuss any critical information about incompatibilities and breaking +changes, performance changes, and any other changes that might impact your production deployment of Kafka. + +The documentation for the most recent release can be found at +https://kafka.apache.org/documentation.html;>https://kafka.apache.org/documentation.html. +New Feature + +[https://issues.apache.org/jira/browse/KAFKA-6080;>KAFKA-6080] - Transactional EoS for source connectors +[https://issues.apache.org/jira/browse/KAFKA-1;>KAFKA-1] - Atomic commit of source connector records and offsets +[https://issues.apache.org/jira/browse/KAFKA-13043;>KAFKA-13043] - Add Admin API for batched offset fetch requests (KIP-709) +[https://issues.apache.org/jira/browse/KAFKA-13410;>KAFKA-13410] - KRaft to KRaft Upgrades +[https://issues.apache.org/jira/browse/KAFKA-13873;>KAFKA-13873] - Add ability to Pause / Resume KafkaStreams Topologies +[https://issues.apache.org/jira/browse/KAFKA-13919;>KAFKA-13919] - Add metric for log recovery progress + +Improvement + +[https://issues.apache.org/jira/browse/KAFKA-6204;>KAFKA-6204] - Interceptor and MetricsReporter should implement java.io.Closeable +[https://issues.apache.org/jira/browse/KAFKA-10095;>KAFKA-10095] - In LogCleanerManagerTest replace get().nonEmpty call with contains +[https://issues.apache.org/jira/browse/KAFKA-12875;>KAFKA-12875] - Change Log layer segment map mutations to avoid absence of active segment +[https://issues.apache.org/jira/browse/KAFKA-13217;>KAFKA-13217] - Reconsider skipping the LeaveGroup on close() or add an overload that does so +[https://issues.apache.org/jira/browse/KAFKA-13654;>KAFKA-13654] - Extend KStream process with new Processor API +[https://issues.apache.org/jira/browse/KAFKA-13687;>KAFKA-13687] - Limit number of batches when using kafka-dump-log.sh +[https://issues.apache.org/jira/browse/KAFKA-13752;>KAFKA-13752] - Using `equals` instead of `==` when Uuid compare in Java +[https://issues.apache.org/jira/browse/KAFKA-13763;>KAFKA-13763] - Improve unit testing coverage and flexibility for IncrementalCooperativeAssignor +[https://issues.apache.org/jira/browse/KAFKA-13780;>KAFKA-13780] - Generate docs for Connect REST API +[https://issues.apache.org/jira/browse/KAFKA-13793;>KAFKA-13793] - Add validators for serialization and deserialization related configuration +[https://issues.apache.org/jira/browse/KAFKA-13799;>KAFKA-13799] - Improve
[kafka-site] branch fix-toc-handle-margin updated (e403b3a5 -> 3facc94f)
This is an automated email from the ASF dual-hosted git repository. davidarthur pushed a change to branch fix-toc-handle-margin in repository https://gitbox.apache.org/repos/asf/kafka-site.git from e403b3a5 quick fix for TOC handle add c4749735 Revert "quick fix for TOC handle" add 3facc94f fix missing closing code tags No new revisions were added by this update. Summary of changes: 33/ops.html| 2 +- css/styles.css | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-)
[kafka-site] branch 3.3-doc-publish updated (70aafe9b -> 27efcb86)
This is an automated email from the ASF dual-hosted git repository. davidarthur pushed a change to branch 3.3-doc-publish in repository https://gitbox.apache.org/repos/asf/kafka-site.git from 70aafe9b Update and publish docs for 3.3 add 27efcb86 Add a few release notes for 3.3.0 No new revisions were added by this update. Summary of changes: downloads.html | 8 +++- 1 file changed, 7 insertions(+), 1 deletion(-)
[kafka-site] 01/01: Update and publish docs for 3.3
This is an automated email from the ASF dual-hosted git repository. davidarthur pushed a commit to branch 3.3-doc-publish in repository https://gitbox.apache.org/repos/asf/kafka-site.git commit 70aafe9b4629a4e669b4f58f7c55fdc6e9e8dfdf Author: David Arthur AuthorDate: Wed Sep 28 16:57:00 2022 -0400 Update and publish docs for 3.3 --- 33/design.html| 36 +--- 33/generated/connect_metrics.html | 4 +- 33/ops.html | 119 ++- 33/security.html | 167 ++ documentation.html| 2 +- downloads.html| 51 ++-- 6 files changed, 340 insertions(+), 39 deletions(-) diff --git a/33/design.html b/33/design.html index 6e32b2d7..9485ab9c 100644 --- a/33/design.html +++ b/33/design.html @@ -322,18 +322,33 @@ Followers consume messages from the leader just as a normal Kafka consumer would and apply them to their own log. Having the followers pull from the leader has the nice property of allowing the follower to naturally batch together log entries they are applying to their log. -As with most distributed systems automatically handling failures requires having a precise definition of what it means for a node to be "alive". For Kafka node liveness has two conditions +As with most distributed systems, automatically handling failures requires a precise definition of what it means for a node to be "alive." In Kafka, a special node +known as the "controller" is responsible for managing the registration of brokers in the cluster. Broker liveness has two conditions: -A node must be able to maintain its session with ZooKeeper (via ZooKeeper's heartbeat mechanism) -If it is a follower it must replicate the writes happening on the leader and not fall "too far" behind + Brokers must maintain an active session with the controller in order to receive regular metadata updates. + Brokers acting as followers must replicate the writes from the leader and not fall "too far" behind. -We refer to nodes satisfying these two conditions as being "in sync" to avoid the vagueness of "alive" or "failed". The leader keeps track of the set of "in sync" nodes. If a follower dies, gets stuck, or falls -behind, the leader will remove it from the list of in sync replicas. The determination of stuck and lagging replicas is controlled by the replica.lag.time.max.ms configuration. + +What is meant by an "active session" depends on the cluster configuration. For KRaft clusters, an active session is maintained by +sending periodic heartbeats to the controller. If the controller fails to receive a heartbeat before the timeout configured by +broker.session.timeout.ms expires, then the node is considered offline. + +For clusters using Zookeeper, liveness is determined indirectly through the existence of an ephemeral node which is created by the broker on +initialization of its Zookeeper session. If the broker loses its session after failing to send heartbeats to Zookeeper before expiration of +zookeeper.session.timeout.ms, then the node gets deleted. The controller would then notice the node deletion through a Zookeeper watch +and mark the broker offline. + +We refer to nodes satisfying these two conditions as being "in sync" to avoid the vagueness of "alive" or "failed". The leader keeps track of the set of "in sync" replicas, +which is known as the ISR. If either of these conditions fail to be satisified, then the broker will be removed from the ISR. For example, +if a follower dies, then the controller will notice the failure through the loss of its session, and will remove the broker from the ISR. +On the other hand, if the follower lags too far behind the leader but still has an active session, then the leader can also remove it from the ISR. +The determination of lagging replicas is controlled through the replica.lag.time.max.ms configuration. +Replicas that cannot catch up to the end of the log on the leader within the max time set by this configuration are removed from the ISR. In distributed systems terminology we only attempt to handle a "fail/recover" model of failures where nodes suddenly cease working and then later recover (perhaps without knowing that they have died). Kafka does not handle so-called "Byzantine" failures in which nodes produce arbitrary or malicious responses (perhaps due to bugs or foul play). -We can now more precisely define that a message is considered committed when all in sync replicas for that partition have applied it to their log. +We can now more precisely define that a message is considered committed when all replicas in the ISR for that partition have applied it to their log. Only committed messages are ever given out to the consumer. This
[kafka-site] branch 3.3-doc-publish created (now 70aafe9b)
This is an automated email from the ASF dual-hosted git repository. davidarthur pushed a change to branch 3.3-doc-publish in repository https://gitbox.apache.org/repos/asf/kafka-site.git at 70aafe9b Update and publish docs for 3.3 This branch includes the following new commits: new 70aafe9b Update and publish docs for 3.3 The 1 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference.
svn commit: r57059 - /dev/kafka/3.3.0/RELEASE_NOTES.html
Author: davidarthur Date: Wed Sep 28 20:40:18 2022 New Revision: 57059 Log: Update release notes for 3.3.0 again Modified: dev/kafka/3.3.0/RELEASE_NOTES.html Modified: dev/kafka/3.3.0/RELEASE_NOTES.html == --- dev/kafka/3.3.0/RELEASE_NOTES.html (original) +++ dev/kafka/3.3.0/RELEASE_NOTES.html Wed Sep 28 20:40:18 2022 @@ -39,7 +39,7 @@ [https://issues.apache.org/jira/browse/KAFKA-13846;>KAFKA-13846] - Add an overloaded metricOrElseCreate function in Metrics [https://issues.apache.org/jira/browse/KAFKA-13851;>KAFKA-13851] - Tests are missing for DeleteRecords API [https://issues.apache.org/jira/browse/KAFKA-13883;>KAFKA-13883] - KIP-835: Monitor Quorum -[https://issues.apache.org/jira/browse/KAFKA-13888;>KAFKA-13888] - KIP-836: Addition of Information in DescribeQuorumResponse about Voter Lag +[https://issues.apache.org/jira/browse/KAFKA-13888;>KAFKA-13888] - KIP-836: Expose replication information of the cluster metadata [https://issues.apache.org/jira/browse/KAFKA-13890;>KAFKA-13890] - Improve documentation of ssl.keystore.type and ssl.truststore.type [https://issues.apache.org/jira/browse/KAFKA-13914;>KAFKA-13914] - Implement kafka-metadata-quorum.sh [https://issues.apache.org/jira/browse/KAFKA-13916;>KAFKA-13916] - Fenced replicas should not be allowed to join the ISR in KRaft (KIP-841) @@ -124,6 +124,7 @@ [https://issues.apache.org/jira/browse/KAFKA-14039;>KAFKA-14039] - Fix KRaft AlterConfigPolicy usage [https://issues.apache.org/jira/browse/KAFKA-14044;>KAFKA-14044] - Upgrade Netty and Jackson for CVE fixes [https://issues.apache.org/jira/browse/KAFKA-14055;>KAFKA-14055] - Transaction markers may be lost during cleaning if data keys conflict with marker keys +[https://issues.apache.org/jira/browse/KAFKA-14063;>KAFKA-14063] - CVE-2022-34917: Kafka message parsing can cause ooms with small antagonistic payloads [https://issues.apache.org/jira/browse/KAFKA-14076;>KAFKA-14076] - Fix issues with KafkaStreams.CloseOptions [https://issues.apache.org/jira/browse/KAFKA-14078;>KAFKA-14078] - Replica fetches to follower should return NOT_LEADER error [https://issues.apache.org/jira/browse/KAFKA-14079;>KAFKA-14079] - Source task will not commit offsets and develops memory leak if "error.tolerance" is set to "all" @@ -177,4 +178,5 @@ [https://issues.apache.org/jira/browse/KAFKA-13830;>KAFKA-13830] - Introduce metadata.version in KRaft [https://issues.apache.org/jira/browse/KAFKA-13929;>KAFKA-13929] - Replace File.createNewFile() with Files.createFile() [https://issues.apache.org/jira/browse/KAFKA-14205;>KAFKA-14205] - Document how to recover from kraft controller disk failure +[https://issues.apache.org/jira/browse/KAFKA-14207;>KAFKA-14207] - Add a 6.10 section for KRaft
svn commit: r57057 - in /dev/kafka/3.3.0: RELEASE_NOTES.html RELEASE_NOTES.html.asc RELEASE_NOTES.html.md5 RELEASE_NOTES.html.sha1 RELEASE_NOTES.html.sha512
Author: davidarthur Date: Wed Sep 28 19:45:02 2022 New Revision: 57057 Log: Update RELEASE_NOTES.html for 3.3.0, remove signatures Removed: dev/kafka/3.3.0/RELEASE_NOTES.html.asc dev/kafka/3.3.0/RELEASE_NOTES.html.md5 dev/kafka/3.3.0/RELEASE_NOTES.html.sha1 dev/kafka/3.3.0/RELEASE_NOTES.html.sha512 Modified: dev/kafka/3.3.0/RELEASE_NOTES.html Modified: dev/kafka/3.3.0/RELEASE_NOTES.html == --- dev/kafka/3.3.0/RELEASE_NOTES.html (original) +++ dev/kafka/3.3.0/RELEASE_NOTES.html Wed Sep 28 19:45:02 2022 @@ -15,7 +15,7 @@ [https://issues.apache.org/jira/browse/KAFKA-6080;>KAFKA-6080] - Transactional EoS for source connectors [https://issues.apache.org/jira/browse/KAFKA-1;>KAFKA-1] - Atomic commit of source connector records and offsets [https://issues.apache.org/jira/browse/KAFKA-13043;>KAFKA-13043] - Add Admin API for batched offset fetch requests (KIP-709) -[https://issues.apache.org/jira/browse/KAFKA-13410;>KAFKA-13410] - KRaft Upgrades +[https://issues.apache.org/jira/browse/KAFKA-13410;>KAFKA-13410] - KRaft to KRaft Upgrades [https://issues.apache.org/jira/browse/KAFKA-13873;>KAFKA-13873] - Add ability to Pause / Resume KafkaStreams Topologies [https://issues.apache.org/jira/browse/KAFKA-13919;>KAFKA-13919] - Add metric for log recovery progress
[kafka-site] 01/01: quick fix for TOC handle
This is an automated email from the ASF dual-hosted git repository.
davidarthur pushed a commit to branch fix-toc-handle-margin
in repository https://gitbox.apache.org/repos/asf/kafka-site.git
commit e403b3a5d47a7f97082482d7753cdafc34546fda
Author: David Arthur
AuthorDate: Wed Sep 28 12:15:49 2022 -0400
quick fix for TOC handle
---
css/styles.css | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/css/styles.css b/css/styles.css
index 697ad892..183c9617 100644
--- a/css/styles.css
+++ b/css/styles.css
@@ -1215,7 +1215,7 @@ nav .btn {
}
.content.documentation--current .right {
max-width: 65rem;
-margin: 0 0 0 auto;
+margin: 0 0 0 33rem;
}
.content.documentation--current.expanded .right {
max-width: 85rem;
@@ -2686,4 +2686,4 @@ pre[class*="language-"].line-numbers > code {
display: block;
padding-right: 0.8em;
text-align: right;
-}
\ No newline at end of file
+}
[kafka-site] branch fix-toc-handle-margin created (now e403b3a5)
This is an automated email from the ASF dual-hosted git repository. davidarthur pushed a change to branch fix-toc-handle-margin in repository https://gitbox.apache.org/repos/asf/kafka-site.git at e403b3a5 quick fix for TOC handle This branch includes the following new commits: new e403b3a5 quick fix for TOC handle The 1 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference.
svn commit: r57054 - /dev/kafka/3.3.0/
Author: davidarthur Date: Wed Sep 28 14:36:34 2022 New Revision: 57054 Log: Release 3.3.0 Added: dev/kafka/3.3.0/ dev/kafka/3.3.0/RELEASE_NOTES.html dev/kafka/3.3.0/RELEASE_NOTES.html.asc dev/kafka/3.3.0/RELEASE_NOTES.html.md5 dev/kafka/3.3.0/RELEASE_NOTES.html.sha1 dev/kafka/3.3.0/RELEASE_NOTES.html.sha512 dev/kafka/3.3.0/kafka-3.3.0-src.tgz (with props) dev/kafka/3.3.0/kafka-3.3.0-src.tgz.asc dev/kafka/3.3.0/kafka-3.3.0-src.tgz.md5 dev/kafka/3.3.0/kafka-3.3.0-src.tgz.sha1 dev/kafka/3.3.0/kafka-3.3.0-src.tgz.sha512 dev/kafka/3.3.0/kafka_2.12-3.3.0-site-docs.tgz (with props) dev/kafka/3.3.0/kafka_2.12-3.3.0-site-docs.tgz.asc dev/kafka/3.3.0/kafka_2.12-3.3.0-site-docs.tgz.md5 dev/kafka/3.3.0/kafka_2.12-3.3.0-site-docs.tgz.sha1 dev/kafka/3.3.0/kafka_2.12-3.3.0-site-docs.tgz.sha512 dev/kafka/3.3.0/kafka_2.12-3.3.0.tgz (with props) dev/kafka/3.3.0/kafka_2.12-3.3.0.tgz.asc dev/kafka/3.3.0/kafka_2.12-3.3.0.tgz.md5 dev/kafka/3.3.0/kafka_2.12-3.3.0.tgz.sha1 dev/kafka/3.3.0/kafka_2.12-3.3.0.tgz.sha512 dev/kafka/3.3.0/kafka_2.13-3.3.0-site-docs.tgz (with props) dev/kafka/3.3.0/kafka_2.13-3.3.0-site-docs.tgz.asc dev/kafka/3.3.0/kafka_2.13-3.3.0-site-docs.tgz.md5 dev/kafka/3.3.0/kafka_2.13-3.3.0-site-docs.tgz.sha1 dev/kafka/3.3.0/kafka_2.13-3.3.0-site-docs.tgz.sha512 dev/kafka/3.3.0/kafka_2.13-3.3.0.tgz (with props) dev/kafka/3.3.0/kafka_2.13-3.3.0.tgz.asc dev/kafka/3.3.0/kafka_2.13-3.3.0.tgz.md5 dev/kafka/3.3.0/kafka_2.13-3.3.0.tgz.sha1 dev/kafka/3.3.0/kafka_2.13-3.3.0.tgz.sha512 Added: dev/kafka/3.3.0/RELEASE_NOTES.html == --- dev/kafka/3.3.0/RELEASE_NOTES.html (added) +++ dev/kafka/3.3.0/RELEASE_NOTES.html Wed Sep 28 14:36:34 2022 @@ -0,0 +1,180 @@ +Release Notes - Kafka - Version 3.3.0 +Below is a summary of the JIRA issues addressed in the 3.3.0 release of Kafka. For full documentation of the +release, a guide to get started, and information about the project, see the https://kafka.apache.org/;>Kafka +project site. + +Note about upgrades: Please carefully review the +https://kafka.apache.org/33/documentation.html#upgrade;>upgrade documentation for this release thoroughly +before upgrading your cluster. The upgrade notes discuss any critical information about incompatibilities and breaking +changes, performance changes, and any other changes that might impact your production deployment of Kafka. + +The documentation for the most recent release can be found at +https://kafka.apache.org/documentation.html;>https://kafka.apache.org/documentation.html. +New Feature + +[https://issues.apache.org/jira/browse/KAFKA-6080;>KAFKA-6080] - Transactional EoS for source connectors +[https://issues.apache.org/jira/browse/KAFKA-1;>KAFKA-1] - Atomic commit of source connector records and offsets +[https://issues.apache.org/jira/browse/KAFKA-13043;>KAFKA-13043] - Add Admin API for batched offset fetch requests (KIP-709) +[https://issues.apache.org/jira/browse/KAFKA-13410;>KAFKA-13410] - KRaft Upgrades +[https://issues.apache.org/jira/browse/KAFKA-13873;>KAFKA-13873] - Add ability to Pause / Resume KafkaStreams Topologies +[https://issues.apache.org/jira/browse/KAFKA-13919;>KAFKA-13919] - Add metric for log recovery progress + +Improvement + +[https://issues.apache.org/jira/browse/KAFKA-6204;>KAFKA-6204] - Interceptor and MetricsReporter should implement java.io.Closeable +[https://issues.apache.org/jira/browse/KAFKA-10095;>KAFKA-10095] - In LogCleanerManagerTest replace get().nonEmpty call with contains +[https://issues.apache.org/jira/browse/KAFKA-12875;>KAFKA-12875] - Change Log layer segment map mutations to avoid absence of active segment +[https://issues.apache.org/jira/browse/KAFKA-13217;>KAFKA-13217] - Reconsider skipping the LeaveGroup on close() or add an overload that does so +[https://issues.apache.org/jira/browse/KAFKA-13654;>KAFKA-13654] - Extend KStream process with new Processor API +[https://issues.apache.org/jira/browse/KAFKA-13687;>KAFKA-13687] - Limit number of batches when using kafka-dump-log.sh +[https://issues.apache.org/jira/browse/KAFKA-13752;>KAFKA-13752] - Using `equals` instead of `==` when Uuid compare in Java +[https://issues.apache.org/jira/browse/KAFKA-13763;>KAFKA-13763] - Improve unit testing coverage and flexibility for IncrementalCooperativeAssignor +[https://issues.apache.org/jira/browse/KAFKA-13780;>KAFKA-13780] - Generate docs for Connect REST API +[https://issues.apache.org/jira/browse/KAFKA-13793;>KAFKA-13793] - Add validators for serialization and deserialization related configuration +[https://issues.apache.org/jira/browse/KAFKA-13799;>KAFKA-13799] - Improve documentation for Kafka zero-copy +[https://issues.apache.org/jira/browse/KAFKA-13803;>KAFKA-13803] - Refactor Leader API Access
[kafka] branch 3.3 updated (07a448295f7 -> 4b35f247d15)
This is an automated email from the ASF dual-hosted git repository. davidarthur pushed a change to branch 3.3 in repository https://gitbox.apache.org/repos/asf/kafka.git from 07a448295f7 MINOR: Small update docs/design.html grammar and typo (#12691) add 9d1f9f77642 Bump version to 3.3.0 new da96ac933cf Merge tag '3.3.0-rc2' into 3.3 new 4b35f247d15 Bump 3.3 branch to 3.3.1-SNAPSHOT The 2 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: docs/js/templateData.js | 2 +- gradle.properties| 2 +- kafka-merge-pr.py| 2 +- streams/quickstart/java/pom.xml | 2 +- .../quickstart/java/src/main/resources/archetype-resources/pom.xml | 2 +- streams/quickstart/pom.xml | 2 +- tests/kafkatest/__init__.py | 2 +- tests/kafkatest/version.py | 5 +++-- 8 files changed, 10 insertions(+), 9 deletions(-)
[kafka] 02/02: Bump 3.3 branch to 3.3.1-SNAPSHOT
This is an automated email from the ASF dual-hosted git repository.
davidarthur pushed a commit to branch 3.3
in repository https://gitbox.apache.org/repos/asf/kafka.git
commit 4b35f247d15d97cb9f60818441b1da4371ead04a
Author: David Arthur
AuthorDate: Wed Sep 28 09:56:44 2022 -0400
Bump 3.3 branch to 3.3.1-SNAPSHOT
---
docs/js/templateData.js | 2 +-
gradle.properties| 2 +-
kafka-merge-pr.py| 2 +-
streams/quickstart/java/pom.xml | 2 +-
.../quickstart/java/src/main/resources/archetype-resources/pom.xml | 2 +-
streams/quickstart/pom.xml | 2 +-
tests/kafkatest/__init__.py | 2 +-
tests/kafkatest/version.py | 5 +++--
8 files changed, 10 insertions(+), 9 deletions(-)
diff --git a/docs/js/templateData.js b/docs/js/templateData.js
index 6b773468f96..dd5e02d93a5 100644
--- a/docs/js/templateData.js
+++ b/docs/js/templateData.js
@@ -19,6 +19,6 @@ limitations under the License.
var context={
"version": "33",
"dotVersion": "3.3",
-"fullDotVersion": "3.3.0",
+"fullDotVersion": "3.3.1",
"scalaVersion": "2.13"
};
diff --git a/gradle.properties b/gradle.properties
index c25b54b817e..a56c5959b04 100644
--- a/gradle.properties
+++ b/gradle.properties
@@ -20,7 +20,7 @@ group=org.apache.kafka
# - tests/kafkatest/__init__.py
# - tests/kafkatest/version.py (variable DEV_VERSION)
# - kafka-merge-pr.py
-version=3.3.0
+version=3.3.1-SNAPSHOT
scalaVersion=2.13.8
task=build
org.gradle.jvmargs=-Xmx2g -Xss4m -XX:+UseParallelGC
diff --git a/kafka-merge-pr.py b/kafka-merge-pr.py
index 75a2fc4ba97..9593046b9cd 100755
--- a/kafka-merge-pr.py
+++ b/kafka-merge-pr.py
@@ -70,7 +70,7 @@ TEMP_BRANCH_PREFIX = "PR_TOOL"
DEV_BRANCH_NAME = "trunk"
-DEFAULT_FIX_VERSION = os.environ.get("DEFAULT_FIX_VERSION", "3.3.0")
+DEFAULT_FIX_VERSION = os.environ.get("DEFAULT_FIX_VERSION", "3.3.1")
ORIGINAL_HEAD = ""
diff --git a/streams/quickstart/java/pom.xml b/streams/quickstart/java/pom.xml
index ad707a1f171..c488b85dc46 100644
--- a/streams/quickstart/java/pom.xml
+++ b/streams/quickstart/java/pom.xml
@@ -26,7 +26,7 @@
org.apache.kafka
streams-quickstart
-3.3.0
+3.3.1-SNAPSHOT
..
diff --git
a/streams/quickstart/java/src/main/resources/archetype-resources/pom.xml
b/streams/quickstart/java/src/main/resources/archetype-resources/pom.xml
index 2e8250f9e73..46297302c64 100644
--- a/streams/quickstart/java/src/main/resources/archetype-resources/pom.xml
+++ b/streams/quickstart/java/src/main/resources/archetype-resources/pom.xml
@@ -29,7 +29,7 @@
UTF-8
-3.3.0
+3.3.1-SNAPSHOT
1.7.7
1.2.17
diff --git a/streams/quickstart/pom.xml b/streams/quickstart/pom.xml
index 194ef84ca47..e65f678edf1 100644
--- a/streams/quickstart/pom.xml
+++ b/streams/quickstart/pom.xml
@@ -22,7 +22,7 @@
org.apache.kafka
streams-quickstart
pom
-3.3.0
+3.3.1-SNAPSHOT
Kafka Streams :: Quickstart
diff --git a/tests/kafkatest/__init__.py b/tests/kafkatest/__init__.py
index 9ae8244e082..a769f78f0e9 100644
--- a/tests/kafkatest/__init__.py
+++ b/tests/kafkatest/__init__.py
@@ -22,4 +22,4 @@
# Instead, in development branches, the version should have a suffix of the
form ".devN"
#
# For example, when Kafka is at version 1.0.0-SNAPSHOT, this should be
something like "1.0.0.dev0"
-__version__ = '3.3.0'
+__version__ = '3.3.1.dev0'
diff --git a/tests/kafkatest/version.py b/tests/kafkatest/version.py
index 29f1b4e8418..ada1e76e6c5 100644
--- a/tests/kafkatest/version.py
+++ b/tests/kafkatest/version.py
@@ -119,7 +119,7 @@ def get_version(node=None):
return DEV_BRANCH
DEV_BRANCH = KafkaVersion("dev")
-DEV_VERSION = KafkaVersion("3.3.0-SNAPSHOT")
+DEV_VERSION = KafkaVersion("3.3.1-SNAPSHOT")
LATEST_METADATA_VERSION = "3.3"
@@ -233,4 +233,5 @@ LATEST_3_2 = V_3_2_0
# 3.3.x versions
V_3_3_0 = KafkaVersion("3.3.0")
-LATEST_3_3 = V_3_3_0
+V_3_3_1 = KafkaVersion("3.3.1")
+LATEST_3_3 = V_3_3_1
[kafka] 01/02: Merge tag '3.3.0-rc2' into 3.3
This is an automated email from the ASF dual-hosted git repository. davidarthur pushed a commit to branch 3.3 in repository https://gitbox.apache.org/repos/asf/kafka.git commit da96ac933cf06f5603dbeaf2104fa077ff3c2e80 Merge: 07a448295f7 9d1f9f77642 Author: David Arthur AuthorDate: Wed Sep 28 09:51:55 2022 -0400 Merge tag '3.3.0-rc2' into 3.3 3.3.0-rc2 gradle.properties | 2 +- streams/quickstart/java/pom.xml| 2 +- streams/quickstart/java/src/main/resources/archetype-resources/pom.xml | 2 +- streams/quickstart/pom.xml | 2 +- tests/kafkatest/__init__.py| 2 +- 5 files changed, 5 insertions(+), 5 deletions(-)
[kafka] annotated tag 3.3.0 updated (9d1f9f77642 -> a97acd658b5)
This is an automated email from the ASF dual-hosted git repository. davidarthur pushed a change to annotated tag 3.3.0 in repository https://gitbox.apache.org/repos/asf/kafka.git *** WARNING: tag 3.3.0 was modified! *** from 9d1f9f77642 (commit) to a97acd658b5 (tag) tagging 9d1f9f77642d7e95dec37647657478ed187bdeb7 (commit) replaces 0.8.0-beta1 by David Arthur on Wed Sep 28 09:48:09 2022 -0400 - Log - Apache Kafka 3.3.0 release --- No new revisions were added by this update. Summary of changes:
