dengziming created KAFKA-13042:
--
Summary: Flaky test KafkaMetadataLogTest.testDeleteSnapshots()
Key: KAFKA-13042
URL: https://issues.apache.org/jira/browse/KAFKA-13042
Project: Kafka
Issue Type:
skaundinya15 commented on a change in pull request #10973:
URL: https://github.com/apache/kafka/pull/10973#discussion_r665108901
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/internals/AlterConsumerGroupOffsetsHandler.java
##
@@ -141,9 +147,16 @@ private v
[
https://issues.apache.org/jira/browse/KAFKA-13029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rajini Sivaram resolved KAFKA-13029.
Resolution: Fixed
> FindCoordinators batching can break consumers during rolling upgrade
>
showuon commented on a change in pull request #10973:
URL: https://github.com/apache/kafka/pull/10973#discussion_r665173709
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/internals/AlterConsumerGroupOffsetsHandler.java
##
@@ -141,9 +147,16 @@ private void h
showuon commented on a change in pull request #10973:
URL: https://github.com/apache/kafka/pull/10973#discussion_r665176116
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/internals/AlterConsumerGroupOffsetsHandler.java
##
@@ -141,9 +147,16 @@ private void h
[
https://issues.apache.org/jira/browse/KAFKA-13000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison resolved KAFKA-13000.
Fix Version/s: 3.0.0
Assignee: (was: Kirk True)
Resolution: Fixed
> Im
[
https://issues.apache.org/jira/browse/KAFKA-13000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17376414#comment-17376414
]
Mickael Maison commented on KAFKA-13000:
[~kirktrue] Sorry it looks like this ha
showuon opened a new pull request #10987:
URL: https://github.com/apache/kafka/pull/10987
Before the PR, the `partitioner.class` config doesn't describe what the
config is use for, and what options user can choose.
Key: KAFKA-13043
URL: https://issues.apache.org/jira/browse/KAFKA-13043
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-10675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Iskuskov updated KAFKA-10675:
---
Fix Version/s: 3.0.0
> Error message from ConnectSchema.validateValue() should inclu
[
https://issues.apache.org/jira/browse/KAFKA-10675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Iskuskov updated KAFKA-10675:
---
Fix Version/s: 2.8.1
> Error message from ConnectSchema.validateValue() should inclu
[
https://issues.apache.org/jira/browse/KAFKA-10675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Iskuskov updated KAFKA-10675:
---
Reviewer: Randall Hauch
> Error message from ConnectSchema.validateValue() should in
rajinisivaram commented on a change in pull request #10978:
URL: https://github.com/apache/kafka/pull/10978#discussion_r665288314
##
File path:
clients/src/main/java/org/apache/kafka/common/security/plain/internals/PlainServerCallbackHandler.java
##
@@ -65,7 +65,7 @@ protected
mimaison commented on a change in pull request #10978:
URL: https://github.com/apache/kafka/pull/10978#discussion_r665293815
##
File path: clients/src/main/java/org/apache/kafka/common/utils/Utils.java
##
@@ -331,6 +331,41 @@ public static ByteBuffer wrapNullable(byte[] array)
satishd commented on a change in pull request #10579:
URL: https://github.com/apache/kafka/pull/10579#discussion_r665299398
##
File path:
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/TopicBasedRemoteLogMetadataManagerConfig.java
##
@@ -0,0 +1,197 @
rajinisivaram commented on a change in pull request #10978:
URL: https://github.com/apache/kafka/pull/10978#discussion_r665302911
##
File path: clients/src/main/java/org/apache/kafka/common/utils/Utils.java
##
@@ -331,6 +331,41 @@ public static ByteBuffer wrapNullable(byte[] ar
showuon commented on a change in pull request #10985:
URL: https://github.com/apache/kafka/pull/10985#discussion_r665314091
##
File path:
clients/src/test/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignorTest.java
##
@@ -555,7 +558,7 @@ public void
testL
mimaison commented on a change in pull request #10978:
URL: https://github.com/apache/kafka/pull/10978#discussion_r665322579
##
File path: clients/src/main/java/org/apache/kafka/common/utils/Utils.java
##
@@ -331,6 +331,41 @@ public static ByteBuffer wrapNullable(byte[] array)
mimaison commented on a change in pull request #10978:
URL: https://github.com/apache/kafka/pull/10978#discussion_r665292916
##
File path: clients/src/main/java/org/apache/kafka/common/utils/Utils.java
##
@@ -331,6 +331,41 @@ public static ByteBuffer wrapNullable(byte[] array)
chia7712 commented on a change in pull request #10943:
URL: https://github.com/apache/kafka/pull/10943#discussion_r665323302
##
File path: tests/kafkatest/tests/streams/streams_upgrade_test.py
##
@@ -474,8 +474,9 @@ def do_rolling_bounce(self, processor, counter,
current_gener
showuon commented on a change in pull request #10985:
URL: https://github.com/apache/kafka/pull/10985#discussion_r665328864
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java
##
@@ -122,6 +131,13 @@ private boolean allSu
lct45 opened a new pull request #10988:
URL: https://github.com/apache/kafka/pull/10988
https://github.com/apache/kafka/pull/10813 changed the default serde from
ByteArraySerde as discussed in
[KIP-741](https://cwiki.apache.org/confluence/display/KAFKA/KIP-741%3A+Change+default+serde+to+be
lct45 commented on pull request #10988:
URL: https://github.com/apache/kafka/pull/10988#issuecomment-875584527
cc @ableegoldman @mjsax @wcarlson5 for review
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abov
ijuma commented on a change in pull request #10978:
URL: https://github.com/apache/kafka/pull/10978#discussion_r665362085
##
File path:
clients/src/main/java/org/apache/kafka/common/security/plain/internals/PlainServerCallbackHandler.java
##
@@ -65,7 +65,7 @@ protected boolean
Nanda Kishore M S created KAFKA-13044:
-
Summary: __consumer_offsets corruption
Key: KAFKA-13044
URL: https://issues.apache.org/jira/browse/KAFKA-13044
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-13044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nanda Kishore M S updated KAFKA-13044:
--
Description:
We had an issue where clients are not able to discover a group coordinato
[
https://issues.apache.org/jira/browse/KAFKA-13044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nanda Kishore M S updated KAFKA-13044:
--
Description:
We had an issue where clients are not able to discover a group coordinato
[
https://issues.apache.org/jira/browse/KAFKA-13044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nanda Kishore M S updated KAFKA-13044:
--
Description:
We had an issue where clients are not able to discover a group coordinato
[
https://issues.apache.org/jira/browse/KAFKA-13044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nanda Kishore M S updated KAFKA-13044:
--
Description:
We had an issue where clients are not able to discover a group coordinato
[
https://issues.apache.org/jira/browse/KAFKA-13044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nanda Kishore M S updated KAFKA-13044:
--
Environment:
Amazon Linux
Kafka Server: 2.5.0, scala version - 2.12
Cluster of 6 EC2 N
[
https://issues.apache.org/jira/browse/KAFKA-13044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nanda Kishore M S updated KAFKA-13044:
--
Description:
We had an issue where clients are not able to discover a group coordinato
[
https://issues.apache.org/jira/browse/KAFKA-13044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nanda Kishore M S updated KAFKA-13044:
--
Description:
We had an issue where clients are not able to discover a group coordinato
[
https://issues.apache.org/jira/browse/KAFKA-13044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nanda Kishore M S updated KAFKA-13044:
--
Description:
We had an issue where clients are not able to discover a group coordinato
[
https://issues.apache.org/jira/browse/KAFKA-13044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nanda Kishore M S updated KAFKA-13044:
--
Description:
We had an issue where clients are not able to discover a group coordinato
[
https://issues.apache.org/jira/browse/KAFKA-13044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nanda Kishore M S updated KAFKA-13044:
--
Description:
We had an issue where clients are not able to discover a group coordinato
showuon commented on a change in pull request #10985:
URL: https://github.com/apache/kafka/pull/10985#discussion_r665386121
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java
##
@@ -130,19 +146,26 @@ private boolean allS
rajinisivaram commented on a change in pull request #10978:
URL: https://github.com/apache/kafka/pull/10978#discussion_r665403838
##
File path:
clients/src/main/java/org/apache/kafka/common/security/plain/internals/PlainServerCallbackHandler.java
##
@@ -65,7 +65,7 @@ protected
jacky1193610322 commented on a change in pull request #10985:
URL: https://github.com/apache/kafka/pull/10985#discussion_r665433621
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/CooperativeStickyAssignor.java
##
@@ -53,9 +56,34 @@ public String name() {
tombentley commented on pull request #8259:
URL: https://github.com/apache/kafka/pull/8259#issuecomment-875682628
@rhauch @kkonstantine Any chance we could get this into 3.0?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub an
satishd commented on a change in pull request #10579:
URL: https://github.com/apache/kafka/pull/10579#discussion_r665259927
##
File path:
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/TopicBasedRemoteLogMetadataManager.java
##
@@ -0,0 +1,432 @@
+/*
[
https://issues.apache.org/jira/browse/KAFKA-12992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17376635#comment-17376635
]
David Arthur commented on KAFKA-12992:
--
Some additional properties were added as pa
jolshan commented on a change in pull request #9769:
URL: https://github.com/apache/kafka/pull/9769#discussion_r665476219
##
File path: clients/src/main/java/org/apache/kafka/clients/admin/Admin.java
##
@@ -303,7 +303,33 @@ default DescribeTopicsResult
describeTopics(Collectio
jolshan commented on a change in pull request #9769:
URL: https://github.com/apache/kafka/pull/9769#discussion_r665479977
##
File path:
core/src/test/scala/integration/kafka/server/MetadataRequestBetweenDifferentIbpTest.scala
##
@@ -0,0 +1,103 @@
+/**
+ * Licensed to the Apac
wcarlson5 commented on a change in pull request #10988:
URL: https://github.com/apache/kafka/pull/10988#discussion_r665519455
##
File path: docs/streams/developer-guide/config-streams.html
##
@@ -211,8 +211,9 @@ bootstrap.serversdefault.key.serde
Medium
-
C0urante commented on a change in pull request #10907:
URL: https://github.com/apache/kafka/pull/10907#discussion_r665526680
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/util/KafkaBasedLog.java
##
@@ -337,15 +353,29 @@ private void readToLogEnd() {
tombentley commented on pull request #8571:
URL: https://github.com/apache/kafka/pull/8571#issuecomment-875745475
CI failures are unrelated.
--
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
tombentley merged pull request #8571:
URL: https://github.com/apache/kafka/pull/8571
--
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-unsubscr
tombentley commented on pull request #8571:
URL: https://github.com/apache/kafka/pull/8571#issuecomment-875746579
Cherry-picked to 3.0
--
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 specifi
satishd commented on a change in pull request #10579:
URL: https://github.com/apache/kafka/pull/10579#discussion_r665531236
##
File path:
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/TopicBasedRemoteLogMetadataManager.java
##
@@ -0,0 +1,432 @@
+/*
satishd commented on pull request #10579:
URL: https://github.com/apache/kafka/pull/10579#issuecomment-875750234
Thanks @junrao for the comments. Pl take a look at my inline replies and the
latest commit.
--
This is an automated message from the Apache Git Service.
To respond to the mes
lct45 commented on a change in pull request #10988:
URL: https://github.com/apache/kafka/pull/10988#discussion_r665531990
##
File path: docs/streams/developer-guide/config-streams.html
##
@@ -211,8 +211,9 @@ bootstrap.serversdefault.key.serde
Medium
-De
kamalcph commented on a change in pull request #10579:
URL: https://github.com/apache/kafka/pull/10579#discussion_r665544995
##
File path:
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/ProducerManager.java
##
@@ -0,0 +1,120 @@
+/*
+ * Licensed to th
vlsi commented on a change in pull request #10851:
URL: https://github.com/apache/kafka/pull/10851#discussion_r665553313
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ClientState.java
##
@@ -64,6 +66,7 @@ public ClientState() {
satishd commented on a change in pull request #10579:
URL: https://github.com/apache/kafka/pull/10579#discussion_r66878
##
File path:
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/ProducerManager.java
##
@@ -0,0 +1,120 @@
+/*
+ * Licensed to the
satishd commented on a change in pull request #10579:
URL: https://github.com/apache/kafka/pull/10579#discussion_r66878
##
File path:
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/ProducerManager.java
##
@@ -0,0 +1,120 @@
+/*
+ * Licensed to the
vlsi commented on a change in pull request #10851:
URL: https://github.com/apache/kafka/pull/10851#discussion_r665561377
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/StandbyTaskAssignor.java
##
@@ -0,0 +1,39 @@
+/*
+ * Licensed to
cmccabe commented on pull request #10989:
URL: https://github.com/apache/kafka/pull/10989#issuecomment-875787445
For Replicas, that is actually what it is supposed to do.
I agree that removingReplicas and addingReplicas should not be stored as
null. Can you make a separate PR for tha
cmccabe opened a new pull request #10990:
URL: https://github.com/apache/kafka/pull/10990
The broker should trigger a snapshot once
metadata.log.max.record.bytes.between.snapshots has been exceeded.
--
This is an automated message from the Apache Git Service.
To respond to the message,
hachikuji commented on a change in pull request #10952:
URL: https://github.com/apache/kafka/pull/10952#discussion_r665599081
##
File path: clients/src/main/java/org/apache/kafka/clients/Metadata.java
##
@@ -316,8 +325,16 @@ private MetadataCache
handleMetadataResponse(Metadat
kkonstantine commented on pull request #8259:
URL: https://github.com/apache/kafka/pull/8259#issuecomment-875841425
@tombentley this is a bugfix and we are still on track to include it for 3.0
and other release branches.
I've finished some analysis and I'll add the summary to the review
hachikuji commented on a change in pull request #10560:
URL: https://github.com/apache/kafka/pull/10560#discussion_r665623998
##
File path:
core/src/test/scala/unit/kafka/coordinator/group/GroupMetadataManagerTest.scala
##
@@ -1349,6 +1357,10 @@ class GroupMetadataManagerTest
rondagostino opened a new pull request #10991:
URL: https://github.com/apache/kafka/pull/10991
This patch adds a sanity-check bounce system test for the case where we have
3 co-located KRaft controllers and fixes the system test code so that this case
will pass. We were not testing this c
mumrah merged pull request #10989:
URL: https://github.com/apache/kafka/pull/10989
--
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-unsubscr..
mumrah opened a new pull request #10992:
URL: https://github.com/apache/kafka/pull/10992
This change was discussed in KIP-746 and are actually included in #10753.
I'm pulling them out here since there are NPEs on trunk as a result of the
nullable fields in the PartitionRecord.
--
This
jgray1206 opened a new pull request #10993:
URL: https://github.com/apache/kafka/pull/10993
--
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-u
jolshan commented on a change in pull request #10952:
URL: https://github.com/apache/kafka/pull/10952#discussion_r665649142
##
File path: clients/src/main/java/org/apache/kafka/clients/MetadataCache.java
##
@@ -130,13 +150,30 @@ MetadataCache mergeWith(String newClusterId,
jolshan commented on a change in pull request #10952:
URL: https://github.com/apache/kafka/pull/10952#discussion_r665652021
##
File path: clients/src/main/java/org/apache/kafka/clients/MetadataCache.java
##
@@ -93,6 +104,14 @@ private MetadataCache(String clusterId,
re
jolshan commented on a change in pull request #10952:
URL: https://github.com/apache/kafka/pull/10952#discussion_r665654598
##
File path: clients/src/main/java/org/apache/kafka/clients/MetadataCache.java
##
@@ -93,6 +104,14 @@ private MetadataCache(String clusterId,
re
cmccabe commented on pull request #10992:
URL: https://github.com/apache/kafka/pull/10992#issuecomment-875898150
Thanks, @mumrah !
Can you use `Replicas.EMPTY` instead of `new int[0]`? It saves an allocation.
LGTM after that
--
This is an automated message from the Apache Gi
cmccabe edited a comment on pull request #10992:
URL: https://github.com/apache/kafka/pull/10992#issuecomment-875898150
Thanks, @mumrah !
Can you use `Replicas.NONE` instead of `new int[0]`? It saves an allocation.
LGTM after that
--
This is an automated message from the Apa
[
https://issues.apache.org/jira/browse/KAFKA-13028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17376827#comment-17376827
]
Shiva Mogili commented on KAFKA-13028:
--
Thanks [~rhauch], I think this will be quit
hachikuji commented on a change in pull request #10794:
URL: https://github.com/apache/kafka/pull/10794#discussion_r665698647
##
File path: clients/src/main/java/org/apache/kafka/common/requests/ApiError.java
##
@@ -36,10 +37,16 @@
private final String message;
publ
hachikuji commented on a change in pull request #10794:
URL: https://github.com/apache/kafka/pull/10794#discussion_r665696909
##
File path: core/src/main/scala/kafka/network/RequestChannel.scala
##
@@ -124,8 +124,15 @@ object RequestChannel extends Logging {
def buildRespo
hachikuji commented on pull request #10909:
URL: https://github.com/apache/kafka/pull/10909#issuecomment-875928094
cc @jsancio
--
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 comme
ableegoldman commented on a change in pull request #10943:
URL: https://github.com/apache/kafka/pull/10943#discussion_r665706575
##
File path: tests/kafkatest/tests/streams/streams_upgrade_test.py
##
@@ -474,8 +474,9 @@ def do_rolling_bounce(self, processor, counter,
current_g
ableegoldman commented on a change in pull request #10988:
URL: https://github.com/apache/kafka/pull/10988#discussion_r665708080
##
File path: docs/streams/developer-guide/config-streams.html
##
@@ -549,7 +551,7 @@ acceptable.recovery.lag
default.key.serde
hachikuji commented on a change in pull request #10935:
URL: https://github.com/apache/kafka/pull/10935#discussion_r665713457
##
File path: core/src/test/scala/integration/kafka/server/RaftClusterTest.scala
##
@@ -313,4 +318,94 @@ class RaftClusterTest {
cluster.close()
[
https://issues.apache.org/jira/browse/KAFKA-8410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-8410.
-
Resolution: Fixed
> Strengthen the types of Processors, at least in the DSL, maybe in the PAPI as
hachikuji commented on pull request #10986:
URL: https://github.com/apache/kafka/pull/10986#issuecomment-875956460
@ableegoldman Thanks for the patch. I think the original idea behind the
implementation was to ensure that each rebalance triggered only one call to
`onPartitionsRevoked`. It
hachikuji edited a comment on pull request #10986:
URL: https://github.com/apache/kafka/pull/10986#issuecomment-875956460
@ableegoldman Thanks for the patch. I think the original idea behind the
implementation was to ensure that each rebalance triggered only one call to
`onPartitionsRevoke
hachikuji commented on a change in pull request #10914:
URL: https://github.com/apache/kafka/pull/10914#discussion_r665730032
##
File path:
clients/src/main/java/org/apache/kafka/common/record/DefaultRecordBatch.java
##
@@ -90,11 +90,15 @@
* by the broker and is preserved af
hachikuji commented on a change in pull request #10914:
URL: https://github.com/apache/kafka/pull/10914#discussion_r665735408
##
File path:
clients/src/main/java/org/apache/kafka/common/record/DefaultRecordBatch.java
##
@@ -156,13 +161,27 @@ public void ensureValid() {
}
vvcephei opened a new pull request #10994:
URL: https://github.com/apache/kafka/pull/10994
Since the old Processor API is now deprecated, we need to
update the documentation to steer people to the new API.
### Committer Checklist (excluded from commit message)
- [ ] Verify desig
vvcephei commented on pull request #10994:
URL: https://github.com/apache/kafka/pull/10994#issuecomment-875972075
Here are the rendered docs for the reviewers:
![pr
[
https://issues.apache.org/jira/browse/KAFKA-12980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17376870#comment-17376870
]
Jason Gustafson commented on KAFKA-12980:
-
[~ChrisEgerton] I do not think it req
cmccabe merged pull request #10992:
URL: https://github.com/apache/kafka/pull/10992
--
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-unsubscr.
ableegoldman commented on a change in pull request #10985:
URL: https://github.com/apache/kafka/pull/10985#discussion_r665750661
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/CooperativeStickyAssignor.java
##
@@ -53,9 +56,34 @@ public String name() {
vvcephei commented on a change in pull request #10994:
URL: https://github.com/apache/kafka/pull/10994#discussion_r665744745
##
File path: docs/streams/developer-guide/processor-api.html
##
@@ -86,12 +86,48 @@ Overviewclose() method. Note that Kafka Streams may re-use a
single
[
https://issues.apache.org/jira/browse/KAFKA-7458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17376886#comment-17376886
]
John Roesler commented on KAFKA-7458:
-
Hello again, all, this issue should be resolve
[
https://issues.apache.org/jira/browse/KAFKA-7458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-7458.
-
Resolution: Fixed
> Avoid enforced processing during bootstrap phase
> --
[
https://issues.apache.org/jira/browse/KAFKA-7458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-7458:
Fix Version/s: 3.0.0
> Avoid enforced processing during bootstrap phase
> -
[
https://issues.apache.org/jira/browse/KAFKA-7760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Badai Aqrandista reassigned KAFKA-7760:
---
Assignee: Badai Aqrandista (was: Dulvin Witharane)
> Add broker configuration to se
junrao merged pull request #9944:
URL: https://github.com/apache/kafka/pull/9944
--
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-unsubscr...@
[
https://issues.apache.org/jira/browse/KAFKA-10580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-10580.
-
Fix Version/s: 3.1.0
Resolution: Fixed
merged the PR to trunk.
> Add topic ID support to Fetch r
1 - 100 of 153 matches
Mail list logo
