[
https://issues.apache.org/jira/browse/KAFKA-12257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ryan Leslie updated KAFKA-12257:
Description:
In KAFKA-7738, caching of leader epochs (KIP-320) was added to o.a.k.c.Metadata
to
hachikuji commented on a change in pull request #10005:
URL: https://github.com/apache/kafka/pull/10005#discussion_r567203060
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -249,6 +270,7 @@ class KafkaApis(val requestChannel: RequestChannel,
}
def
hachikuji commented on a change in pull request #10005:
URL: https://github.com/apache/kafka/pull/10005#discussion_r567202218
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -119,7 +122,21 @@ class KafkaApis(val requestChannel: RequestChannel,
type
hachikuji commented on a change in pull request #10005:
URL: https://github.com/apache/kafka/pull/10005#discussion_r567201967
##
File path: core/src/main/scala/kafka/log/LogConfig.scala
##
@@ -374,40 +374,4 @@ object LogConfig {
MessageTimestampDifferenceMaxMsProp ->
hachikuji edited a comment on pull request #10006:
URL: https://github.com/apache/kafka/pull/10006#issuecomment-770119487
@abbccdda See for example this trace, which is often found in an unrelated
test case (https://github.com/apache/kafka/runs/1794689847):
```
[
https://issues.apache.org/jira/browse/KAFKA-10323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17275477#comment-17275477
]
Amir Shahsavand commented on KAFKA-10323:
-
Is there any workaround to get a task in this state
jolshan commented on a change in pull request #9944:
URL: https://github.com/apache/kafka/pull/9944#discussion_r567189128
##
File path: core/src/main/scala/kafka/server/FetchSession.scala
##
@@ -237,14 +317,80 @@ class FetchSession(val id: Int,
type TL =
jolshan commented on a change in pull request #9944:
URL: https://github.com/apache/kafka/pull/9944#discussion_r567189013
##
File path:
clients/src/main/java/org/apache/kafka/common/requests/FetchResponse.java
##
@@ -358,6 +452,15 @@ public int sessionId() {
jolshan commented on a change in pull request #9944:
URL: https://github.com/apache/kafka/pull/9944#discussion_r567188957
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java
##
@@ -254,8 +255,14 @@ public synchronized int sendFetches()
jolshan commented on a change in pull request #9944:
URL: https://github.com/apache/kafka/pull/9944#discussion_r567188652
##
File path:
clients/src/main/java/org/apache/kafka/common/requests/FetchResponse.java
##
@@ -358,6 +452,15 @@ public int sessionId() {
jolshan commented on a change in pull request #9944:
URL: https://github.com/apache/kafka/pull/9944#discussion_r567188287
##
File path:
clients/src/main/java/org/apache/kafka/common/requests/FetchResponse.java
##
@@ -358,6 +452,15 @@ public int sessionId() {
jolshan commented on a change in pull request #9944:
URL: https://github.com/apache/kafka/pull/9944#discussion_r567188108
##
File path: core/src/main/scala/kafka/server/FetchSession.scala
##
@@ -187,24 +205,86 @@ class CachedPartition(val topic: String,
}
}
+/**
+ * Very
jolshan commented on a change in pull request #9944:
URL: https://github.com/apache/kafka/pull/9944#discussion_r567188080
##
File path: core/src/main/scala/kafka/server/FetchSession.scala
##
@@ -237,14 +317,80 @@ class FetchSession(val id: Int,
type TL =
Magesh kumar Nandakumar created KAFKA-12259:
---
Summary: Consolidated Status endpoint return 500 whe config
provider can't find a config
Key: KAFKA-12259
URL:
junrao commented on a change in pull request #9901:
URL: https://github.com/apache/kafka/pull/9901#discussion_r567181341
##
File path:
metadata/src/main/java/org/apache/kafka/timeline/SnapshottableHashTable.java
##
@@ -0,0 +1,449 @@
+/*
+ * Licensed to the Apache Software
dengziming commented on pull request #9769:
URL: https://github.com/apache/kafka/pull/9769#issuecomment-770140196
The 2 failures in
https://ci-builds.apache.org/job/Kafka/job/kafka-pr/job/PR-9769/22/ seem to be
related to Mockito, maybe #10006 will fix it. @rajinisivaram PTAL.
rajinisivaram commented on a change in pull request #9944:
URL: https://github.com/apache/kafka/pull/9944#discussion_r566449639
##
File path:
clients/src/main/java/org/apache/kafka/clients/FetchSessionHandler.java
##
@@ -73,6 +76,25 @@ public FetchSessionHandler(LogContext
ableegoldman commented on a change in pull request #9997:
URL: https://github.com/apache/kafka/pull/9997#discussion_r567173261
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java
##
@@ -714,19 +720,34 @@ public boolean
hachikuji merged pull request #9979:
URL: https://github.com/apache/kafka/pull/9979
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
[
https://issues.apache.org/jira/browse/KAFKA-12258?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17275443#comment-17275443
]
Jason Gustafson edited comment on KAFKA-12258 at 1/30/21, 12:54 AM:
[
https://issues.apache.org/jira/browse/KAFKA-12258?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17275443#comment-17275443
]
Jason Gustafson commented on KAFKA-12258:
-
For some background here, we initially had the
Alok Nikhil created KAFKA-12258:
---
Summary: Change the BatchAccumulator to split records into batches
Key: KAFKA-12258
URL: https://issues.apache.org/jira/browse/KAFKA-12258
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-12257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ryan Leslie updated KAFKA-12257:
Description:
In KAFKA-7738, caching of leader epochs (KIP-320) was added to o.a.k.c.Metadata
to
hachikuji edited a comment on pull request #10006:
URL: https://github.com/apache/kafka/pull/10006#issuecomment-770119487
@abbccdda See for example this trace, which is often found in an unrelated
test case (https://github.com/apache/kafka/runs/1794689847):
```
Ryan Leslie created KAFKA-12257:
---
Summary: Consumer mishandles topics deleted and recreated with
the same name
Key: KAFKA-12257
URL: https://issues.apache.org/jira/browse/KAFKA-12257
Project: Kafka
hachikuji commented on pull request #10006:
URL: https://github.com/apache/kafka/pull/10006#issuecomment-770119487
@abbccdda See for example this trace, which is often found in an unrelated
test case (https://github.com/apache/kafka/runs/1794689847):
```
[
https://issues.apache.org/jira/browse/KAFKA-10873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17275437#comment-17275437
]
Luke Chen commented on KAFKA-10873:
---
[~kkonstantine], could you please comment on this?
> Inaccurate
hachikuji commented on a change in pull request #10006:
URL: https://github.com/apache/kafka/pull/10006#discussion_r567162723
##
File path:
clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetcherTest.java
##
@@ -1745,51 +1742,77 @@ public void
rajinisivaram commented on pull request #9769:
URL: https://github.com/apache/kafka/pull/9769#issuecomment-770115726
@dengziming I am so sorry, I didn't notice that you had updated the branch a
few minutes ago, so force-pushed my version. Do you mind force-pushing your
branch once more
abbccdda commented on a change in pull request #10006:
URL: https://github.com/apache/kafka/pull/10006#discussion_r567159871
##
File path:
clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetcherTest.java
##
@@ -1745,51 +1742,77 @@ public void
Ryan Leslie created KAFKA-12256:
---
Summary: auto commit causes delays due to retribale
UNKNOWN_TOPIC_OR_PARTITION
Key: KAFKA-12256
URL: https://issues.apache.org/jira/browse/KAFKA-12256
Project: Kafka
jolshan commented on a change in pull request #9944:
URL: https://github.com/apache/kafka/pull/9944#discussion_r567146583
##
File path:
core/src/test/scala/integration/kafka/server/FetchRequestBetweenDifferentIbpTest.scala
##
@@ -0,0 +1,165 @@
+/**
+ * Licensed to the Apache
hachikuji opened a new pull request #10006:
URL: https://github.com/apache/kafka/pull/10006
This test has been flaky due to a race condition of some kind. I rewrote it
so that it no longer relies on multiple threads.
### Committer Checklist (excluded from commit message)
- [ ]
bob-barrett commented on a change in pull request #9902:
URL: https://github.com/apache/kafka/pull/9902#discussion_r567120007
##
File path:
clients/src/main/java/org/apache/kafka/clients/ClusterConnectionStates.java
##
@@ -183,6 +186,10 @@ public void disconnected(String id,
bob-barrett commented on a change in pull request #9902:
URL: https://github.com/apache/kafka/pull/9902#discussion_r567120007
##
File path:
clients/src/main/java/org/apache/kafka/clients/ClusterConnectionStates.java
##
@@ -183,6 +186,10 @@ public void disconnected(String id,
[
https://issues.apache.org/jira/browse/KAFKA-10761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson resolved KAFKA-10761.
-
Resolution: Fixed
> In Raft support nonzero start offset and SnapshotId for the Fetch
hachikuji merged pull request #9816:
URL: https://github.com/apache/kafka/pull/9816
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
hachikuji commented on pull request #9816:
URL: https://github.com/apache/kafka/pull/9816#issuecomment-770075156
The failures look like known flakes. Will merge to trunk.
This is an automated message from the Apache Git
bob-barrett commented on a change in pull request #9902:
URL: https://github.com/apache/kafka/pull/9902#discussion_r567117421
##
File path: clients/src/main/java/org/apache/kafka/clients/NetworkClient.java
##
@@ -239,24 +241,63 @@ public NetworkClient(Selectable selector,
hachikuji commented on a change in pull request #9777:
URL: https://github.com/apache/kafka/pull/9777#discussion_r567117397
##
File path: core/src/test/scala/unit/kafka/utils/TestUtils.scala
##
@@ -349,10 +349,13 @@ object TestUtils extends Logging {
hachikuji commented on a change in pull request #9777:
URL: https://github.com/apache/kafka/pull/9777#discussion_r567113645
##
File path: core/src/test/scala/unit/kafka/utils/TestUtils.scala
##
@@ -885,6 +891,24 @@ object TestUtils extends Logging {
), "Timed out waiting
[
https://issues.apache.org/jira/browse/KAFKA-10551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17275381#comment-17275381
]
Justine Olshan commented on KAFKA-10551:
Oh no. I was looking at this and I accidentally
[
https://issues.apache.org/jira/browse/KAFKA-10551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan reassigned KAFKA-10551:
--
Assignee: (was: Justine Olshan)
> Support topic IDs in Produce request
>
[
https://issues.apache.org/jira/browse/KAFKA-10551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan reassigned KAFKA-10551:
--
Assignee: Justine Olshan (was: dengziming)
> Support topic IDs in Produce request
>
[
https://issues.apache.org/jira/browse/KAFKA-10764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan resolved KAFKA-10764.
Resolution: Fixed
> Add support for returning topic IDs on create, supplying topic IDs
bob-barrett commented on a change in pull request #9902:
URL: https://github.com/apache/kafka/pull/9902#discussion_r567112712
##
File path: clients/src/test/java/org/apache/kafka/clients/NetworkClientTest.java
##
@@ -907,6 +924,140 @@ public void testCorrelationId() {
hachikuji commented on pull request #9996:
URL: https://github.com/apache/kafka/pull/9996#issuecomment-770067513
Not also the test failure
`RequestConvertToJsonTest.testAllResponseTypesHandled`.
This is an automated message
hachikuji commented on a change in pull request #9996:
URL: https://github.com/apache/kafka/pull/9996#discussion_r567106239
##
File path: clients/src/main/java/org/apache/kafka/clients/admin/Admin.java
##
@@ -1449,6 +1449,39 @@ default DescribeFeaturesResult describeFeatures()
[
https://issues.apache.org/jira/browse/KAFKA-12247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-12247:
Description:
Ensure that calling removeStreamThread make the thread leave the group right
[
https://issues.apache.org/jira/browse/KAFKA-10015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson closed KAFKA-10015.
--
> React Smartly to Unexpected Errors on Stream Threads
>
[
https://issues.apache.org/jira/browse/KAFKA-10015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson resolved KAFKA-10015.
Resolution: Fixed
> React Smartly to Unexpected Errors on Stream Threads
>
[
https://issues.apache.org/jira/browse/KAFKA-10015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson reassigned KAFKA-10015:
--
Assignee: Walker Carlson (was: Bruno Cadonna)
> React Smartly to Unexpected Errors
[
https://issues.apache.org/jira/browse/KAFKA-10500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson closed KAFKA-10500.
--
> Add API to Start and Stop Stream Threads
>
>
>
[
https://issues.apache.org/jira/browse/KAFKA-12247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson closed KAFKA-12247.
--
> Make removeStreamThread work better with static membership
>
[
https://issues.apache.org/jira/browse/KAFKA-10867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-10867.
-
Resolution: Fixed
> Implement improved semantics using the ConsumerRecords meta
>
[
https://issues.apache.org/jira/browse/KAFKA-10091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-10091:
Fix Version/s: 2.8.0
> Improve task idling
> ---
>
> Key:
[
https://issues.apache.org/jira/browse/KAFKA-10091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-10091.
-
Resolution: Fixed
> Improve task idling
> ---
>
> Key:
[
https://issues.apache.org/jira/browse/KAFKA-10866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-10866.
-
Resolution: Fixed
> Add fetched metadata to ConsumerRecords
>
hachikuji commented on a change in pull request #9986:
URL: https://github.com/apache/kafka/pull/9986#discussion_r567078580
##
File path: core/src/test/java/kafka/test/junit/ClusterForEach.java
##
@@ -0,0 +1,219 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under
hachikuji commented on a change in pull request #9986:
URL: https://github.com/apache/kafka/pull/9986#discussion_r567073840
##
File path: core/src/test/java/kafka/test/annotation/ClusterProperty.java
##
@@ -0,0 +1,32 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
ableegoldman merged pull request #9984:
URL: https://github.com/apache/kafka/pull/9984
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
ableegoldman commented on pull request #9984:
URL: https://github.com/apache/kafka/pull/9984#issuecomment-770035212
All tests passed 拾 Merging to trunk
This is an automated message from the Apache Git Service.
To respond to
hachikuji commented on a change in pull request #9986:
URL: https://github.com/apache/kafka/pull/9986#discussion_r567073840
##
File path: core/src/test/java/kafka/test/annotation/ClusterProperty.java
##
@@ -0,0 +1,32 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
mumrah commented on a change in pull request #10003:
URL: https://github.com/apache/kafka/pull/10003#discussion_r567070588
##
File path: core/src/main/scala/kafka/server/ReplicaManager.scala
##
@@ -257,6 +265,25 @@ class ReplicaManager(val config: KafkaConfig,
}
}
+
Jose Armando Garcia Sancio created KAFKA-12255:
--
Summary: Investigate allowing for Fetch request that are not
validated
Key: KAFKA-12255
URL: https://issues.apache.org/jira/browse/KAFKA-12255
[
https://issues.apache.org/jira/browse/KAFKA-12254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dhruvil Shah updated KAFKA-12254:
-
Description:
`MirrorSourceConnector` implements the logic for replicating data,
Dhruvil Shah created KAFKA-12254:
Summary: MirrorMaker 2.0 creates destination topic with default
configs
Key: KAFKA-12254
URL: https://issues.apache.org/jira/browse/KAFKA-12254
Project: Kafka
mumrah commented on a change in pull request #10003:
URL: https://github.com/apache/kafka/pull/10003#discussion_r567065946
##
File path: core/src/main/scala/kafka/server/ReplicaManager.scala
##
@@ -197,7 +204,8 @@ class ReplicaManager(val config: KafkaConfig,
mumrah commented on a change in pull request #10003:
URL: https://github.com/apache/kafka/pull/10003#discussion_r567064852
##
File path: core/src/main/scala/kafka/server/ReplicaManager.scala
##
@@ -257,6 +265,25 @@ class ReplicaManager(val config: KafkaConfig,
}
}
+
ableegoldman commented on pull request #9671:
URL: https://github.com/apache/kafka/pull/9671#issuecomment-770017240
Cherrypicked to 2.6 as well
This is an automated message from the Apache Git Service.
To respond to the
[
https://issues.apache.org/jira/browse/KAFKA-10793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman updated KAFKA-10793:
---
Fix Version/s: 2.6.2
> Race condition in FindCoordinatorFuture permanently
Jose Armando Garcia Sancio created KAFKA-12253:
--
Summary: Add tests that cover all of all of the cases for
ReplicatedLog::validateOffsetAndEpoch
Key: KAFKA-12253
URL:
[
https://issues.apache.org/jira/browse/KAFKA-8930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman updated KAFKA-8930:
--
Fix Version/s: (was: 2.6.0)
2.6.2
> MM2 documentation
>
[
https://issues.apache.org/jira/browse/KAFKA-8930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17275292#comment-17275292
]
A. Sophie Blee-Goldman commented on KAFKA-8930:
---
Hey [~miguno] I changed the FixVersion to
wcarlson5 commented on a change in pull request #9984:
URL: https://github.com/apache/kafka/pull/9984#discussion_r566940153
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -25,7 +25,7 @@
import
rajinisivaram commented on pull request #9769:
URL: https://github.com/apache/kafka/pull/9769#issuecomment-770011022
@dengziming Even the last PR build for this one seemed to have issues. I
merged https://github.com/apache/kafka/pull/9684 first since that build looked
good. But now this
rajinisivaram merged pull request #9684:
URL: https://github.com/apache/kafka/pull/9684
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
hachikuji merged pull request #:
URL: https://github.com/apache/kafka/pull/
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
rajinisivaram commented on pull request #9684:
URL: https://github.com/apache/kafka/pull/9684#issuecomment-770006566
The failing test FetcherTest.testEarlierOffsetResetArrivesLate is a known
flaky test (https://issues.apache.org/jira/browse/KAFKA-12245). Merging to
trunk.
rondagostino opened a new pull request #10005:
URL: https://github.com/apache/kafka/pull/10005
`Partition` objects are able to retrieve topic configs when creating their
log, and currently they do so via ZooKeeper. ZooKeeper is not available when
using the Raft-based metadata log, so we
cmccabe commented on a change in pull request #9901:
URL: https://github.com/apache/kafka/pull/9901#discussion_r567034077
##
File path:
metadata/src/main/java/org/apache/kafka/timeline/SnapshotRegistry.java
##
@@ -0,0 +1,251 @@
+/*
+ * Licensed to the Apache Software
cmccabe commented on a change in pull request #9901:
URL: https://github.com/apache/kafka/pull/9901#discussion_r567032323
##
File path:
metadata/src/main/java/org/apache/kafka/timeline/SnapshotRegistry.java
##
@@ -0,0 +1,249 @@
+/*
+ * Licensed to the Apache Software
cmccabe commented on a change in pull request #9901:
URL: https://github.com/apache/kafka/pull/9901#discussion_r567028392
##
File path: metadata/src/main/java/org/apache/kafka/timeline/TimelineHashMap.java
##
@@ -0,0 +1,414 @@
+/*
+ * Licensed to the Apache Software Foundation
cmccabe commented on a change in pull request #9901:
URL: https://github.com/apache/kafka/pull/9901#discussion_r567027495
##
File path:
metadata/src/main/java/org/apache/kafka/timeline/timeline/SnapshottableHashTable.java
##
@@ -0,0 +1,410 @@
+/*
+ * Licensed to the Apache
junrao commented on a change in pull request #9901:
URL: https://github.com/apache/kafka/pull/9901#discussion_r567020932
##
File path:
metadata/src/main/java/org/apache/kafka/timeline/SnapshotRegistry.java
##
@@ -0,0 +1,251 @@
+/*
+ * Licensed to the Apache Software
ning2008wisc commented on pull request #9287:
URL: https://github.com/apache/kafka/pull/9287#issuecomment-769983845
@mimaison @ryannedolan As titled, I think the change proposed in this PR may
be preferred when tackling https://issues.apache.org/jira/browse/KAFKA-10339
(EOS) since lots of
dhruvilshah3 commented on pull request #7480:
URL: https://github.com/apache/kafka/pull/7480#issuecomment-769980062
@ryannedolan are you planning on working on this? I noticed that MM2 has no
system tests at the moment.
wcarlson5 commented on a change in pull request #9978:
URL: https://github.com/apache/kafka/pull/9978#discussion_r567019601
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateDirectory.java
##
@@ -133,6 +152,72 @@ private void
cmccabe commented on a change in pull request #9901:
URL: https://github.com/apache/kafka/pull/9901#discussion_r567014747
##
File path:
metadata/src/main/java/org/apache/kafka/timeline/SnapshotRegistry.java
##
@@ -0,0 +1,251 @@
+/*
+ * Licensed to the Apache Software
cmccabe commented on a change in pull request #9901:
URL: https://github.com/apache/kafka/pull/9901#discussion_r567014310
##
File path:
metadata/src/main/java/org/apache/kafka/timeline/SnapshotRegistry.java
##
@@ -0,0 +1,251 @@
+/*
+ * Licensed to the Apache Software
ableegoldman commented on a change in pull request #9978:
URL: https://github.com/apache/kafka/pull/9978#discussion_r567013928
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateDirectory.java
##
@@ -133,6 +152,72 @@ private void
lct45 commented on a change in pull request #9253:
URL: https://github.com/apache/kafka/pull/9253#discussion_r567013228
##
File path:
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/Serdes.scala
##
@@ -41,8 +43,19 @@ object Serdes {
implicit def
junrao commented on a change in pull request #9901:
URL: https://github.com/apache/kafka/pull/9901#discussion_r567004415
##
File path:
metadata/src/main/java/org/apache/kafka/timeline/SnapshotRegistry.java
##
@@ -0,0 +1,251 @@
+/*
+ * Licensed to the Apache Software
vvcephei commented on a change in pull request #9253:
URL: https://github.com/apache/kafka/pull/9253#discussion_r567010831
##
File path:
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/Serdes.scala
##
@@ -41,8 +43,19 @@ object Serdes {
implicit def
hachikuji commented on a change in pull request #9994:
URL: https://github.com/apache/kafka/pull/9994#discussion_r566987833
##
File path: clients/src/main/java/org/apache/kafka/common/protocol/ApiKeys.java
##
@@ -98,7 +98,9 @@
mjsax merged pull request #9969:
URL: https://github.com/apache/kafka/pull/9969
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
dengziming edited a comment on pull request #9769:
URL: https://github.com/apache/kafka/pull/9769#issuecomment-769911317
@rajinisivaram Thank you, I think the problem comes from
`EasyMock.expect(authorizer.authorize(anyObject[RequestContext],
EasyMock.eq(expectedActions.asJava)))`.
lct45 commented on a change in pull request #9253:
URL: https://github.com/apache/kafka/pull/9253#discussion_r566957547
##
File path:
streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/SerdesUnitTest.scala
##
@@ -0,0 +1,35 @@
+/**
+ * Licensed to the Apache
lct45 commented on a change in pull request #9253:
URL: https://github.com/apache/kafka/pull/9253#discussion_r566957204
##
File path:
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/Serdes.scala
##
@@ -41,8 +43,19 @@ object Serdes {
implicit def
nicolasguyomar opened a new pull request #10004:
URL: https://github.com/apache/kafka/pull/10004
Hi team,
Minor improvement to log the received memberId upon joining a group at INFO
level on the memberside (consumer, worker) so that we can easily track broker
logs with the member
1 - 100 of 134 matches
Mail list logo
