shadikajevand commented on pull request #9359:
URL: https://github.com/apache/kafka/pull/9359#issuecomment-704087513
Thanks @rhauch I will look into it :)
This is an automated message from the Apache Git Service.
To respond
Fleshgrinder commented on pull request #9369:
URL: https://github.com/apache/kafka/pull/9369#issuecomment-704098722
@vvcephei done
This is an automated message from the Apache Git Service.
To respond to the message, please lo
rajinisivaram commented on pull request #9372:
URL: https://github.com/apache/kafka/pull/9372#issuecomment-704107648
Test failure not related, merging to trunk
This is an automated message from the Apache Git Service.
To resp
rajinisivaram merged pull request #9372:
URL: https://github.com/apache/kafka/pull/9372
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-7334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17208614#comment-17208614
]
Vladimir commented on KAFKA-7334:
-
I'd like to take this issue.
> Suggest changing confi
nym3r0s commented on a change in pull request #9280:
URL: https://github.com/apache/kafka/pull/9280#discussion_r500166517
##
File path:
clients/src/test/java/org/apache/kafka/clients/producer/internals/SenderTest.java
##
@@ -2358,6 +2359,41 @@ public void testForceShutdownWith
lkokhreidze commented on a change in pull request #9237:
URL: https://github.com/apache/kafka/pull/9237#discussion_r500023844
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/StreamTableJoinTopologyOptimizationIntegrationTest.java
##
@@ -0,0 +1,256 @@
+
voffcheg109 opened a new pull request #9380:
URL: https://github.com/apache/kafka/pull/9380
When state.dir is left at default configuration, there is a chance that
certain files under the state directory are cleaned by OS since the default dir
starts with /tmp/kafka-streams.
I've ad
Javier Freire Riobó created KAFKA-10578:
---
Summary: KIP-675: Convert KTable to a KStream using the previous
value
Key: KAFKA-10578
URL: https://issues.apache.org/jira/browse/KAFKA-10578
Project:
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17208688#comment-17208688
]
Sandeep commented on KAFKA-5998:
[~ableegoldman] , Yes I was trying out in my local machi
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,
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
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
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
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
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
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 {
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 {
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
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 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
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
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
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
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
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.
[
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
[
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
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
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
- [ ]
[
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
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
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
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
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.
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
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_r500464258
##
File path: tests/kafkatest/services/kafka/kafka.py
##
@@ -983,7 +988,10 @@ def _topic_command_connect_setting(self, node,
force_use_zk_connection):
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_r500465547
##
File path: tests/kafkatest/services/kafka/kafka.py
##
@@ -451,7 +451,8 @@ def _kafka_topics_cmd(self, node, force_use_zk_connection):
set.
[
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
> -
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-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
[
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
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.
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
[
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
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
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-704460681
test this please
This is an automated message from the Apache Git Service.
To respond to the message, please
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 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 #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 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-704474872
test this
This is an automated message from the Apache Git Service.
To respond to the message, please log on
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 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
[
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
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.
-
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
Sophie Blee-Goldman created KAFKA-10579:
---
Summary: Flaky test
connect.integration.InternalTopicsIntegrationTest.testStartWhenInternalTopicsCreatedManuallyWithCompactForBrokersDefaultCleanupPolicy
Key: KAFKA-10579
[
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
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
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
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.
---
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
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
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
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_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_r500569567
##
File path:
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorConnectorConfig.java
##
@@ -199,8 +199,8 @@
protected static fina
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
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 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_r500574894
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/HighAvailabilityStreamsPartitionAssignorTest.java
##
@@ -203,8 +204,8 @@ pub
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
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
[
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
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) ?
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
[
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
[
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
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
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 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
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).
[
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
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
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() {
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
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
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
[
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
> ---
[
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: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 reassigned KAFKA-10578:
---
Assignee: Javier Freire Riobó
> Convert KTable to a KStream using the previous valu
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
1 - 100 of 110 matches
Mail list logo
