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
[
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:
[
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:
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
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
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
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
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
[
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
[
https://issues.apache.org/jira/browse/KAFKA-10578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17209253#comment-17209253
]
Matthias J. Sax commented on KAFKA-10578:
-
[~javier.freire] – I added you to the list of
[
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
[
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
[
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
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
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
[
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
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
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
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
[
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,
[
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
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:
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
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`
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 @@
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
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
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
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
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
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
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
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 /
[
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
>
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
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=17209038#comment-17209038
]
Sophie Blee-Goldman commented on KAFKA-9831:
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
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
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
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
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
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
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
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17209006#comment-17209006
]
Sophie Blee-Goldman commented on KAFKA-5998:
Yeah I think both of those (running with shared
[
https://issues.apache.org/jira/browse/KAFKA-10520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17208995#comment-17208995
]
Sophie Blee-Goldman commented on KAFKA-10520:
-
Hey [~rsivaram], is this something we can get
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
[
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
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,
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,
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
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):
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
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
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
>
[
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
>
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
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
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
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
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
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
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,
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
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
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.
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,
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17208688#comment-17208688
]
Sandeep commented on KAFKA-5998:
[~ableegoldman] , Yes I was trying out in my local machine. The tmp/
1 - 100 of 112 matches
Mail list logo
