nym3r0s commented on pull request #9280:
URL: https://github.com/apache/kafka/pull/9280#issuecomment-704718666
ha - thank you đŸ˜„
This is an automated message from the Apache Git Service.
To respond to the message, please log o
rite2nikhil commented on a change in pull request #9382:
URL: https://github.com/apache/kafka/pull/9382#discussion_r500743939
##
File path: core/src/main/scala/kafka/server/AbstractFetcherThread.scala
##
@@ -432,14 +455,22 @@ abstract class AbstractFetcherThread(name: String,
vvcephei commented on a change in pull request #9388:
URL: https://github.com/apache/kafka/pull/9388#discussion_r500715702
##
File path:
streams/examples/src/test/java/org/apache/kafka/streams/examples/wordcount/WordCountProcessorTest.java
##
@@ -34,6 +34,7 @@
* Demonstrate
vvcephei opened a new pull request #9388:
URL: https://github.com/apache/kafka/pull/9388
* all wrapping stores should pass StateStoreContext init through to the same
method on the wrapped store and not translate it to ProcessorContext init
* base-level stores should handle StateStore
[
https://issues.apache.org/jira/browse/KAFKA-10437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10437:
-
Description:
In addition to implementing the KIP, search for and resolve these todos:
{color:#0
[
https://issues.apache.org/jira/browse/KAFKA-10437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10437:
-
Description:
In addition to implementing the KIP, search for and resolve these todos:
{color:#0
ableegoldman commented on a change in pull request #9273:
URL: https://github.com/apache/kafka/pull/9273#discussion_r500682632
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -364,6 +370,73 @@ public void setUncaughtExceptionHandler(final
T
ableegoldman commented on a change in pull request #9273:
URL: https://github.com/apache/kafka/pull/9273#discussion_r500682039
##
File path:
streams/src/main/java/org/apache/kafka/streams/errors/StreamsUncaughtExceptionHandler.java
##
@@ -0,0 +1,49 @@
+/*
+ * Licensed to the A
ableegoldman commented on a change in pull request #9273:
URL: https://github.com/apache/kafka/pull/9273#discussion_r500681912
##
File path:
streams/src/main/java/org/apache/kafka/streams/errors/StreamsUncaughtExceptionHandler.java
##
@@ -0,0 +1,49 @@
+/*
+ * Licensed to the A
ableegoldman commented on a change in pull request #9273:
URL: https://github.com/apache/kafka/pull/9273#discussion_r500681512
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -364,6 +370,73 @@ public void setUncaughtExceptionHandler(final
T
ableegoldman commented on a change in pull request #9273:
URL: https://github.com/apache/kafka/pull/9273#discussion_r500681407
##
File path:
streams/src/main/java/org/apache/kafka/streams/errors/StreamsUncaughtExceptionHandler.java
##
@@ -0,0 +1,49 @@
+/*
+ * Licensed to the A
[
https://issues.apache.org/jira/browse/KAFKA-10578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-10578:
---
Assignee: Javier Freire RiobĂ³
> Convert KTable to a KStream using the previous valu
[
https://issues.apache.org/jira/browse/KAFKA-10578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17209253#comment-17209253
]
Matthias J. Sax commented on KAFKA-10578:
-
[~javier.freire] – I added you to the
[
https://issues.apache.org/jira/browse/KAFKA-10578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-10578:
Summary: Convert KTable to a KStream using the previous value (was:
KIP-675: Convert KTab
[
https://issues.apache.org/jira/browse/KAFKA-10578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-10578:
Description:
Imagine that we have an entity for which we want to emit the difference betwe
[
https://issues.apache.org/jira/browse/KAFKA-10578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-10578:
Labels: kip (was: )
> KIP-675: Convert KTable to a KStream using the previous value
> ---
ableegoldman commented on a change in pull request #9139:
URL: https://github.com/apache/kafka/pull/9139#discussion_r500664927
##
File path:
streams/src/test/java/org/apache/kafka/streams/state/internals/CachingSessionStoreTest.java
##
@@ -278,6 +326,23 @@ public void shouldFe
guozhangwang commented on pull request #8988:
URL: https://github.com/apache/kafka/pull/8988#issuecomment-704615880
test this
This is an automated message from the Apache Git Service.
To respond to the message, please log on
guozhangwang commented on pull request #8988:
URL: https://github.com/apache/kafka/pull/8988#issuecomment-704615342
System test:
https://jenkins.confluent.io/job/system-test-kafka-branch-builder/4195/
This is an automated me
ableegoldman commented on a change in pull request #9139:
URL: https://github.com/apache/kafka/pull/9139#discussion_r500658560
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/CachingSessionStore.java
##
@@ -270,25 +335,32 @@ public void close() {
kowshik commented on pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#issuecomment-704596581
@junrao The test failure in
`MirrorConnectorsIntegrationTest.testReplication` does not seem related. I have
rebased the PR now against latest AK trunk, I'd like to see if the fail
[
https://issues.apache.org/jira/browse/KAFKA-10024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Anna Povzner reassigned KAFKA-10024:
Assignee: David Mao (was: Anna Povzner)
> Add dynamic configuration and enforce quota fo
ableegoldman commented on pull request #9280:
URL: https://github.com/apache/kafka/pull/9280#issuecomment-704587824
I don't think they're fixed on trunk lol đŸ™‚ (besides, I believe Jenkins
merges the PR with trunk before running the tests so it's running the most
recent code anyways).
rgo edited a comment on pull request #2541:
URL: https://github.com/apache/kafka/pull/2541#issuecomment-704547984
I've been working on it. I'm going to open a new PR and I'll link it to this
one.
PR: #9387
This is an
rgo opened a new pull request #9387:
URL: https://github.com/apache/kafka/pull/9387
Add subnet support to ACL authorizer. For IPv4 and IPv6, it supports:
- IP address range
- Subnet CIDR notation
Test strategy has been simple:
- Define ranges and set ACLs with IPs include
rgo commented on pull request #2541:
URL: https://github.com/apache/kafka/pull/2541#issuecomment-704547984
I've been working on it. I'm going to open a new PR and I'll link it to this
one.
This is an automated message from t
[
https://issues.apache.org/jira/browse/KAFKA-10550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan updated KAFKA-10550:
---
Description:
Change some AdminClient methods to expose and support topic IDs (describe,
del
[
https://issues.apache.org/jira/browse/KAFKA-10550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan updated KAFKA-10550:
---
Summary: Update AdminClient and kafka-topics.sh to support topic IDs (was:
Update kafka-top
Justine Olshan created KAFKA-10580:
--
Summary: Add topic ID support to Fetch request
Key: KAFKA-10580
URL: https://issues.apache.org/jira/browse/KAFKA-10580
Project: Kafka
Issue Type: Sub-tas
nym3r0s commented on pull request #9280:
URL: https://github.com/apache/kafka/pull/9280#issuecomment-704543777
@ableegoldman @hachikuji - Should I rebase these changes off of trunk
(assuming these tests are fixed on trunk) ?
[
https://issues.apache.org/jira/browse/KAFKA-10547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan updated KAFKA-10547:
---
Summary: Add topic IDs to MetadataResponse, UpdateMetadata (was: Add topic
IDs to MetadataR
splett2 opened a new pull request #9386:
URL: https://github.com/apache/kafka/pull/9386
This PR implements the part of KIP-612 for adding IP throttling enforcement,
and a ZK entity for configuring dynamic IP throttles.
I will add `kafka-configs` support as well as `KafkaApi` reconfig
mjsax opened a new pull request #9385:
URL: https://github.com/apache/kafka/pull/9385
Part of KIP-572.
Also add handler method to trigger/reset the timeout on a task.
Call for review @vvcephei
This
mjsax commented on a change in pull request #9384:
URL: https://github.com/apache/kafka/pull/9384#discussion_r500574894
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/HighAvailabilityStreamsPartitionAssignorTest.java
##
@@ -203,8 +204,8 @@ pub
mjsax commented on a change in pull request #9384:
URL: https://github.com/apache/kafka/pull/9384#discussion_r500574645
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/HighAvailabilityStreamsPartitionAssignorTest.java
##
@@ -131,12 +130,13 @@
mjsax commented on a change in pull request #9384:
URL: https://github.com/apache/kafka/pull/9384#discussion_r500574127
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/AssignorConfiguration.java
##
@@ -291,11 +271,7 @@ public String
mjsax opened a new pull request #9384:
URL: https://github.com/apache/kafka/pull/9384
Currently, we pass `AdminClient` and `TaskManager` into
`StreamsPartitionAssignor` and use `TaskManager#mainConsumer()` to get access
to the main consumer. However, TM also had a reference to `AdminClient
scanterog commented on a change in pull request #9313:
URL: https://github.com/apache/kafka/pull/9313#discussion_r500569567
##
File path:
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorConnectorConfig.java
##
@@ -199,8 +199,8 @@
protected static fina
mimaison commented on a change in pull request #9313:
URL: https://github.com/apache/kafka/pull/9313#discussion_r500568357
##
File path:
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorConnectorConfig.java
##
@@ -199,8 +199,8 @@
protected static final
scanterog commented on a change in pull request #9313:
URL: https://github.com/apache/kafka/pull/9313#discussion_r500566839
##
File path:
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorConnectorConfig.java
##
@@ -199,8 +199,8 @@
protected static fina
mimaison commented on a change in pull request #9313:
URL: https://github.com/apache/kafka/pull/9313#discussion_r500562684
##
File path:
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorConnectorConfig.java
##
@@ -199,8 +199,8 @@
protected static final
ijuma merged pull request #9336:
URL: https://github.com/apache/kafka/pull/9336
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
ijuma commented on pull request #9336:
URL: https://github.com/apache/kafka/pull/9336#issuecomment-704521581
Sounds good.
This is an automated message from the Apache Git Service.
To respond to the message, please log on to G
hachikuji commented on pull request #9336:
URL: https://github.com/apache/kafka/pull/9336#issuecomment-704519950
@ijuma Thanks, LGTM. I think we can consider exposing an API eventually, but
for now I'd like to have full flexibility to change it.
---
dajac commented on a change in pull request #9318:
URL: https://github.com/apache/kafka/pull/9318#discussion_r500544582
##
File path:
core/src/main/scala/kafka/coordinator/group/GroupMetadataManager.scala
##
@@ -1321,25 +1106,15 @@ object GroupMetadataManager {
*/
def r
ableegoldman commented on pull request #9280:
URL: https://github.com/apache/kafka/pull/9280#issuecomment-704502487
LGTM!
Looks like the builds just failed with some unrelated flaky tests:
```
Build / JDK 8 /
org.apache.kafka.connect.integration.InternalTopicsIntegrationTest.te
[
https://issues.apache.org/jira/browse/KAFKA-10579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman updated KAFKA-10579:
Labels: flaky-test (was: )
> Flaky test
> connect.integration.InternalTopicsInte
Sophie Blee-Goldman created KAFKA-10579:
---
Summary: Flaky test
connect.integration.InternalTopicsIntegrationTest.testStartWhenInternalTopicsCreatedManuallyWithCompactForBrokersDefaultCleanupPolicy
Key: KAFKA-10579
ableegoldman commented on pull request #9373:
URL: https://github.com/apache/kafka/pull/9373#issuecomment-704493219
FYI this should be cherrypicked back to 2.6 once merged
This is an automated message from the Apache Git Serv
brbrown25 commented on pull request #9057:
URL: https://github.com/apache/kafka/pull/9057#issuecomment-704492883
@mimaison I've updated the kip and put out a vote request but not seeing any
action. I've gone ahead and updated this pr to be updated with latest trunk as
well.
-
[
https://issues.apache.org/jira/browse/KAFKA-9831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17209038#comment-17209038
]
Sophie Blee-Goldman commented on KAFKA-9831:
[https://ci-builds.apache.org/jo
guozhangwang commented on a change in pull request #8988:
URL: https://github.com/apache/kafka/pull/8988#discussion_r500521516
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextImpl.java
##
@@ -65,10 +65,6 @@ public ProcessorConte
wcarlson5 commented on a change in pull request #9273:
URL: https://github.com/apache/kafka/pull/9273#discussion_r500521571
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
##
@@ -384,9 +390,8 @@ public static StreamThread crea
guozhangwang commented on pull request #9020:
URL: https://github.com/apache/kafka/pull/9020#issuecomment-704474872
test this
This is an automated message from the Apache Git Service.
To respond to the message, please log on
guozhangwang closed pull request #9020:
URL: https://github.com/apache/kafka/pull/9020
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
guozhangwang commented on pull request #9020:
URL: https://github.com/apache/kafka/pull/9020#issuecomment-704462953
test this
This is an automated message from the Apache Git Service.
To respond to the message, please log on
guozhangwang merged pull request #9321:
URL: https://github.com/apache/kafka/pull/9321
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
guozhangwang commented on pull request #9321:
URL: https://github.com/apache/kafka/pull/9321#issuecomment-704461565
LGTM!
This is an automated message from the Apache Git Service.
To respond to the message, please log on to G
guozhangwang commented on pull request #9020:
URL: https://github.com/apache/kafka/pull/9020#issuecomment-704460681
test this please
This is an automated message from the Apache Git Service.
To respond to the message, please
rhauch merged pull request #8910:
URL: https://github.com/apache/kafka/pull/8910
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
guozhangwang commented on pull request #9020:
URL: https://github.com/apache/kafka/pull/9020#issuecomment-704460234
test this please
This is an automated message from the Apache Git Service.
To respond to the message, please
[
https://issues.apache.org/jira/browse/KAFKA-10338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rajini Sivaram resolved KAFKA-10338.
Fix Version/s: 2.7.0
Reviewer: Manikumar
Resolution: Fixed
> Support PEM f
rajinisivaram merged pull request #9345:
URL: https://github.com/apache/kafka/pull/9345
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
rajinisivaram commented on pull request #9345:
URL: https://github.com/apache/kafka/pull/9345#issuecomment-704456290
@omkreddy Thanks for the review, merging to trunk.
This is an automated message from the Apache Git Service.
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17209006#comment-17209006
]
Sophie Blee-Goldman commented on KAFKA-5998:
Yeah I think both of those (runn
[
https://issues.apache.org/jira/browse/KAFKA-10520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17208995#comment-17208995
]
Sophie Blee-Goldman commented on KAFKA-10520:
-
Hey [~rsivaram], is this some
piotrrzysko commented on pull request #9371:
URL: https://github.com/apache/kafka/pull/9371#issuecomment-704430920
Thanks for the review, @stanislavkozlovski. If I understand your point
clearly, you are wondering whether this validation will block changing the
replication factor for all pa
[
https://issues.apache.org/jira/browse/KAFKA-10527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson resolved KAFKA-10527.
-
Resolution: Fixed
> Voters should always initialize as followers
> -
rondagostino commented on a change in pull request #9378:
URL: https://github.com/apache/kafka/pull/9378#discussion_r500465547
##
File path: tests/kafkatest/services/kafka/kafka.py
##
@@ -451,7 +451,8 @@ def _kafka_topics_cmd(self, node, force_use_zk_connection):
set.
scanterog commented on a change in pull request #9313:
URL: https://github.com/apache/kafka/pull/9313#discussion_r500464804
##
File path:
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorConnectorConfig.java
##
@@ -199,8 +199,8 @@
protected static fina
rondagostino commented on a change in pull request #9378:
URL: https://github.com/apache/kafka/pull/9378#discussion_r500464258
##
File path: tests/kafkatest/services/kafka/kafka.py
##
@@ -983,7 +988,10 @@ def _topic_command_connect_setting(self, node,
force_use_zk_connection):
hachikuji merged pull request #9348:
URL: https://github.com/apache/kafka/pull/9348
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
rondagostino commented on a change in pull request #9378:
URL: https://github.com/apache/kafka/pull/9378#discussion_r500460487
##
File path: tests/kafkatest/services/security/kafka_acls.py
##
@@ -93,11 +97,13 @@ def add_cluster_acl(self, kafka, principal,
force_use_zk_connecti
lct45 commented on pull request #9383:
URL: https://github.com/apache/kafka/pull/9383#issuecomment-704410260
@ableegoldman ready for initial review
This is an automated message from the Apache Git Service.
To respond to the m
rajinisivaram commented on a change in pull request #9378:
URL: https://github.com/apache/kafka/pull/9378#discussion_r500429377
##
File path: tests/kafkatest/services/kafka/kafka.py
##
@@ -451,7 +451,8 @@ def _kafka_topics_cmd(self, node, force_use_zk_connection):
set.
junrao commented on pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#issuecomment-704393633
@abbccdda : Any more comments from you?
This is an automated message from the Apache Git Service.
To respond to the
guozhangwang commented on pull request #9358:
URL: https://github.com/apache/kafka/pull/9358#issuecomment-704386882
Thanks @abbccdda for the reviews!
This is an automated message from the Apache Git Service.
To respond to the
guozhangwang merged pull request #9358:
URL: https://github.com/apache/kafka/pull/9358
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
[
https://issues.apache.org/jira/browse/KAFKA-10578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Javier Freire RiobĂ³ updated KAFKA-10578:
Issue Type: Improvement (was: Wish)
> KIP-675: Convert KTable to a KStream using
lct45 opened a new pull request #9383:
URL: https://github.com/apache/kafka/pull/9383
Add data to subscriptionUserData to make sure that it's different each time
a consumer rejoins
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ]
ning2008wisc commented on pull request #9224:
URL: https://github.com/apache/kafka/pull/9224#issuecomment-704353923
@mimaison I think this pr is ready for initial review. Please take your time
when available. Thanks
This is
[
https://issues.apache.org/jira/browse/KAFKA-6733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-6733:
---
Fix Version/s: 2.7.0
> Support of printing additional ConsumerRecord fields in
> DefaultMessageForma
[
https://issues.apache.org/jira/browse/KAFKA-6733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-6733:
---
Affects Version/s: 2.7.0
> Support of printing additional ConsumerRecord fields in
> DefaultMessageF
bbejeck commented on pull request #9237:
URL: https://github.com/apache/kafka/pull/9237#issuecomment-704347684
Java 8 failed with
`kafka.network.ConnectionQuotasTest.testNoConnectionLimitsByDefault`
Java 11 failed with
`org.apache.kafka.streams.integration.EosBetaUpgradeIntegrationTest.
coded9 commented on pull request #8575:
URL: https://github.com/apache/kafka/pull/8575#issuecomment-704328653
Any update or possible workaround ? @rhauch
This is an automated message from the Apache Git Service.
To respond
chia7712 commented on a change in pull request #9318:
URL: https://github.com/apache/kafka/pull/9318#discussion_r500361487
##
File path:
core/src/main/scala/kafka/coordinator/group/GroupMetadataManager.scala
##
@@ -997,174 +996,7 @@ object GroupMetadataManager {
val Metrics
rajinisivaram commented on pull request #9345:
URL: https://github.com/apache/kafka/pull/9345#issuecomment-704327619
@omkreddy Thanks for the review, have addressed the comments.
This is an automated message from the Apache G
rajinisivaram commented on a change in pull request #9345:
URL: https://github.com/apache/kafka/pull/9345#discussion_r500360036
##
File path:
clients/src/test/java/org/apache/kafka/common/network/SslTransportLayerTest.java
##
@@ -167,17 +181,12 @@ public void testValidEndpoint
rajinisivaram commented on a change in pull request #9345:
URL: https://github.com/apache/kafka/pull/9345#discussion_r500359056
##
File path: clients/src/test/java/org/apache/kafka/common/network/CertStores.java
##
@@ -54,13 +60,30 @@ public CertStores(boolean server, String co
bbejeck commented on pull request #9099:
URL: https://github.com/apache/kafka/pull/9099#issuecomment-704322766
Thanks for the contribution @badaiaqrandista!
This is an automated message from the Apache Git Service.
To respond
bbejeck commented on pull request #9099:
URL: https://github.com/apache/kafka/pull/9099#issuecomment-704322552
Merged #9099 into trunk
This is an automated message from the Apache Git Service.
To respond to the message, pleas
bbejeck merged pull request #9099:
URL: https://github.com/apache/kafka/pull/9099
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 th
chia7712 commented on a change in pull request #9318:
URL: https://github.com/apache/kafka/pull/9318#discussion_r500352497
##
File path:
core/src/main/scala/kafka/coordinator/group/GroupMetadataManager.scala
##
@@ -1257,60 +1059,31 @@ object GroupMetadataManager {
dajac commented on a change in pull request #9318:
URL: https://github.com/apache/kafka/pull/9318#discussion_r500293553
##
File path:
core/src/main/scala/kafka/coordinator/group/GroupMetadataManager.scala
##
@@ -1257,60 +1059,31 @@ object GroupMetadataManager {
kkonstantine merged pull request #9379:
URL: https://github.com/apache/kafka/pull/9379
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
kkonstantine commented on pull request #9379:
URL: https://github.com/apache/kafka/pull/9379#issuecomment-704314583
JDK 15 was green. Rest of the failures are not relevant.
This is an automated message from the Apache Git Se
stanislavkozlovski commented on pull request #9371:
URL: https://github.com/apache/kafka/pull/9371#issuecomment-704300915
Thanks for the PR @piotrrzysko. The changes look good although I'm not sure
if we're not regressing the ability to change the replication factor of a topic
if we're to
rajinisivaram opened a new pull request #9382:
URL: https://github.com/apache/kafka/pull/9382
For IBP 2.7 onwards, fetch responses include diverging epoch and offset in
fetch responses if `lastFetchedEpoch` is provided in the fetch request. This PR
uses that information for truncation and
javierfreire opened a new pull request #9381:
URL: https://github.com/apache/kafka/pull/9381
This gives the possibility of converting a table into a stream using a
mapper with the new and old values as arguments.
[KIP-675](https://cwiki.apache.org/confluence/display/KAFKA/KIP-675%3A
omkreddy commented on a change in pull request #9345:
URL: https://github.com/apache/kafka/pull/9345#discussion_r500186433
##
File path: clients/src/test/java/org/apache/kafka/test/TestSslUtils.java
##
@@ -199,6 +206,156 @@ public static void createKeyStore(String filename,
1 - 100 of 110 matches
Mail list logo
