[
https://issues.apache.org/jira/browse/KAFKA-12994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17401493#comment-17401493
]
Christo Lolov commented on KAFKA-12994:
---
Great, thanks for the reply! [~officialan
showuon opened a new pull request #11234:
URL: https://github.com/apache/kafka/pull/11234
*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-10038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17401490#comment-17401490
]
Yanwen Lin commented on KAFKA-10038:
Hi [~apompeev], are you still working on this o
[
https://issues.apache.org/jira/browse/KAFKA-12766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tomer Wizman reassigned KAFKA-12766:
Assignee: Tomer Wizman
> Consider Disabling WAL-related Options in RocksDB
>
kkonstantine merged pull request #11232:
URL: https://github.com/apache/kafka/pull/11232
--
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
rodesai commented on a change in pull request #11149:
URL: https://github.com/apache/kafka/pull/11149#discussion_r691775378
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamsProducerTest.java
##
@@ -1121,4 +1125,60 @@ public void
shouldRe
rodesai commented on a change in pull request #11149:
URL: https://github.com/apache/kafka/pull/11149#discussion_r691768579
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsThreadTotalBlockedTime.java
##
@@ -0,0 +1,59 @@
+/*
+ * Licensed
rodesai commented on a change in pull request #11149:
URL: https://github.com/apache/kafka/pull/11149#discussion_r691767731
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/StreamsMetricsImpl.java
##
@@ -200,6 +201,30 @@ public RocksDBMe
leiminghany created KAFKA-13218:
---
Summary: kafka deleted unexpired message unexpectedly
Key: KAFKA-13218
URL: https://issues.apache.org/jira/browse/KAFKA-13218
Project: Kafka
Issue Type: Bug
rhauch commented on a change in pull request #11232:
URL: https://github.com/apache/kafka/pull/11232#discussion_r691743181
##
File path: LICENSE-binary
##
@@ -208,52 +208,52 @@ License Version 2.0:
audience-annotations-0.5.0
commons-cli-1.4
commons-lang3-3.8.1
-jackson-annot
mjsax opened a new pull request #11233:
URL: https://github.com/apache/kafka/pull/11233
KAFKA-10847 improves stream-stream left/outer joins to avoid spurious
left/outer join results. However, it introduces regression bug
KAFKA-13216.
This PR disables KAFKA-10847 by partially rol
[
https://issues.apache.org/jira/browse/KAFKA-13217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17401433#comment-17401433
]
A. Sophie Blee-Goldman commented on KAFKA-13217:
This is all the more im
A. Sophie Blee-Goldman created KAFKA-13217:
--
Summary: Reconsider skipping the LeaveGroup on close() or add an
overload that does so
Key: KAFKA-13217
URL: https://issues.apache.org/jira/browse/KAFKA-13217
[
https://issues.apache.org/jira/browse/KAFKA-13204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman updated KAFKA-13204:
---
Fix Version/s: 3.1.0
> wrong assignor selected if the assignor name is ident
kkonstantine edited a comment on pull request #11232:
URL: https://github.com/apache/kafka/pull/11232#issuecomment-901540065
Hey @rhauch. I replied to the other comments inline. Regarding your
question:
> Do you plan to backport this, and if so to what branches?
This was ran
kkonstantine edited a comment on pull request #11232:
URL: https://github.com/apache/kafka/pull/11232#issuecomment-901540065
Hey @rhauch. I replied to the other comments inline. Regarding your
question:
> Do you plan to backport this, and if so to what branches?
This was ran
kkonstantine commented on pull request #11232:
URL: https://github.com/apache/kafka/pull/11232#issuecomment-901540065
Hey @rhauch. I replied to the other comments inline. Regarding your
question:
> Do you plan to backport this, and if so to what branches?
This was run against
kkonstantine commented on a change in pull request #11232:
URL: https://github.com/apache/kafka/pull/11232#discussion_r691710928
##
File path: LICENSE-binary
##
@@ -208,52 +208,52 @@ License Version 2.0:
audience-annotations-0.5.0
commons-cli-1.4
commons-lang3-3.8.1
-jackson
kkonstantine commented on a change in pull request #11232:
URL: https://github.com/apache/kafka/pull/11232#discussion_r691710720
##
File path: LICENSE-binary
##
@@ -208,52 +208,52 @@ License Version 2.0:
audience-annotations-0.5.0
commons-cli-1.4
commons-lang3-3.8.1
-jackson
kkonstantine commented on a change in pull request #11232:
URL: https://github.com/apache/kafka/pull/11232#discussion_r691710309
##
File path: LICENSE-binary
##
@@ -208,52 +208,52 @@ License Version 2.0:
audience-annotations-0.5.0
commons-cli-1.4
commons-lang3-3.8.1
-jackson
kkonstantine commented on a change in pull request #11232:
URL: https://github.com/apache/kafka/pull/11232#discussion_r691710309
##
File path: LICENSE-binary
##
@@ -208,52 +208,52 @@ License Version 2.0:
audience-annotations-0.5.0
commons-cli-1.4
commons-lang3-3.8.1
-jackson
rhauch commented on pull request #11232:
URL: https://github.com/apache/kafka/pull/11232#issuecomment-901534553
Do you plan to backport this, and if so to what branches?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
rhauch commented on a change in pull request #11232:
URL: https://github.com/apache/kafka/pull/11232#discussion_r691705388
##
File path: LICENSE-binary
##
@@ -208,52 +208,52 @@ License Version 2.0:
audience-annotations-0.5.0
commons-cli-1.4
commons-lang3-3.8.1
-jackson-annot
hachikuji commented on a change in pull request #11225:
URL: https://github.com/apache/kafka/pull/11225#discussion_r691706079
##
File path: core/src/main/scala/kafka/server/ReplicaManager.scala
##
@@ -1436,17 +1438,15 @@ class ReplicaManager(val config: KafkaConfig,
hachikuji commented on a change in pull request #11225:
URL: https://github.com/apache/kafka/pull/11225#discussion_r691703790
##
File path: core/src/main/scala/kafka/server/ReplicaManager.scala
##
@@ -1436,17 +1438,15 @@ class ReplicaManager(val config: KafkaConfig,
[
https://issues.apache.org/jira/browse/KAFKA-13216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-13216:
Fix Version/s: 3.0.0
> Streams left/outer joins cause new internal changelog topic to grow
[
https://issues.apache.org/jira/browse/KAFKA-12994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17401410#comment-17401410
]
A. Sophie Blee-Goldman commented on KAFKA-12994:
Hey guys, thanks for pi
kkonstantine opened a new pull request #11232:
URL: https://github.com/apache/kafka/pull/11232
One new dependency was missing a license entry
[jline](https://github.com/jline/jline3)
The rest of the changes correspond to updated package versions.
No functional changes in the code
hachikuji commented on a change in pull request #11229:
URL: https://github.com/apache/kafka/pull/11229#discussion_r691694091
##
File path: core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala
##
@@ -1391,78 +1392,92 @@ class GroupCoordinator(val brokerId: Int,
ableegoldman merged pull request #11217:
URL: https://github.com/apache/kafka/pull/11217
--
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
ableegoldman commented on pull request #11217:
URL: https://github.com/apache/kafka/pull/11217#issuecomment-901516021
Merged to trunk
--
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
ableegoldman commented on pull request #11217:
URL: https://github.com/apache/kafka/pull/11217#issuecomment-901515775
Test failure is unrelated:
`StoreQueryIntegrationTest.shouldQueryStoresAfterAddingAndRemovingStreamThread`
--
This is an automated message from the Apache Git Service.
To
[
https://issues.apache.org/jira/browse/KAFKA-12550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17401408#comment-17401408
]
A. Sophie Blee-Goldman commented on KAFKA-12550:
Yeah, the RESTORING wou
ableegoldman merged pull request #11068:
URL: https://github.com/apache/kafka/pull/11068
--
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
ableegoldman commented on a change in pull request #11124:
URL: https://github.com/apache/kafka/pull/11124#discussion_r691646220
##
File path:
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregateTest.java
##
@@ -100,17 +99,78 @@
Sergio Peña created KAFKA-13216:
---
Summary: Streams left/outer joins cause new internal changelog
topic to grow unbounded
Key: KAFKA-13216
URL: https://issues.apache.org/jira/browse/KAFKA-13216
Project:
guozhangwang commented on a change in pull request #11149:
URL: https://github.com/apache/kafka/pull/11149#discussion_r691613659
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamsProducerTest.java
##
@@ -1121,4 +1125,60 @@ public void
sho
[
https://issues.apache.org/jira/browse/KAFKA-13152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17401318#comment-17401318
]
Guozhang Wang commented on KAFKA-13152:
---
I think it's a good idea to continue our
hachikuji commented on a change in pull request #11231:
URL: https://github.com/apache/kafka/pull/11231#discussion_r691522435
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java
##
@@ -476,7 +476,6 @@ boolean joinGroupIfNeed
hachikuji commented on a change in pull request #11231:
URL: https://github.com/apache/kafka/pull/11231#discussion_r691522435
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java
##
@@ -476,7 +476,6 @@ boolean joinGroupIfNeed
[
https://issues.apache.org/jira/browse/KAFKA-13152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17401302#comment-17401302
]
Matthias J. Sax commented on KAFKA-13152:
-
[~guozhang] – your proposal to only p
hachikuji opened a new pull request #11231:
URL: https://github.com/apache/kafka/pull/11231
Currently the consumer will reset state after any retriable error during a
rebalance. This includes coordinator disconnects as well as coordinator
changes. The impact of this is that rebalances get
lbradstreet commented on a change in pull request #11230:
URL: https://github.com/apache/kafka/pull/11230#discussion_r691487441
##
File path: core/src/main/scala/kafka/server/ConfigHandler.scala
##
@@ -66,8 +66,13 @@ class TopicConfigHandler(private val logManager: LogManager,
[
https://issues.apache.org/jira/browse/KAFKA-12713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17401270#comment-17401270
]
Kai Huang commented on KAFKA-12713:
---
[~ijuma] Thanks for the pointer. I've bumped up t
[
https://issues.apache.org/jira/browse/KAFKA-13214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson reassigned KAFKA-13214:
---
Assignee: Jason Gustafson
> Consumer should not reset group state after disconnect
jsancio commented on a change in pull request #11216:
URL: https://github.com/apache/kafka/pull/11216#discussion_r690620725
##
File path: core/src/main/scala/kafka/server/BrokerServer.scala
##
@@ -113,7 +113,7 @@ class BrokerServer(
var dynamicConfigHandlers: Map[String, C
junrao merged pull request #11216:
URL: https://github.com/apache/kafka/pull/11216
--
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..
yangdaixai closed pull request #11185:
URL: https://github.com/apache/kafka/pull/11185
--
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-unsubs
dajac commented on pull request #11073:
URL: https://github.com/apache/kafka/pull/11073#issuecomment-901015825
@jolshan is it something that we must add to 2.8.1?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
UR
jomach commented on pull request #9493:
URL: https://github.com/apache/kafka/pull/9493#issuecomment-901121979
seems to be some conflicts. @joshuagrisham can you fix them please ?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
rajinisivaram commented on pull request #11221:
URL: https://github.com/apache/kafka/pull/11221#issuecomment-900433010
--
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 un
showuon commented on a change in pull request #11227:
URL: https://github.com/apache/kafka/pull/11227#discussion_r691052026
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractRocksDBSegmentedBytesStore.java
##
@@ -124,8 +124,8 @@
fi
vvcephei commented on a change in pull request #11213:
URL: https://github.com/apache/kafka/pull/11213#discussion_r690642563
##
File path:
streams/src/test/java/org/apache/kafka/test/MockInternalNewProcessorContext.java
##
@@ -0,0 +1,172 @@
+/*
+ * Licensed to the Apache Softw
jlprat commented on pull request #11228:
URL: https://github.com/apache/kafka/pull/11228#issuecomment-901030641
--
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 unsubscri
Justinwins commented on a change in pull request #10652:
URL: https://github.com/apache/kafka/pull/10652#discussion_r684042834
##
File path: docs/upgrade.html
##
@@ -83,7 +83,13 @@ Notable changes in 3
understood by brokers or version 2.5 or higher, so you must upgrade
dajac commented on a change in pull request #11225:
URL: https://github.com/apache/kafka/pull/11225#discussion_r691041467
##
File path: core/src/main/scala/kafka/server/ReplicaManager.scala
##
@@ -1436,17 +1438,15 @@ class ReplicaManager(val config: KafkaConfig,
le
dajac commented on pull request #11221:
URL: https://github.com/apache/kafka/pull/11221#issuecomment-900541736
@rajinisivaram Should we also add it to 2.8 branch?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
UR
junrao commented on a change in pull request #11216:
URL: https://github.com/apache/kafka/pull/11216#discussion_r690492221
##
File path: core/src/main/scala/kafka/server/BrokerServer.scala
##
@@ -113,7 +113,7 @@ class BrokerServer(
var dynamicConfigHandlers: Map[String, Co
guozhangwang merged pull request #11184:
URL: https://github.com/apache/kafka/pull/11184
--
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
lbradstreet commented on a change in pull request #11230:
URL: https://github.com/apache/kafka/pull/11230#discussion_r691368381
##
File path: core/src/main/scala/kafka/server/ConfigHandler.scala
##
@@ -66,8 +66,13 @@ class TopicConfigHandler(private val logManager: LogManager,
guozhangwang commented on a change in pull request #11184:
URL: https://github.com/apache/kafka/pull/11184#discussion_r690792216
##
File path: docs/streams/upgrade-guide.html
##
@@ -52,6 +52,15 @@ Upgrade Guide and API Changes
restart all new ({{fullDotVersion}}) appl
rajinisivaram merged pull request #11221:
URL: https://github.com/apache/kafka/pull/11221
--
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-uns
jolshan commented on pull request #11073:
URL: https://github.com/apache/kafka/pull/11073#issuecomment-901220052
Ah yes. I had a feeling I still had a pr open for this. I think I can clean
it up a bit and it should be ready for review by tomorrow.
--
This is an automated message from the
guozhangwang commented on pull request #11184:
URL: https://github.com/apache/kafka/pull/11184#issuecomment-900710127
Cherry-picked to 3.0 to be included in the 3.0 docs cc @kkonstantine
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
cadonna commented on a change in pull request #11149:
URL: https://github.com/apache/kafka/pull/11149#discussion_r691098389
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsThreadTotalBlockedTime.java
##
@@ -0,0 +1,59 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/KAFKA-13215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantine Karantasis updated KAFKA-13215:
---
Description:
Integration test {{test
org.apache.kafka.streams.integration.T
omkreddy merged pull request #11224:
URL: https://github.com/apache/kafka/pull/11224
--
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
dajac commented on a change in pull request #11170:
URL: https://github.com/apache/kafka/pull/11170#discussion_r690993461
##
File path: core/src/main/scala/kafka/server/ReplicaManager.scala
##
@@ -1755,6 +1765,78 @@ class ReplicaManager(val config: KafkaConfig,
partitionsT
[
https://issues.apache.org/jira/browse/KAFKA-13215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantine Karantasis reassigned KAFKA-13215:
--
Assignee: (was: Walker Carlson)
> Flaky test
> org.apache.kafka.
Konstantine Karantasis created KAFKA-13215:
--
Summary: Flaky test
org.apache.kafka.streams.integration.TaskMetadataIntegrationTest.shouldReportCorrectEndOffsetInformation
Key: KAFKA-13215
URL: https://issu
[
https://issues.apache.org/jira/browse/KAFKA-13215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantine Karantasis updated KAFKA-13215:
---
Reporter: Konstantine Karantasis (was: Bruno Cadonna)
> Flaky test
> org.a
rondagostino commented on pull request #6233:
URL: https://github.com/apache/kafka/pull/6233#issuecomment-900456795
--
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 unsub
jolshan commented on a change in pull request #11170:
URL: https://github.com/apache/kafka/pull/11170#discussion_r691366479
##
File path: core/src/main/scala/kafka/server/ReplicaManager.scala
##
@@ -1755,6 +1765,78 @@ class ReplicaManager(val config: KafkaConfig,
partition
venkatesh010 commented on pull request #6233:
URL: https://github.com/apache/kafka/pull/6233#issuecomment-900514731
--
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 unsub
dajac commented on a change in pull request #11173:
URL: https://github.com/apache/kafka/pull/11173#discussion_r691375264
##
File path: core/src/main/scala/kafka/tools/GetOffsetShell.scala
##
@@ -224,9 +227,14 @@ object GetOffsetShell {
/**
* Return the partition infos.
dajac commented on a change in pull request #11230:
URL: https://github.com/apache/kafka/pull/11230#discussion_r691396770
##
File path: core/src/main/scala/kafka/server/ConfigHandler.scala
##
@@ -66,8 +66,13 @@ class TopicConfigHandler(private val logManager: LogManager,
kafka
Jason Gustafson created KAFKA-13214:
---
Summary: Consumer should not reset group state after disconnect
Key: KAFKA-13214
URL: https://issues.apache.org/jira/browse/KAFKA-13214
Project: Kafka
dajac commented on a change in pull request #11230:
URL: https://github.com/apache/kafka/pull/11230#discussion_r691400434
##
File path: core/src/main/scala/kafka/server/ConfigHandler.scala
##
@@ -66,8 +66,13 @@ class TopicConfigHandler(private val logManager: LogManager,
kafka
dajac commented on a change in pull request #11230:
URL: https://github.com/apache/kafka/pull/11230#discussion_r691396770
##
File path: core/src/main/scala/kafka/server/ConfigHandler.scala
##
@@ -66,8 +66,13 @@ class TopicConfigHandler(private val logManager: LogManager,
kafka
dajac commented on a change in pull request #11173:
URL: https://github.com/apache/kafka/pull/11173#discussion_r691375264
##
File path: core/src/main/scala/kafka/tools/GetOffsetShell.scala
##
@@ -224,9 +227,14 @@ object GetOffsetShell {
/**
* Return the partition infos.
jolshan commented on pull request #11073:
URL: https://github.com/apache/kafka/pull/11073#issuecomment-901220052
Ah yes. I had a feeling I still had a pr open for this. I think I can clean
it up a bit and it should be ready for review by tomorrow.
--
This is an automated message from the
lbradstreet commented on a change in pull request #11230:
URL: https://github.com/apache/kafka/pull/11230#discussion_r691368381
##
File path: core/src/main/scala/kafka/server/ConfigHandler.scala
##
@@ -66,8 +66,13 @@ class TopicConfigHandler(private val logManager: LogManager,
jolshan commented on a change in pull request #11170:
URL: https://github.com/apache/kafka/pull/11170#discussion_r691366479
##
File path: core/src/main/scala/kafka/server/ReplicaManager.scala
##
@@ -1755,6 +1765,78 @@ class ReplicaManager(val config: KafkaConfig,
partition
dajac opened a new pull request #11230:
URL: https://github.com/apache/kafka/pull/11230
When `compact` is removed from the `cleanup.policy` of a topic, the
compactions of that topic should be aborted.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and i
cadonna commented on a change in pull request #11149:
URL: https://github.com/apache/kafka/pull/11149#discussion_r691098389
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsThreadTotalBlockedTime.java
##
@@ -0,0 +1,59 @@
+/*
+ * Licensed
jlprat commented on pull request #11228:
URL: https://github.com/apache/kafka/pull/11228#issuecomment-901123276
Test failure was https://issues.apache.org/jira/browse/KAFKA-8529 which was
apparently resolved. I reopened the issue.
I rebased this PR to the trunk of a couple of hours ago.
jomach commented on pull request #9493:
URL: https://github.com/apache/kafka/pull/9493#issuecomment-901121979
seems to be some conflicts. @joshuagrisham can you fix them please ?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
[
https://issues.apache.org/jira/browse/KAFKA-8529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17401062#comment-17401062
]
Josep Prat commented on KAFKA-8529:
---
I'll reopen this issue as it happened again on a f
[
https://issues.apache.org/jira/browse/KAFKA-8529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Josep Prat reopened KAFKA-8529:
---
> Flakey test ConsumerBounceTest#testCloseDuringRebalance
> -
[
https://issues.apache.org/jira/browse/KAFKA-8295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17401043#comment-17401043
]
Sagar Rao commented on KAFKA-8295:
--
I see. Is there a KIP for list append types for wind
[
https://issues.apache.org/jira/browse/KAFKA-13152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17401034#comment-17401034
]
Sagar Rao commented on KAFKA-13152:
---
[~mjsax], [~guozhang] I had a slightly different
Patrik Kleindl created KAFKA-13213:
--
Summary: StreamThread: State transition from PARTITIONS_ASSIGNED
to PARTITIONS_ASSIGNED
Key: KAFKA-13213
URL: https://issues.apache.org/jira/browse/KAFKA-13213
Pr
dajac opened a new pull request #11229:
URL: https://github.com/apache/kafka/pull/11229
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgrade not
jlprat commented on pull request #11228:
URL: https://github.com/apache/kafka/pull/11228#issuecomment-901030641
cc. @guozhangwang Feel free to review this PR and let me know if this is
what you had in mind with https://issues.apache.org/jira/browse/KAFKA-12887
--
This is an automated mes
jlprat opened a new pull request #11228:
URL: https://github.com/apache/kafka/pull/11228
Instead of letting all `RuntimeException`s go through and be processed by
the uncaught exception handler, `IllegalStateException` and
`IllegalArgumentException` are not passed through and fail fast
dajac commented on pull request #11073:
URL: https://github.com/apache/kafka/pull/11073#issuecomment-901015825
@jolshan is it something that we must add to 2.8.1?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
UR
showuon commented on a change in pull request #11227:
URL: https://github.com/apache/kafka/pull/11227#discussion_r691055719
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/SegmentIterator.java
##
@@ -74,7 +74,7 @@ public boolean hasNext() {
showuon commented on a change in pull request #11227:
URL: https://github.com/apache/kafka/pull/11227#discussion_r691053240
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/CachingWindowStore.java
##
@@ -573,12 +573,14 @@ private void setCacheKeyRan
showuon commented on a change in pull request #11227:
URL: https://github.com/apache/kafka/pull/11227#discussion_r691052026
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractRocksDBSegmentedBytesStore.java
##
@@ -124,8 +124,8 @@
fi
showuon opened a new pull request #11227:
URL: https://github.com/apache/kafka/pull/11227
Add support for infinite range query for WindowStore.
Story JIRA: https://issues.apache.org/jira/browse/KAFKA-13210
### Committer Checklist (excluded from commit message)
- [ ] Verify d
1 - 100 of 116 matches
Mail list logo