urbandan commented on a change in pull request #11748:
URL: https://github.com/apache/kafka/pull/11748#discussion_r815676139
##
File path:
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointTask.java
##
@@ -169,6 +172,7 @@ public String version() {
urbandan commented on a change in pull request #11748:
URL: https://github.com/apache/kafka/pull/11748#discussion_r815676139
##
File path:
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointTask.java
##
@@ -169,6 +172,7 @@ public String version() {
dengziming commented on pull request #11173:
URL: https://github.com/apache/kafka/pull/11173#issuecomment-1054166718
The latest commit rebased on the trunk and add support earliest, latest and
max-timestamp for --time. I also test them locally:
```
bin/kafka-run-class.sh kafka.tools.G
[
https://issues.apache.org/jira/browse/KAFKA-10857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17498863#comment-17498863
]
Guram Savinov edited comment on KAFKA-10857 at 2/28/22, 11:50 AM:
[
https://issues.apache.org/jira/browse/KAFKA-10857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17498863#comment-17498863
]
Guram Savinov commented on KAFKA-10857:
---
The problem still exists in Kafka 3.x
St
michalxo commented on pull request #11788:
URL: https://github.com/apache/kafka/pull/11788#issuecomment-1054317604
I ran almost full kafka test suite. Got in total around 23 failures, which
is great compared to `trunk` where fails almost everything.
I have executed it last Wednesday, so
cadonna merged pull request #11804:
URL: https://github.com/apache/kafka/pull/11804
--
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 specific comment.
To unsubscribe, e-mail: jira-unsubscr.
[
https://issues.apache.org/jira/browse/KAFKA-13542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna resolved KAFKA-13542.
---
Resolution: Fixed
> Utilize the new Consumer#enforceRebalance(reason) API in Streams
> -
dajac commented on a change in pull request #11173:
URL: https://github.com/apache/kafka/pull/11173#discussion_r816093355
##
File path: core/src/main/scala/kafka/tools/GetOffsetShell.scala
##
@@ -70,12 +71,13 @@ object GetOffsetShell {
.withRequiredA
mimaison commented on pull request #11572:
URL: https://github.com/apache/kafka/pull/11572#issuecomment-1054536303
Thanks @C0urante for the review! Again you made some very good suggestions.
I've pushed an update.
--
This is an automated message from the Apache Git Service.
To respond to
C0urante commented on a change in pull request #11773:
URL: https://github.com/apache/kafka/pull/11773#discussion_r816156264
##
File path:
connect/api/src/main/java/org/apache/kafka/connect/source/SourceConnector.java
##
@@ -28,4 +30,46 @@
protected SourceConnectorContext
C0urante commented on a change in pull request #11572:
URL: https://github.com/apache/kafka/pull/11572#discussion_r816159562
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/DelegatingClassLoader.java
##
@@ -232,8 +252,7 @@ private void in
C0urante commented on pull request #11572:
URL: https://github.com/apache/kafka/pull/11572#issuecomment-1054567120
Noticed that the "resolve comment" option isn't available on this PR,
apparently you need to either be the author of a PR or have write access to the
repo in order to resolve
C0urante edited a comment on pull request #11572:
URL: https://github.com/apache/kafka/pull/11572#issuecomment-1054567120
Noticed that the "resolve comment" option isn't available on this PR,
apparently you need to either be the author of a PR or have write access to the
repo in order to r
[
https://issues.apache.org/jira/browse/KAFKA-12901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499138#comment-17499138
]
Jun Rao commented on KAFKA-12901:
-
[~suriyav] : Did you see the same log error as in KAF
[
https://issues.apache.org/jira/browse/KAFKA-13418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499167#comment-17499167
]
Yiming Zang commented on KAFKA-13418:
-
Thanks [~skokoori] for creating this issue, a
[
https://issues.apache.org/jira/browse/KAFKA-9957?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499166#comment-17499166
]
John D commented on KAFKA-9957:
---
I am facing an exact similar issue,
# a broker is having
wcarlson5 commented on a change in pull request #11813:
URL: https://github.com/apache/kafka/pull/11813#discussion_r816239929
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/NamedTopologyTest.java
##
@@ -149,7 +149,7 @@ public void
shouldThrow
[
https://issues.apache.org/jira/browse/KAFKA-13672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Liam Clarke-Hutchinson reassigned KAFKA-13672:
--
Assignee: Liam Clarke-Hutchinson
> Flaky test
> kafka.server.Dynamic
[
https://issues.apache.org/jira/browse/KAFKA-13658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499202#comment-17499202
]
Pratim Chaudhuri commented on KAFKA-13658:
--
This also affects version 3.0 and 3
ableegoldman commented on a change in pull request #11813:
URL: https://github.com/apache/kafka/pull/11813#discussion_r816305679
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/NamedTopologyTest.java
##
@@ -124,6 +124,17 @@ public void
shouldA
ableegoldman commented on a change in pull request #11813:
URL: https://github.com/apache/kafka/pull/11813#discussion_r816306370
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/NamedTopologyTest.java
##
@@ -149,7 +149,7 @@ public void
shouldTh
ableegoldman commented on a change in pull request #11813:
URL: https://github.com/apache/kafka/pull/11813#discussion_r816306491
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/namedtopology/KafkaStreamsNamedTopologyWrapper.java
##
@@ -230,53 +
ableegoldman commented on a change in pull request #11813:
URL: https://github.com/apache/kafka/pull/11813#discussion_r816307586
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/namedtopology/KafkaStreamsNamedTopologyWrapper.java
##
@@ -230,53 +
ableegoldman commented on a change in pull request #11813:
URL: https://github.com/apache/kafka/pull/11813#discussion_r816307925
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/namedtopology/KafkaStreamsNamedTopologyWrapper.java
##
@@ -230,53 +
[
https://issues.apache.org/jira/browse/KAFKA-13699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shay Lin updated KAFKA-13699:
-
Description:
As a KS developer, I would like to leverage
[KIP-622|https://cwiki.apache.org/confluence/d
Shay Lin created KAFKA-13699:
Summary: ProcessorContext does not expose Stream Time
Key: KAFKA-13699
URL: https://issues.apache.org/jira/browse/KAFKA-13699
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-13699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shay Lin updated KAFKA-13699:
-
Description:
As a KS developer, I would like to leverage
[KIP-622|https://cwiki.apache.org/confluence/d
ableegoldman commented on a change in pull request #11813:
URL: https://github.com/apache/kafka/pull/11813#discussion_r816337445
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/namedtopology/KafkaStreamsNamedTopologyWrapper.java
##
@@ -230,53 +
ableegoldman commented on a change in pull request #11813:
URL: https://github.com/apache/kafka/pull/11813#discussion_r816337811
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/namedtopology/KafkaStreamsNamedTopologyWrapper.java
##
@@ -100,7 +1
Uday Bhaskar created KAFKA-13700:
Summary: Kafka reporting corrupted block message.
Key: KAFKA-13700
URL: https://issues.apache.org/jira/browse/KAFKA-13700
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-13700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Uday Bhaskar updated KAFKA-13700:
-
Summary: Kafka reporting CorruptRecordException exception (was: Kafka
reporting corrupted block
ableegoldman commented on a change in pull request #11812:
URL: https://github.com/apache/kafka/pull/11812#discussion_r816342899
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/NamedTopologyIntegrationTest.java
##
@@ -775,6 +781,70 @@ public void shoul
lihaosky opened a new pull request #11820:
URL: https://github.com/apache/kafka/pull/11820
Add restoration logic for `RocksDBTimeOrderedWindowStore`. Changelog's key
is serialized from `WindowKeySchema` and transform key format to match index
and base store's format
### Comm
[
https://issues.apache.org/jira/browse/KAFKA-13514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499259#comment-17499259
]
A. Sophie Blee-Goldman commented on KAFKA-13514:
Hmm, I'm sure it was fr
[
https://issues.apache.org/jira/browse/KAFKA-13514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499259#comment-17499259
]
A. Sophie Blee-Goldman edited comment on KAFKA-13514 at 3/1/22, 1:28 AM:
-
[
https://issues.apache.org/jira/browse/KAFKA-13658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen reassigned KAFKA-13658:
-
Assignee: (was: Luke Chen)
> Upgrade vulnerable dependencies jan 2022
> ---
[
https://issues.apache.org/jira/browse/KAFKA-13658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499271#comment-17499271
]
Luke Chen commented on KAFKA-13658:
---
[~pratimsc] , go ahead to submit PR to fix this i
wcarlson5 commented on a change in pull request #11813:
URL: https://github.com/apache/kafka/pull/11813#discussion_r816411304
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/NamedTopologyTest.java
##
@@ -149,7 +149,7 @@ public void
shouldThrow
LiamClarkeNZ opened a new pull request #11821:
URL: https://github.com/apache/kafka/pull/11821
WIP PR to get better insight into flakiness in CI context.
--
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 t
showuon opened a new pull request #11822:
URL: https://github.com/apache/kafka/pull/11822
*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 testing
[
https://issues.apache.org/jira/browse/KAFKA-9374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton updated KAFKA-9374:
-
Description:
If a connector hangs during any of its {{{}initialize{}}}, {{{}start{}}},
{{{}stop{
dengziming commented on a change in pull request #11173:
URL: https://github.com/apache/kafka/pull/11173#discussion_r816447498
##
File path: core/src/test/scala/kafka/tools/GetOffsetShellParsingTest.scala
##
@@ -17,191 +17,231 @@
package kafka.tools
-import org.apache.kafk
hgeraldino commented on a change in pull request #11773:
URL: https://github.com/apache/kafka/pull/11773#discussion_r816451067
##
File path:
connect/api/src/main/java/org/apache/kafka/connect/source/SourceConnector.java
##
@@ -28,4 +30,46 @@
protected SourceConnectorConte
[
https://issues.apache.org/jira/browse/KAFKA-13631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499337#comment-17499337
]
Chris Egerton commented on KAFKA-13631:
---
Interestingly enough, it seemed initially
[
https://issues.apache.org/jira/browse/KAFKA-13631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499337#comment-17499337
]
Chris Egerton edited comment on KAFKA-13631 at 3/1/22, 5:26 AM:
--
[
https://issues.apache.org/jira/browse/KAFKA-13631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499337#comment-17499337
]
Chris Egerton edited comment on KAFKA-13631 at 3/1/22, 5:27 AM:
--
ableegoldman opened a new pull request #11823:
URL: https://github.com/apache/kafka/pull/11823
Pretty much any time we have an integration test failure that's flaky or
only exposed when running on Jenkins through the PR builds, it's impossible to
debug if it cannot be reproduced locally as
ableegoldman opened a new pull request #11824:
URL: https://github.com/apache/kafka/pull/11824
Seen a few of the new tests added [fail on PR
builds](https://ci-builds.apache.org/job/Kafka/job/kafka-pr/job/PR-11812/3/testReport/org.apache.kafka.streams.integration/NamedTopologyIntegrationTes
showuon commented on pull request #11788:
URL: https://github.com/apache/kafka/pull/11788#issuecomment-1055087971
Thanks for verifying it @michalxo !
--
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
Kowshik Prakasam created KAFKA-13701:
Summary: Pin background worker threads for certain background work
(ex: UnifiedLog.flush())
Key: KAFKA-13701
URL: https://issues.apache.org/jira/browse/KAFKA-13701
kowshik commented on pull request #11814:
URL: https://github.com/apache/kafka/pull/11814#issuecomment-1055098574
@junrao Thanks for the review! I checked the test failures, and they look
unrelated to this PR. I agree, your suggestion is a good way to simplify the
code and it will be a lot
[
https://issues.apache.org/jira/browse/KAFKA-13701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kowshik Prakasam updated KAFKA-13701:
-
Description:
Certain background work such as UnifiedLog.flush() need not support
concur
yangyijun1990 opened a new pull request #11825:
URL: https://github.com/apache/kafka/pull/11825
*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 t
yangyijun1990 opened a new pull request #11826:
URL: https://github.com/apache/kafka/pull/11826
*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 t
yangyijun1990 commented on pull request #11826:
URL: https://github.com/apache/kafka/pull/11826#issuecomment-1055122657
update
--
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 specific commen
56 matches
Mail list logo