You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by GitBox <gi...@apache.org> on 2022/03/21 12:13:06 UTC
[GitHub] [kafka] lkokhreidze opened a new pull request #11923: KAFKA-6718 / Documentation
lkokhreidze opened a new pull request #11923:
URL: https://github.com/apache/kafka/pull/11923
Validated by running kafka-site locally as described in [here](https://cwiki.apache.org/confluence/display/KAFKA/Setup+Kafka+Website+on+Local+Apache+Server).
Screenshots
<img width="1130" alt="Screenshot 2022-03-21 at 14 11 01" src="https://user-images.githubusercontent.com/8927925/159258573-7b908ba7-6954-4587-9dcb-426b338ba5d2.png">
<img width="1066" alt="Screenshot 2022-03-21 at 14 10 56" src="https://user-images.githubusercontent.com/8927925/159258584-5f883f08-8cdb-4801-9770-d05c50e5fad0.png">
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgrade notes)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscribe@kafka.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [kafka] showuon commented on pull request #11923: KAFKA-6718 / Documentation
Posted by GitBox <gi...@apache.org>.
showuon commented on pull request #11923:
URL: https://github.com/apache/kafka/pull/11923#issuecomment-1076362860
cc @cadonna , do you want to have another look?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscribe@kafka.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [kafka] lkokhreidze commented on a change in pull request #11923: KAFKA-6718 / Documentation
Posted by GitBox <gi...@apache.org>.
lkokhreidze commented on a change in pull request #11923:
URL: https://github.com/apache/kafka/pull/11923#discussion_r831038170
##########
File path: clients/src/main/java/org/apache/kafka/common/config/ConfigDef.java
##########
@@ -1140,6 +1140,11 @@ public void ensureValid(final String name, final Object value) {
throw new ConfigException(name, value, "exceeds maximum list size of [" + maxSize + "].");
}
}
+
+ @Override
+ public String toString() {
+ return "List containing maximum of " + maxSize + " elements";
Review comment:
This message is included in configuration's `Valid values` paragraph.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscribe@kafka.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [kafka] cadonna commented on a change in pull request #11923: KAFKA-6718 / Documentation
Posted by GitBox <gi...@apache.org>.
cadonna commented on a change in pull request #11923:
URL: https://github.com/apache/kafka/pull/11923#discussion_r837390343
##########
File path: docs/streams/developer-guide/config-streams.html
##########
@@ -677,6 +685,40 @@ <h4><a class="toc-backref" href="#id33">default.windowed.value.serde.inner</a><a
<p>This is discussed in more detail in <a class="reference internal" href="datatypes.html#streams-developer-guide-serdes"><span class="std std-ref">Data types and serialization</span></a>.</p>
</div></blockquote>
</div>
+ <div class="section" id="rack-aware-assignment-tags">
+ <h4><a class="toc-backref" href="#id34">rack.aware.assignment.tags</a><a class="headerlink" href="#rack-aware-assignment-tags" title="Permalink to this headline"></a>
+ </h4>
+ <blockquote>
+ <div>
+ <p>
+ This configuration sets a list of tag keys used to distribute standby replicas across Kafka Streams
+ clients. When configured, Kafka Streams will make a best-effort to distribute the standby tasks over
+ clients with different tag values.
+ </p>
+ <p>
+ Tags for the Kafka Streams instances can be set via <code class="docutils literal"><span class="pre">client.tag.</span></code>
Review comment:
```suggestion
Tags for the Kafka Streams clients can be set via <code class="docutils literal"><span class="pre">client.tag.</span></code>
```
##########
File path: docs/streams/developer-guide/config-streams.html
##########
@@ -383,6 +384,13 @@ <h4><a class="toc-backref" href="#id23">num.standby.replicas</a><a class="header
<td colspan="2">The amount of time in milliseconds to block waiting for input.</td>
<td>100 milliseconds</td>
</tr>
+ <tr class="row-even"><td>rack.aware.assignment.tags</td>
+ <td>Medium</td>
+ <td colspan="2">List of tag keys used to distribute standby replicas across Kafka Streams
+ clients. When configured, Kafka Streams will make a best-effort to distribute the standby tasks over
+ client with different tag values.</td>
Review comment:
```suggestion
clients with different tag values.</td>
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscribe@kafka.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [kafka] lkokhreidze commented on pull request #11923: KAFKA-6718 / Documentation
Posted by GitBox <gi...@apache.org>.
lkokhreidze commented on pull request #11923:
URL: https://github.com/apache/kafka/pull/11923#issuecomment-1073821545
Call for review @cadonna @showuon
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscribe@kafka.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [kafka] lkokhreidze commented on a change in pull request #11923: KAFKA-6718 / Documentation
Posted by GitBox <gi...@apache.org>.
lkokhreidze commented on a change in pull request #11923:
URL: https://github.com/apache/kafka/pull/11923#discussion_r831038617
##########
File path: clients/src/main/java/org/apache/kafka/common/config/ConfigDef.java
##########
@@ -33,8 +31,10 @@
import java.util.Map;
import java.util.Set;
import java.util.function.BiConsumer;
+import java.util.function.Function;
import java.util.function.Supplier;
import java.util.regex.Pattern;
+import java.util.stream.Collectors;
Review comment:
Sorry about this. Accidentally formatted with idea :(
##########
File path: clients/src/main/java/org/apache/kafka/common/config/ConfigDef.java
##########
@@ -33,8 +31,10 @@
import java.util.Map;
import java.util.Set;
import java.util.function.BiConsumer;
+import java.util.function.Function;
import java.util.function.Supplier;
import java.util.regex.Pattern;
+import java.util.stream.Collectors;
Review comment:
Sorry about this. Accidentally formatted imports :(
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscribe@kafka.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [kafka] showuon commented on a change in pull request #11923: KAFKA-6718 / Documentation
Posted by GitBox <gi...@apache.org>.
showuon commented on a change in pull request #11923:
URL: https://github.com/apache/kafka/pull/11923#discussion_r831722091
##########
File path: docs/streams/architecture.html
##########
@@ -161,6 +161,12 @@ <h3 class="anchor-heading"><a id="streams_architecture_recovery" class="anchor-l
Starting in 2.6, Kafka Streams will guarantee that a task is only ever assigned to an instance with a fully caught-up local copy of the state, if such an instance
exists. Standby tasks will increase the likelihood that a caught-up instance exists in the case of a failure.
</p>
+ <p>
+ You can also configure standby replicas with rack awareness. When configured, Kafka Streams will attempt to
+ create a standby task on a different "rack" than the active one, thus having a faster recovery time when the
Review comment:
nit: Kafka Streams will attempt to [distribute] a standby task on a different "rack" than the active one,
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscribe@kafka.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [kafka] lkokhreidze commented on a change in pull request #11923: KAFKA-6718 / Documentation
Posted by GitBox <gi...@apache.org>.
lkokhreidze commented on a change in pull request #11923:
URL: https://github.com/apache/kafka/pull/11923#discussion_r836386016
##########
File path: docs/streams/developer-guide/config-streams.html
##########
@@ -677,6 +685,30 @@ <h4><a class="toc-backref" href="#id33">default.windowed.value.serde.inner</a><a
<p>This is discussed in more detail in <a class="reference internal" href="datatypes.html#streams-developer-guide-serdes"><span class="std std-ref">Data types and serialization</span></a>.</p>
</div></blockquote>
</div>
+ <div class="section" id="rack-aware-assignment-tags">
+ <h4><a class="toc-backref" href="#id34">rack.aware.assignment.tags</a><a class="headerlink" href="#rack-aware-assignment-tags" title="Permalink to this headline"></a>
+ </h4>
+ <blockquote>
+ <div>
+ <p>
+ This configuration sets list of tag keys used to distribute standby replicas across Kafka Streams
+ instances. When configured, Kafka Streams will make a best-effort to distribute the standby tasks over
+ each client tag dimension.
+ </p>
+ <p>
+ Tags for the Kafka Streams instances can be set via <code class="docutils literal"><span class="pre">client.tag.</span></code>
+ prefix. Example:
+ </p>
Review comment:
Done
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscribe@kafka.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [kafka] lkokhreidze commented on a change in pull request #11923: KAFKA-6718 / Documentation
Posted by GitBox <gi...@apache.org>.
lkokhreidze commented on a change in pull request #11923:
URL: https://github.com/apache/kafka/pull/11923#discussion_r831823225
##########
File path: docs/streams/architecture.html
##########
@@ -161,6 +161,12 @@ <h3 class="anchor-heading"><a id="streams_architecture_recovery" class="anchor-l
Starting in 2.6, Kafka Streams will guarantee that a task is only ever assigned to an instance with a fully caught-up local copy of the state, if such an instance
exists. Standby tasks will increase the likelihood that a caught-up instance exists in the case of a failure.
</p>
+ <p>
+ You can also configure standby replicas with rack awareness. When configured, Kafka Streams will attempt to
+ create a standby task on a different "rack" than the active one, thus having a faster recovery time when the
Review comment:
Done
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscribe@kafka.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [kafka] lkokhreidze commented on pull request #11923: KAFKA-6718 / Documentation
Posted by GitBox <gi...@apache.org>.
lkokhreidze commented on pull request #11923:
URL: https://github.com/apache/kafka/pull/11923#issuecomment-1077305642
FYI, I'll cherry-pick this to 3.2 branch once it's merged.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscribe@kafka.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [kafka] cadonna commented on a change in pull request #11923: KAFKA-6718 / Documentation
Posted by GitBox <gi...@apache.org>.
cadonna commented on a change in pull request #11923:
URL: https://github.com/apache/kafka/pull/11923#discussion_r835303600
##########
File path: docs/streams/developer-guide/config-streams.html
##########
@@ -677,6 +685,30 @@ <h4><a class="toc-backref" href="#id33">default.windowed.value.serde.inner</a><a
<p>This is discussed in more detail in <a class="reference internal" href="datatypes.html#streams-developer-guide-serdes"><span class="std std-ref">Data types and serialization</span></a>.</p>
</div></blockquote>
</div>
+ <div class="section" id="rack-aware-assignment-tags">
+ <h4><a class="toc-backref" href="#id34">rack.aware.assignment.tags</a><a class="headerlink" href="#rack-aware-assignment-tags" title="Permalink to this headline"></a>
+ </h4>
+ <blockquote>
+ <div>
+ <p>
+ This configuration sets list of tag keys used to distribute standby replicas across Kafka Streams
+ instances. When configured, Kafka Streams will make a best-effort to distribute the standby tasks over
+ each client tag dimension.
+ </p>
+ <p>
+ Tags for the Kafka Streams instances can be set via <code class="docutils literal"><span class="pre">client.tag.</span></code>
+ prefix. Example:
+ </p>
Review comment:
I think the doc would benefit from a more complete example. could you try to put the example from the KIP in a concise way here?
```
# Kafka Streams Client 1
client.tag.zone: eu-central-1a
client.tag.cluster: k8s-cluster1
rack.aware.assignment.tags: zone,cluster
# Kafka Streams Client 2
client.tag.zone: eu-central-1b
client.tag.cluster: k8s-cluster1
rack.aware.assignment.tags: zone,cluster
# Kafka Streams Client 3
client.tag.zone: eu-central-1a
client.tag.cluster: k8s-cluster2
rack.aware.assignment.tags: zone,cluster
# Kafka Streams Client 4
client.tag.zone: eu-central-1b
client.tag.cluster: k8s-cluster2
rack.aware.assignment.tags: zone,cluster
```
Maybe it is possible to put the clients next to each other or two client in one row and the other two client below. Below the clients you could describe who get which standbys for the active tasks on each client.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscribe@kafka.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [kafka] lkokhreidze commented on pull request #11923: KAFKA-6718 / Documentation
Posted by GitBox <gi...@apache.org>.
lkokhreidze commented on pull request #11923:
URL: https://github.com/apache/kafka/pull/11923#issuecomment-1081787376
Thanks @cadonna, all done.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscribe@kafka.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [kafka] lkokhreidze commented on pull request #11923: KAFKA-6718 / Documentation
Posted by GitBox <gi...@apache.org>.
lkokhreidze commented on pull request #11923:
URL: https://github.com/apache/kafka/pull/11923#issuecomment-1081781203
Thanks @cadonna
I've accepted your suggestions.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscribe@kafka.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [kafka] cadonna commented on a change in pull request #11923: KAFKA-6718 / Documentation
Posted by GitBox <gi...@apache.org>.
cadonna commented on a change in pull request #11923:
URL: https://github.com/apache/kafka/pull/11923#discussion_r837379281
##########
File path: docs/streams/developer-guide/config-streams.html
##########
@@ -383,6 +384,13 @@ <h4><a class="toc-backref" href="#id23">num.standby.replicas</a><a class="header
<td colspan="2">The amount of time in milliseconds to block waiting for input.</td>
<td>100 milliseconds</td>
</tr>
+ <tr class="row-even"><td>rack.aware.assignment.tags</td>
+ <td>Medium</td>
+ <td colspan="2">List of tag keys used to distribute standby replicas across Kafka Streams
+ instances. When configured, Kafka Streams will make a best-effort to distribute the standby tasks over
+ each client tag dimension.</td>
Review comment:
```suggestion
<td colspan="2">List of tag keys used to distribute standby replicas across Kafka Streams
clients. When configured, Kafka Streams will make a best-effort to distribute the standby tasks over
client with different tag values.</td>
```
##########
File path: docs/streams/developer-guide/config-streams.html
##########
@@ -677,6 +685,40 @@ <h4><a class="toc-backref" href="#id33">default.windowed.value.serde.inner</a><a
<p>This is discussed in more detail in <a class="reference internal" href="datatypes.html#streams-developer-guide-serdes"><span class="std std-ref">Data types and serialization</span></a>.</p>
</div></blockquote>
</div>
+ <div class="section" id="rack-aware-assignment-tags">
+ <h4><a class="toc-backref" href="#id34">rack.aware.assignment.tags</a><a class="headerlink" href="#rack-aware-assignment-tags" title="Permalink to this headline"></a>
+ </h4>
+ <blockquote>
+ <div>
+ <p>
+ This configuration sets list of tag keys used to distribute standby replicas across Kafka Streams
+ instances. When configured, Kafka Streams will make a best-effort to distribute the standby tasks over
+ each client tag dimension.
+ </p>
+ <p>
+ Tags for the Kafka Streams instances can be set via <code class="docutils literal"><span class="pre">client.tag.</span></code>
+ prefix. Example:
+ </p>
+ <pre><code class="language-text">
+Client-1 | Client-2
+_______________________________________________________________________
+client.tag.zone: eu-central-1a | client.tag.zone: eu-central-1b
+client.tag.cluster: k8s-cluster1 | client.tag.cluster: k8s-cluster1
+rack.aware.assignment.tags: zone,cluster | rack.aware.assignment.tags: zone,cluster
+
+
+Client-3 | Client-4
+_______________________________________________________________________
+client.tag.zone: eu-central-1a | client.tag.zone: eu-central-1b
+client.tag.cluster: k8s-cluster2 | client.tag.cluster: k8s-cluster2
+rack.aware.assignment.tags: zone,cluster | rack.aware.assignment.tags: zone,cluster</code></pre>
+ <p>
+ In the above example, we have four clients spanned across two zones (<code class="docutils literal"><span class="pre">eu-central-1a</span></code>, <code class="docutils literal"><span class="pre">eu-central-1b</span></code>) and two clusters (<code class="docutils literal"><span class="pre">k8s-cluster1</span></code>, <code class="docutils literal"><span class="pre">k8s-cluster2</span></code>).
+ Assuming we have to create a standby task for an active task located on <code class="docutils literal"><span class="pre">Client-1</span></code>, Kafka Streams will allocate a standby task on <code class="docutils literal"><span class="pre">Client-4</span></code>, which has different <code class="docutils literal"><span class="pre">zone</span></code> and <code class="docutils literal"><span class="pre">cluster</span></code> tag values compared to the active task.
Review comment:
```suggestion
In the above example, we have four Kafka Streams clients across two zones (<code class="docutils literal"><span class="pre">eu-central-1a</span></code>, <code class="docutils literal"><span class="pre">eu-central-1b</span></code>) and across two clusters (<code class="docutils literal"><span class="pre">k8s-cluster1</span></code>, <code class="docutils literal"><span class="pre">k8s-cluster2</span></code>).
For an active task located on <code class="docutils literal"><span class="pre">Client-1</span></code>, Kafka Streams will allocate a standby task on <code class="docutils literal"><span class="pre">Client-4</span></code>, since <code class="docutils literal"><span class="pre">Client-4</span></code> has a different <code class="docutils literal"><span class="pre">zone</span></code> and a different <code class="docutils literal"><span class="pre">cluster</span></code> than <code class="docutils literal"><span class="pre">Client-1</span></code>.
```
##########
File path: docs/streams/developer-guide/config-streams.html
##########
@@ -677,6 +685,40 @@ <h4><a class="toc-backref" href="#id33">default.windowed.value.serde.inner</a><a
<p>This is discussed in more detail in <a class="reference internal" href="datatypes.html#streams-developer-guide-serdes"><span class="std std-ref">Data types and serialization</span></a>.</p>
</div></blockquote>
</div>
+ <div class="section" id="rack-aware-assignment-tags">
+ <h4><a class="toc-backref" href="#id34">rack.aware.assignment.tags</a><a class="headerlink" href="#rack-aware-assignment-tags" title="Permalink to this headline"></a>
+ </h4>
+ <blockquote>
+ <div>
+ <p>
+ This configuration sets list of tag keys used to distribute standby replicas across Kafka Streams
+ instances. When configured, Kafka Streams will make a best-effort to distribute the standby tasks over
+ each client tag dimension.
Review comment:
```suggestion
This configuration sets a list of tag keys used to distribute standby replicas across Kafka Streams
clients. When configured, Kafka Streams will make a best-effort to distribute the standby tasks over
clients with different tag values.
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscribe@kafka.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [kafka] cadonna merged pull request #11923: KAFKA-6718 / Documentation
Posted by GitBox <gi...@apache.org>.
cadonna merged pull request #11923:
URL: https://github.com/apache/kafka/pull/11923
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscribe@kafka.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [kafka] cadonna commented on pull request #11923: KAFKA-6718 / Documentation
Posted by GitBox <gi...@apache.org>.
cadonna commented on pull request #11923:
URL: https://github.com/apache/kafka/pull/11923#issuecomment-1081792480
Cherry-picked to 3.2
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscribe@kafka.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [kafka] lkokhreidze commented on pull request #11923: KAFKA-6718 / Documentation
Posted by GitBox <gi...@apache.org>.
lkokhreidze commented on pull request #11923:
URL: https://github.com/apache/kafka/pull/11923#issuecomment-1074801863
Thanks @showuon
I've addressed your comments.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscribe@kafka.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [kafka] lkokhreidze commented on a change in pull request #11923: KAFKA-6718 / Documentation
Posted by GitBox <gi...@apache.org>.
lkokhreidze commented on a change in pull request #11923:
URL: https://github.com/apache/kafka/pull/11923#discussion_r836386016
##########
File path: docs/streams/developer-guide/config-streams.html
##########
@@ -677,6 +685,30 @@ <h4><a class="toc-backref" href="#id33">default.windowed.value.serde.inner</a><a
<p>This is discussed in more detail in <a class="reference internal" href="datatypes.html#streams-developer-guide-serdes"><span class="std std-ref">Data types and serialization</span></a>.</p>
</div></blockquote>
</div>
+ <div class="section" id="rack-aware-assignment-tags">
+ <h4><a class="toc-backref" href="#id34">rack.aware.assignment.tags</a><a class="headerlink" href="#rack-aware-assignment-tags" title="Permalink to this headline"></a>
+ </h4>
+ <blockquote>
+ <div>
+ <p>
+ This configuration sets list of tag keys used to distribute standby replicas across Kafka Streams
+ instances. When configured, Kafka Streams will make a best-effort to distribute the standby tasks over
+ each client tag dimension.
+ </p>
+ <p>
+ Tags for the Kafka Streams instances can be set via <code class="docutils literal"><span class="pre">client.tag.</span></code>
+ prefix. Example:
+ </p>
Review comment:
Done
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscribe@kafka.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org