chia7712 commented on a change in pull request #9850:
URL: https://github.com/apache/kafka/pull/9850#discussion_r70480
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -3242,6 +3209,133 @@ class KafkaApis(val requestChannel: RequestChannel,
}
}
lordcheng10 commented on pull request #9870:
URL: https://github.com/apache/kafka/pull/9870#issuecomment-758447102
@guozhangwang @stanislavkozlovski
Added a tool for dynamic log modification. Can you help me take a look?
Thank you for your attention
---
lordcheng10 commented on pull request #9870:
URL: https://github.com/apache/kafka/pull/9870#issuecomment-758444947
@guozhangwang Added a tool for dynamic log modification. Can you help me
take a look? Thank you for your attention
---
[
https://issues.apache.org/jira/browse/KAFKA-10895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantine Karantasis resolved KAFKA-10895.
Resolution: Fixed
> Basic auth extension's JAAS config can be corrupted by
[
https://issues.apache.org/jira/browse/KAFKA-10895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantine Karantasis updated KAFKA-10895:
---
Fix Version/s: 2.6.2
2.7.1
2.8.0
kkonstantine merged pull request #9806:
URL: https://github.com/apache/kafka/pull/9806
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-12181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17263042#comment-17263042
]
Jose Armando Garcia Sancio commented on KAFKA-12181:
This analysis m
hachikuji opened a new pull request #9871:
URL: https://github.com/apache/kafka/pull/9871
We would like to be able to use `KafkaRaftClient` for tooling/debugging use
cases. For this, we need the localId to be optional so that the client can be
used more like a consumer. This is already sup
lordcheng10 commented on pull request #9869:
URL: https://github.com/apache/kafka/pull/9869#issuecomment-758355110
> Closing since this looks like it was opened by mistake.
@hachikuji Thank you for your attention, the correct submission is here
：https://github.com/apache/kafka/pull/9
jsancio commented on a change in pull request #9756:
URL: https://github.com/apache/kafka/pull/9756#discussion_r555472538
##
File path:
raft/src/main/java/org/apache/kafka/raft/internals/BatchAccumulator.java
##
@@ -211,6 +214,33 @@ public long timeUntilDrain(long currentTimeM
lordcheng10 commented on pull request #9869:
URL: https://github.com/apache/kafka/pull/9869#issuecomment-758354394
> Closing since this looks like it was opened by mistake.
Thank you for your attention, the correct submission is here
：https://github.com/apache/kafka/pull/9870
-
hachikuji closed pull request #9869:
URL: https://github.com/apache/kafka/pull/9869
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 #9869:
URL: https://github.com/apache/kafka/pull/9869#issuecomment-758353061
Closing since this looks like it was opened by mistake.
This is an automated message from the Apache Git Service
jsancio commented on a change in pull request #9756:
URL: https://github.com/apache/kafka/pull/9756#discussion_r555470725
##
File path: raft/src/main/java/org/apache/kafka/raft/RaftConfig.java
##
@@ -59,6 +60,11 @@
private static final String QUORUM_LINGER_MS_DOC = "The du
lordcheng10 opened a new pull request #9870:
URL: https://github.com/apache/kafka/pull/9870
*More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a separate
comment to ping reviewers.*
*Summary of testi
hachikuji commented on a change in pull request #9756:
URL: https://github.com/apache/kafka/pull/9756#discussion_r555466107
##
File path:
raft/src/main/java/org/apache/kafka/raft/internals/BatchAccumulator.java
##
@@ -37,6 +37,7 @@
private final Time time;
private fi
lordcheng10 closed pull request #9868:
URL: https://github.com/apache/kafka/pull/9868
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 t
lordcheng10 closed pull request #9860:
URL: https://github.com/apache/kafka/pull/9860
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 t
hachikuji commented on a change in pull request #9756:
URL: https://github.com/apache/kafka/pull/9756#discussion_r555466107
##
File path:
raft/src/main/java/org/apache/kafka/raft/internals/BatchAccumulator.java
##
@@ -37,6 +37,7 @@
private final Time time;
private fi
[
https://issues.apache.org/jira/browse/KAFKA-12176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17263020#comment-17263020
]
Jun Rao commented on KAFKA-12176:
-
Another complication in the previous discussion was w
jsancio commented on a change in pull request #9756:
URL: https://github.com/apache/kafka/pull/9756#discussion_r555462779
##
File path:
raft/src/main/java/org/apache/kafka/raft/internals/BatchAccumulator.java
##
@@ -37,6 +37,7 @@
private final Time time;
private fina
jsancio commented on a change in pull request #9756:
URL: https://github.com/apache/kafka/pull/9756#discussion_r555460647
##
File path:
raft/src/main/java/org/apache/kafka/raft/internals/BatchAccumulator.java
##
@@ -37,6 +37,7 @@
private final Time time;
private fina
[
https://issues.apache.org/jira/browse/KAFKA-12173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-12173:
Component/s: streams
> Migrate streams:streams-scala module to JUnit 5
> -
[
https://issues.apache.org/jira/browse/KAFKA-12171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-12171:
Component/s: streams-test-utils
> Migrate streams:test-utils module to JUnit 5
> -
[
https://issues.apache.org/jira/browse/KAFKA-12172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-12172:
Component/s: streams
> Migrate streams:examples module to JUnit 5
> --
[
https://issues.apache.org/jira/browse/KAFKA-7342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-7342:
---
Component/s: streams
> Migrate streams modules to JUnit 5
> -
lordcheng10 opened a new pull request #9869:
URL: https://github.com/apache/kafka/pull/9869
*More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a separate
comment to ping reviewers.*
*Summary of testi
hachikuji commented on a change in pull request #9756:
URL: https://github.com/apache/kafka/pull/9756#discussion_r555431717
##
File path:
raft/src/main/java/org/apache/kafka/raft/internals/BatchAccumulator.java
##
@@ -37,6 +37,7 @@
private final Time time;
private fi
lordcheng10 opened a new pull request #9868:
URL: https://github.com/apache/kafka/pull/9868
*More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a separate
comment to ping reviewers.*
*Summary of testi
hachikuji commented on a change in pull request #9600:
URL: https://github.com/apache/kafka/pull/9600#discussion_r555419244
##
File path:
clients/src/main/java/org/apache/kafka/common/protocol/ApiVersion.java
##
@@ -53,4 +53,18 @@ public String toString() {
", max
hachikuji commented on a change in pull request #9600:
URL: https://github.com/apache/kafka/pull/9600#discussion_r555415827
##
File path:
clients/src/main/java/org/apache/kafka/common/protocol/ApiVersion.java
##
@@ -14,10 +14,10 @@
* See the License for the specific language
[
https://issues.apache.org/jira/browse/KAFKA-6223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sebb reopened KAFKA-6223:
-
A couple of old releases could/should now be dropped from the mirrors:
2.5.0
2.6.0
> Please delete old releases fro
levzem opened a new pull request #9867:
URL: https://github.com/apache/kafka/pull/9867
Signed-off-by: Lev Zemlyanov
*More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a separate
comment to ping revi
Jason Gustafson created KAFKA-12181:
---
Summary: Loosen monotonic fetch offset validation by raft leader
Key: KAFKA-12181
URL: https://issues.apache.org/jira/browse/KAFKA-12181
Project: Kafka
jsancio commented on a change in pull request #9816:
URL: https://github.com/apache/kafka/pull/9816#discussion_r555386624
##
File path: raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java
##
@@ -970,40 +996,98 @@ private FetchResponseData tryCompleteFetchRequest(
cmccabe opened a new pull request #9866:
URL: https://github.com/apache/kafka/pull/9866
* Implement the uint16 type
* Implement MetadataRecordType and MetadataJsonConverters
This is an automated message from the Apache
jsancio commented on a change in pull request #9816:
URL: https://github.com/apache/kafka/pull/9816#discussion_r555386153
##
File path: raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java
##
@@ -970,40 +996,98 @@ private FetchResponseData tryCompleteFetchRequest(
jsancio commented on a change in pull request #9816:
URL: https://github.com/apache/kafka/pull/9816#discussion_r555382425
##
File path: raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java
##
@@ -2216,7 +2316,7 @@ public void complete() {
// These fields are v
jsancio commented on a change in pull request #9816:
URL: https://github.com/apache/kafka/pull/9816#discussion_r555381158
##
File path: raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java
##
@@ -1326,6 +1408,17 @@ private boolean handleFetchSnapshotResponse(
Colin McCabe created KAFKA-12180:
Summary: Implement the KIP-631 message generator changes
Key: KAFKA-12180
URL: https://issues.apache.org/jira/browse/KAFKA-12180
Project: Kafka
Issue Type: I
jsancio commented on a change in pull request #9816:
URL: https://github.com/apache/kafka/pull/9816#discussion_r555371195
##
File path: core/src/main/scala/kafka/raft/KafkaMetadataLog.scala
##
@@ -29,13 +32,15 @@ import org.apache.kafka.snapshot.FileRawSnapshotReader
import or
jsancio commented on a change in pull request #9816:
URL: https://github.com/apache/kafka/pull/9816#discussion_r555371195
##
File path: core/src/main/scala/kafka/raft/KafkaMetadataLog.scala
##
@@ -29,13 +32,15 @@ import org.apache.kafka.snapshot.FileRawSnapshotReader
import or
d8tltanc opened a new pull request #9865:
URL: https://github.com/apache/kafka/pull/9865
Fill in the 2.8 release note for Authorizer
This is an automated message from the Apache Git Service.
To respond to the message, please
inponomarev commented on pull request #9107:
URL: https://github.com/apache/kafka/pull/9107#issuecomment-758218461
Hi @vvcephei , thank you for your comment. There's another question that we
were unable to solve without you -- see
https://github.com/apache/kafka/pull/9107#issuecomment-7520
[
https://issues.apache.org/jira/browse/KAFKA-12179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Muhammad Arif updated KAFKA-12179:
--
Description:
*Installing Kafka on IBM Cloud*
This document will describe how to install Ka
[
https://issues.apache.org/jira/browse/KAFKA-12179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Muhammad Arif updated KAFKA-12179:
--
Description:
*Installing Kafka on IBM Cloud*
This document will describe how to install Ka
[
https://issues.apache.org/jira/browse/KAFKA-12179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Muhammad Arif updated KAFKA-12179:
--
Description:
*Installing Kafka on IBM Cloud*
This document will describe how to install Ka
[
https://issues.apache.org/jira/browse/KAFKA-12179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Muhammad Arif updated KAFKA-12179:
--
Description:
*Installing Kafka on IBM Cloud*
This document will describe how to install Ka
[
https://issues.apache.org/jira/browse/KAFKA-12179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Muhammad Arif updated KAFKA-12179:
--
Description:
*Installing Kafka on IBM Cloud*
This document will describe how to install Ka
[
https://issues.apache.org/jira/browse/KAFKA-12179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Muhammad Arif updated KAFKA-12179:
--
Description:
*Installing Kafka on IBM Cloud*
*+Contents+*
# Introduction
# Provision Kub
[
https://issues.apache.org/jira/browse/KAFKA-12179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Muhammad Arif updated KAFKA-12179:
--
Description:
*Installing Kafka on IBM Cloud*
*+Contents+*
# Introduction
# Provision Kub
ableegoldman merged pull request #9695:
URL: https://github.com/apache/kafka/pull/9695
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
cadonna commented on a change in pull request #9863:
URL: https://github.com/apache/kafka/pull/9863#discussion_r555322808
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -249,20 +249,31 @@ public boolean isValidTransition(final State newStat
ableegoldman commented on pull request #9695:
URL: https://github.com/apache/kafka/pull/9695#issuecomment-758208639
Merged to trunk
This is an automated message from the Apache Git Service.
To respond to the message, please l
[
https://issues.apache.org/jira/browse/KAFKA-12179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Muhammad Arif updated KAFKA-12179:
--
Description:
*Installing Kafka on IBM Cloud*
*+Contents+*
# Introduction
# Provision Kub
wcarlson5 commented on a change in pull request #9863:
URL: https://github.com/apache/kafka/pull/9863#discussion_r555320421
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -249,20 +249,31 @@ public boolean isValidTransition(final State newSt
[
https://issues.apache.org/jira/browse/KAFKA-12179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Muhammad Arif updated KAFKA-12179:
--
Attachment: (was: Kafka1.png)
> Install Kafka on IBM Cloud
> --
>
[
https://issues.apache.org/jira/browse/KAFKA-12179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Muhammad Arif updated KAFKA-12179:
--
Description:
*Installing Kafka on IBM Cloud*
*+Contents+*
# Introduction
# Provision Kub
cadonna commented on a change in pull request #9863:
URL: https://github.com/apache/kafka/pull/9863#discussion_r555319837
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -249,20 +249,31 @@ public boolean isValidTransition(final State newStat
[
https://issues.apache.org/jira/browse/KAFKA-12179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Muhammad Arif updated KAFKA-12179:
--
Description:
*Installing Kafka on IBM Cloud*
*+Contents+*
# Introduction
# Provision Kub
cadonna commented on a change in pull request #9863:
URL: https://github.com/apache/kafka/pull/9863#discussion_r555313715
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -249,20 +249,31 @@ public boolean isValidTransition(final State newStat
hachikuji commented on a change in pull request #9749:
URL: https://github.com/apache/kafka/pull/9749#discussion_r555294948
##
File path: core/src/main/scala/kafka/server/AlterIsrManager.scala
##
@@ -116,63 +116,75 @@ class DefaultAlterIsrManager(
private val unsentIsrUpdate
Muhammad Arif created KAFKA-12179:
-
Summary: Install Kafka on IBM Cloud
Key: KAFKA-12179
URL: https://issues.apache.org/jira/browse/KAFKA-12179
Project: Kafka
Issue Type: Improvement
mimaison commented on pull request #9844:
URL: https://github.com/apache/kafka/pull/9844#issuecomment-758184086
@bbejeck @mjsax @vvcephei Can you comment on
https://github.com/apache/kafka/pull/9844#issuecomment-757859210? Thanks
--
Lucas Bradstreet created KAFKA-12178:
Summary: Improve guard rails for consumer commit when using EOS
Key: KAFKA-12178
URL: https://issues.apache.org/jira/browse/KAFKA-12178
Project: Kafka
hachikuji commented on a change in pull request #9815:
URL: https://github.com/apache/kafka/pull/9815#discussion_r555286063
##
File path: examples/src/main/java/kafka/examples/Consumer.java
##
@@ -26,33 +25,34 @@
import java.util.Collections;
import java.util.Optional;
impor
Lucas Bradstreet created KAFKA-12177:
Summary: Retention is not idempotent
Key: KAFKA-12177
URL: https://issues.apache.org/jira/browse/KAFKA-12177
Project: Kafka
Issue Type: Improvement
hachikuji commented on a change in pull request #9850:
URL: https://github.com/apache/kafka/pull/9850#discussion_r555281573
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -3242,6 +3209,133 @@ class KafkaApis(val requestChannel: RequestChannel,
}
}
Jason Gustafson created KAFKA-12176:
---
Summary: Consider changing default
log.message.timestamp.difference.max.ms
Key: KAFKA-12176
URL: https://issues.apache.org/jira/browse/KAFKA-12176
Project: Kafk
hachikuji commented on a change in pull request #9850:
URL: https://github.com/apache/kafka/pull/9850#discussion_r555247829
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -3242,6 +3209,133 @@ class KafkaApis(val requestChannel: RequestChannel,
}
}
C0urante commented on pull request #9806:
URL: https://github.com/apache/kafka/pull/9806#issuecomment-758124317
Thanks Konstantine, I've resolved the merge conflicts.
This is an automated message from the Apache Git Service.
hachikuji commented on a change in pull request #9850:
URL: https://github.com/apache/kafka/pull/9850#discussion_r555236682
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -3242,6 +3209,133 @@ class KafkaApis(val requestChannel: RequestChannel,
}
}
hachikuji commented on a change in pull request #9850:
URL: https://github.com/apache/kafka/pull/9850#discussion_r555227878
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -3242,6 +3209,133 @@ class KafkaApis(val requestChannel: RequestChannel,
}
}
chia7712 commented on pull request #9864:
URL: https://github.com/apache/kafka/pull/9864#issuecomment-758120400
The code is related to
https://github.com/apache/kafka/commit/befd80b38d3ccb1aa0c6d99a899129fd5cf27774
so ping @guozhangwang @ijuma for reviewing.
chia7712 opened a new pull request #9864:
URL: https://github.com/apache/kafka/pull/9864
I'm deploying a new system tests suite for latest JDK (i.e JDK 15) on my
machine. the version of JDK is ```openjdk version "15" 2020-09-15```.
Unfortunately, it can't be parsed by kafka system tests.
hachikuji commented on a change in pull request #9850:
URL: https://github.com/apache/kafka/pull/9850#discussion_r555227878
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -3242,6 +3209,133 @@ class KafkaApis(val requestChannel: RequestChannel,
}
}
hachikuji commented on a change in pull request #9850:
URL: https://github.com/apache/kafka/pull/9850#discussion_r555221278
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -186,77 +160,70 @@ class KafkaApis(val requestChannel: RequestChannel,
trace(s
hachikuji merged pull request #9839:
URL: https://github.com/apache/kafka/pull/9839
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-10759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17262814#comment-17262814
]
Jun Rao commented on KAFKA-10759:
-
[~xiaopenglei] : Thanks for your help. Perhaps you co
[
https://issues.apache.org/jira/browse/KAFKA-12170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17262779#comment-17262779
]
Sven Erik Knop commented on KAFKA-12170:
Thanks a lot. I work for Confluent, som
chia7712 commented on a change in pull request #9856:
URL: https://github.com/apache/kafka/pull/9856#discussion_r555190531
##
File path:
streams/test-utils/src/test/java/org/apache/kafka/streams/TopologyTestDriverTest.java
##
@@ -448,29 +441,37 @@ private Topology setupTopolog
chia7712 commented on a change in pull request #9856:
URL: https://github.com/apache/kafka/pull/9856#discussion_r555187556
##
File path:
streams/test-utils/src/test/java/org/apache/kafka/streams/TopologyTestDriverTest.java
##
@@ -448,29 +441,37 @@ private Topology setupTopolog
ijuma commented on a change in pull request #9856:
URL: https://github.com/apache/kafka/pull/9856#discussion_r555186158
##
File path:
streams/test-utils/src/test/java/org/apache/kafka/streams/TopologyTestDriverTest.java
##
@@ -448,29 +441,37 @@ private Topology setupTopologyWi
chia7712 commented on a change in pull request #9856:
URL: https://github.com/apache/kafka/pull/9856#discussion_r555184290
##
File path:
streams/test-utils/src/test/java/org/apache/kafka/streams/TopologyTestDriverTest.java
##
@@ -448,29 +441,37 @@ private Topology setupTopolog
wcarlson5 commented on pull request #9697:
URL: https://github.com/apache/kafka/pull/9697#issuecomment-758067947
@zydzjy I don't think you can do that yet, at least not with anything I have
added here. The idea is to recover from transient expectations without having
to restart the client.
wcarlson5 commented on a change in pull request #9863:
URL: https://github.com/apache/kafka/pull/9863#discussion_r555168775
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -249,20 +249,31 @@ public boolean isValidTransition(final State newSt
ijuma commented on a change in pull request #9856:
URL: https://github.com/apache/kafka/pull/9856#discussion_r555168755
##
File path:
streams/test-utils/src/test/java/org/apache/kafka/streams/TopologyTestDriverTest.java
##
@@ -448,29 +441,37 @@ private Topology setupTopologyWi
wcarlson5 commented on a change in pull request #9695:
URL: https://github.com/apache/kafka/pull/9695#discussion_r555141563
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -1432,7 +1480,9 @@ public void cleanUp() {
validateIsRunning
cadonna commented on a change in pull request #9508:
URL: https://github.com/apache/kafka/pull/9508#discussion_r555140872
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBPrefixIterator.java
##
@@ -0,0 +1,66 @@
+/*
+ * Licensed to the Apache
wcarlson5 commented on a change in pull request #9695:
URL: https://github.com/apache/kafka/pull/9695#discussion_r555138077
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -992,7 +992,7 @@ private StreamThread createStreamThread(final long
vamossagar12 commented on a change in pull request #9508:
URL: https://github.com/apache/kafka/pull/9508#discussion_r555134866
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBPrefixIterator.java
##
@@ -0,0 +1,66 @@
+/*
+ * Licensed to the Ap
chia7712 commented on a change in pull request #9856:
URL: https://github.com/apache/kafka/pull/9856#discussion_r55513
##
File path:
streams/test-utils/src/test/java/org/apache/kafka/streams/TopologyTestDriverTest.java
##
@@ -1832,8 +1916,10 @@ public void process(final Re
ijuma commented on a change in pull request #9856:
URL: https://github.com/apache/kafka/pull/9856#discussion_r555128880
##
File path:
streams/test-utils/src/test/java/org/apache/kafka/streams/TopologyTestDriverTest.java
##
@@ -1832,8 +1916,10 @@ public void process(final Recor
[
https://issues.apache.org/jira/browse/KAFKA-10526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17262724#comment-17262724
]
Sagar Rao edited comment on KAFKA-10526 at 1/11/21, 3:30 PM:
-
[
https://issues.apache.org/jira/browse/KAFKA-12170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17262725#comment-17262725
]
Chia-Ping Tsai commented on KAFKA-12170:
[~seknop] welcome to Kafka :)
I have a
mumrah commented on a change in pull request #9749:
URL: https://github.com/apache/kafka/pull/9749#discussion_r555127356
##
File path: core/src/main/scala/kafka/server/AlterIsrManager.scala
##
@@ -116,63 +116,78 @@ class DefaultAlterIsrManager(
private val unsentIsrUpdates:
[
https://issues.apache.org/jira/browse/KAFKA-12170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai reassigned KAFKA-12170:
--
Assignee: Sven Erik Knop
> Connect Cast cannot deal with fields of type "bytes" corre
chia7712 commented on a change in pull request #9856:
URL: https://github.com/apache/kafka/pull/9856#discussion_r555125957
##
File path:
streams/test-utils/src/test/java/org/apache/kafka/streams/TopologyTestDriverTest.java
##
@@ -1832,8 +1916,10 @@ public void process(final Re
ijuma commented on a change in pull request #9856:
URL: https://github.com/apache/kafka/pull/9856#discussion_r555124847
##
File path:
streams/test-utils/src/test/java/org/apache/kafka/streams/TopologyTestDriverTest.java
##
@@ -1832,8 +1916,10 @@ public void process(final Recor
[
https://issues.apache.org/jira/browse/KAFKA-10526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17262724#comment-17262724
]
Sagar Rao commented on KAFKA-10526:
---
[~hachikuji], while KAFKA-10652 is getting revie
1 - 100 of 138 matches
Mail list logo
