[
https://issues.apache.org/jira/browse/KAFKA-13255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17407122#comment-17407122
]
Anamika Nadkarni commented on KAFKA-13255:
--
To replicate source topic in destin
[
https://issues.apache.org/jira/browse/KAFKA-13255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17407116#comment-17407116
]
Anamika Nadkarni commented on KAFKA-13255:
--
I keep getting HTTP error 403 when
Anamika Nadkarni created KAFKA-13255:
Summary: Mirrormaker config property config.properties.exclude is
not working as expected
Key: KAFKA-13255
URL: https://issues.apache.org/jira/browse/KAFKA-13255
rodesai commented on pull request #11286:
URL: https://github.com/apache/kafka/pull/11286#issuecomment-908931988
@guozhangwang
--
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 comme
rodesai opened a new pull request #11286:
URL: https://github.com/apache/kafka/pull/11286
Fix some review feedback and test flakiness from #11149
- adds units to metrics descriptions for total blocked time metrics
- fix producer metrics test checks
--
This is an automated message f
[
https://issues.apache.org/jira/browse/KAFKA-13248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17407070#comment-17407070
]
S. B. Hunter commented on KAFKA-13248:
--
I would love to. I already have changed the
hutchiko edited a comment on pull request #11283:
URL: https://github.com/apache/kafka/pull/11283#issuecomment-908804447
@ableegoldman I did not test against 3.0 just 2.7 and 2.8. I'll rebase onto
`trunk` as see how that goes.
--
This is an automated message from the Apache Git Service.
[
https://issues.apache.org/jira/browse/KAFKA-13249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Oliver Hutchison updated KAFKA-13249:
-
Affects Version/s: 3.0.0
> Checkpoints do not contain latest offsets on shutdown when us
hutchiko commented on pull request #11283:
URL: https://github.com/apache/kafka/pull/11283#issuecomment-908826996
Yeah I've rebased and verified the issue is there in `trunk` too.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitH
hutchiko commented on a change in pull request #11283:
URL: https://github.com/apache/kafka/pull/11283#discussion_r698898574
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java
##
@@ -565,7 +565,7 @@ public void closeCleanAndRecycle
hutchiko commented on pull request #11283:
URL: https://github.com/apache/kafka/pull/11283#issuecomment-908804447
@ableegoldman I did not test against 3.0 just 2.7 and 2.8. I'll rebase onto
trunk/3.0 as see how that goes.
--
This is an automated message from the Apache Git Service.
To re
[
https://issues.apache.org/jira/browse/KAFKA-13091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson updated KAFKA-13091:
Fix Version/s: (was: 3.0.1)
> Increment HW after shrinking ISR through AlterIsr
>
[
https://issues.apache.org/jira/browse/KAFKA-13254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson updated KAFKA-13254:
Issue Type: Bug (was: Improvement)
> Deadlock when expanding ISR
> --
Jason Gustafson created KAFKA-13254:
---
Summary: Deadlock when expanding ISR
Key: KAFKA-13254
URL: https://issues.apache.org/jira/browse/KAFKA-13254
Project: Kafka
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/KAFKA-13248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17406991#comment-17406991
]
A. Sophie Blee-Goldman commented on KAFKA-13248:
Nice find, thanks for t
gitlw opened a new pull request #11285:
URL: https://github.com/apache/kafka/pull/11285
This PR includes the following changes
1. Adding the type field to the LeaderAndIsr request as proposed in KIP-516
2. Letting the controller set the type of LeaderAndIsr requests to be either
FULL
ableegoldman commented on a change in pull request #11283:
URL: https://github.com/apache/kafka/pull/11283#discussion_r698868805
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java
##
@@ -565,7 +565,7 @@ public void closeCleanAndRec
[
https://issues.apache.org/jira/browse/KAFKA-13249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17406988#comment-17406988
]
A. Sophie Blee-Goldman commented on KAFKA-13249:
Thanks for the detailed
guozhangwang merged pull request #11149:
URL: https://github.com/apache/kafka/pull/11149
--
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-unsu
guozhangwang commented on a change in pull request #11149:
URL: https://github.com/apache/kafka/pull/11149#discussion_r698854001
##
File path:
clients/src/main/java/org/apache/kafka/clients/producer/internals/KafkaProducerMetrics.java
##
@@ -0,0 +1,123 @@
+/*
+ * Licensed to t
[
https://issues.apache.org/jira/browse/KAFKA-13249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman updated KAFKA-13249:
---
Affects Version/s: (was: 2.7.1)
> Checkpoints do not contain latest offs
ableegoldman commented on pull request #11283:
URL: https://github.com/apache/kafka/pull/11283#issuecomment-908748576
Hey @hutchiko , thanks for digging into this bug so thoroughly and providing
a patch! One quick question before I review -- does this only affect version
2.8 or below speci
junrao commented on a change in pull request #11255:
URL: https://github.com/apache/kafka/pull/11255#discussion_r698849242
##
File path: core/src/main/scala/kafka/controller/KafkaController.scala
##
@@ -628,9 +628,9 @@ class KafkaController(val config: KafkaConfig,
topic
kirktrue opened a new pull request #11284:
URL: https://github.com/apache/kafka/pull/11284
This task is to provide a concrete implementation of the interfaces defined
in KIP-255 to allow Kafka to connect to an OAuth/OIDC identity provider for
authentication and token retrieval. While KIP-2
splett2 commented on a change in pull request #11255:
URL: https://github.com/apache/kafka/pull/11255#discussion_r698693107
##
File path: core/src/main/scala/kafka/controller/KafkaController.scala
##
@@ -628,9 +628,9 @@ class KafkaController(val config: KafkaConfig,
topi
splett2 commented on a change in pull request #11255:
URL: https://github.com/apache/kafka/pull/11255#discussion_r698693107
##
File path: core/src/main/scala/kafka/controller/KafkaController.scala
##
@@ -628,9 +628,9 @@ class KafkaController(val config: KafkaConfig,
topi
junrao commented on a change in pull request #11255:
URL: https://github.com/apache/kafka/pull/11255#discussion_r698652526
##
File path: core/src/main/scala/kafka/controller/KafkaController.scala
##
@@ -628,9 +628,9 @@ class KafkaController(val config: KafkaConfig,
topic
[
https://issues.apache.org/jira/browse/KAFKA-13253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Urban resolved KAFKA-13253.
--
Resolution: Duplicate
Same issue as KAFKA-9747 - that one already has a fix under review
> Ka
junrao merged pull request #11060:
URL: https://github.com/apache/kafka/pull/11060
--
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..
jlprat commented on pull request #11228:
URL: https://github.com/apache/kafka/pull/11228#issuecomment-908365423
Test failure is related to https://issues.apache.org/jira/browse/KAFKA-8138
but not the same, as in this particular instance it seems more like a failure
in the test itself (topi
dajac commented on pull request #11073:
URL: https://github.com/apache/kafka/pull/11073#issuecomment-908364578
@lbradstreet @junrao Could you take a look at this one as you both reviewed
the original PR?
--
This is an automated message from the Apache Git Service.
To respond to the messa
[
https://issues.apache.org/jira/browse/KAFKA-13253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Dufour updated KAFKA-13253:
-
Description:
When not leader, DistributedHerder.reconfigureConnector() forwards the task
config
[
https://issues.apache.org/jira/browse/KAFKA-13253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Dufour updated KAFKA-13253:
-
Description:
When not leader, DistributedHerder.reconfigureConnector() forwards the task
config
[
https://issues.apache.org/jira/browse/KAFKA-13253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Dufour updated KAFKA-13253:
-
Description:
When not leader, DistributedHerder.reconfigureConnector() forwards the task
config
[
https://issues.apache.org/jira/browse/KAFKA-13253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Dufour updated KAFKA-13253:
-
Description:
When not leader, DistributedHerder.reconfigureConnector() forwards the task
config
David Dufour created KAFKA-13253:
Summary: Kafka Connect losing task (re)configuration when
connector name has special characters
Key: KAFKA-13253
URL: https://issues.apache.org/jira/browse/KAFKA-13253
[
https://issues.apache.org/jira/browse/KAFKA-13252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chaos closed KAFKA-13252.
-
duplicated
> ISR shrink to an error broker
> -
>
> Key: KAFKA-13252
>
[
https://issues.apache.org/jira/browse/KAFKA-13250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chaos closed KAFKA-13250.
-
duplicated
> 2.4.0
> -
>
> Key: KAFKA-13250
> URL: https://issues.apache.org/ji
vamossagar12 commented on pull request #11211:
URL: https://github.com/apache/kafka/pull/11211#issuecomment-908275012
@showuon , is there an existing integration test for Metered classes? I
tried to find one to add the relevant tests but couldnt't find one..
--
This is an automated messa
vamossagar12 commented on a change in pull request #11211:
URL: https://github.com/apache/kafka/pull/11211#discussion_r698417779
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowStore.java
##
@@ -217,6 +230,24 @@ public V fetch(final K
vamossagar12 commented on a change in pull request #11211:
URL: https://github.com/apache/kafka/pull/11211#discussion_r698416259
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/PersistentSessionStore.java
##
@@ -0,0 +1,28 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/KAFKA-13250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chaos resolved KAFKA-13250.
---
Resolution: Duplicate
> 2.4.0
> -
>
> Key: KAFKA-13250
> URL: https://is
[
https://issues.apache.org/jira/browse/KAFKA-13252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chaos resolved KAFKA-13252.
---
Resolution: Duplicate
> ISR shrink to an error broker
> -
>
> Ke
[
https://issues.apache.org/jira/browse/KAFKA-13251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chaos updated KAFKA-13251:
--
Summary: ISR shrink to an error broker (was: 2.4.0)
> ISR shrink to an error broker
> ---
chaos created KAFKA-13252:
-
Summary: ISR shrink to an error broker
Key: KAFKA-13252
URL: https://issues.apache.org/jira/browse/KAFKA-13252
Project: Kafka
Issue Type: Bug
Reporter: chaos
[
https://issues.apache.org/jira/browse/KAFKA-13251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chaos updated KAFKA-13251:
--
Description:
Disk error occurred in broker(=42),and then Shrinking ISR to itself.
so why Shrinking ISR to an
[
https://issues.apache.org/jira/browse/KAFKA-13251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chaos updated KAFKA-13251:
--
Component/s: core
> 2.4.0
> -
>
> Key: KAFKA-13251
> URL: https://issues.a
[
https://issues.apache.org/jira/browse/KAFKA-13251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chaos updated KAFKA-13251:
--
Description:
Disk error occurred in broker(=42),and then Shrinking ISR to itself.
so why Shrinking ISR to an
[
https://issues.apache.org/jira/browse/KAFKA-13251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chaos updated KAFKA-13251:
--
Description:
Disk error occurred in broker(=42),and then Shrinking ISR,
why Shrinking ISR to error broker ?
cadonna commented on a change in pull request #11149:
URL: https://github.com/apache/kafka/pull/11149#discussion_r698327147
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsProducer.java
##
@@ -178,12 +184,48 @@ public void resetProducer(
chaos created KAFKA-13251:
-
Summary: 2.4.0
Key: KAFKA-13251
URL: https://issues.apache.org/jira/browse/KAFKA-13251
Project: Kafka
Issue Type: Bug
Affects Versions: 2.4.0
Environment: lin
chaos created KAFKA-13250:
-
Summary: 2.4.0
Key: KAFKA-13250
URL: https://issues.apache.org/jira/browse/KAFKA-13250
Project: Kafka
Issue Type: Bug
Affects Versions: 2.4.0
Environment: lin
jlprat commented on pull request #11228:
URL: https://github.com/apache/kafka/pull/11228#issuecomment-908160013
@cadonna Applied your feedback as well, thanks for the comments. I also
realized the `AtomicBoolean` variables in the test could be final and added
that as well.
--
This is an
wangxianghu closed pull request #11210:
URL: https://github.com/apache/kafka/pull/11210
--
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-unsub
cadonna commented on a change in pull request #11228:
URL: https://github.com/apache/kafka/pull/11228#discussion_r698280849
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -495,9 +498,23 @@ private void replaceStreamThread(final Throwable
t
jlprat commented on a change in pull request #11228:
URL: https://github.com/apache/kafka/pull/11228#discussion_r698268258
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -509,7 +526,7 @@ private void handleStreamsUncaughtException(final Thr
[
https://issues.apache.org/jira/browse/KAFKA-12963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17406600#comment-17406600
]
Rasmus Helbig Hansen commented on KAFKA-12963:
--
[~ableegoldman] first of al
57 matches
Mail list logo
