vvcephei commented on a change in pull request #8882:
URL: https://github.com/apache/kafka/pull/8882#discussion_r441170578
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextImpl.java
##
@@ -235,7 +235,7 @@ public StateStore getSta
[
https://issues.apache.org/jira/browse/KAFKA-10151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17137956#comment-17137956
]
Sophie Blee-Goldman commented on KAFKA-10151:
-
Go for it. For some context,
ableegoldman commented on a change in pull request #8882:
URL: https://github.com/apache/kafka/pull/8882#discussion_r441171975
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextImpl.java
##
@@ -235,7 +235,7 @@ public StateStore ge
ableegoldman commented on a change in pull request #8882:
URL: https://github.com/apache/kafka/pull/8882#discussion_r441172228
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyTask.java
##
@@ -160,18 +162,21 @@ public void postCommit() {
vvcephei commented on a change in pull request #8882:
URL: https://github.com/apache/kafka/pull/8882#discussion_r441169327
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyTask.java
##
@@ -160,18 +162,21 @@ public void postCommit() {
vvcephei commented on a change in pull request #8882:
URL: https://github.com/apache/kafka/pull/8882#discussion_r441169062
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextImpl.java
##
@@ -235,7 +235,7 @@ public StateStore getSta
vvcephei commented on a change in pull request #8882:
URL: https://github.com/apache/kafka/pull/8882#discussion_r441169628
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/StreamsMetricsImpl.java
##
@@ -675,27 +670,6 @@ public static voi
ableegoldman commented on pull request #8853:
URL: https://github.com/apache/kafka/pull/8853#issuecomment-645040934
@rhauch is this ready to be merged?
This is an automated message from the Apache Git Service.
To respond to t
ableegoldman commented on a change in pull request #8882:
URL: https://github.com/apache/kafka/pull/8882#discussion_r441175266
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/StandbyTaskTest.java
##
@@ -366,6 +369,37 @@ public void shouldThrowO
ableegoldman commented on pull request #8856:
URL: https://github.com/apache/kafka/pull/8856#issuecomment-645043278
Failures were all due to known-flaky/completely broken
`ReassignPartitionsUnitTest.testModifyBrokerThrottles` (PR for that test is
still waiting to be merged -- https://issue
junrao commented on a change in pull request #8657:
URL: https://github.com/apache/kafka/pull/8657#discussion_r441177055
##
File path: core/src/main/scala/kafka/server/DelayedOperation.scala
##
@@ -100,40 +99,27 @@ abstract class DelayedOperation(override val delayMs: Long,
mumrah commented on pull request #8841:
URL: https://github.com/apache/kafka/pull/8841#issuecomment-645054474
Ran client system tests here, all passing except for one which looks flaky
http://confluent-kafka-branch-builder-system-test-results.s3-us-west-2.amazonaws.com/2020-06-16--0
guozhangwang merged pull request #8856:
URL: https://github.com/apache/kafka/pull/8856
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
guozhangwang commented on pull request #8856:
URL: https://github.com/apache/kafka/pull/8856#issuecomment-645062759
Cherry-picked to 2.6.
This is an automated message from the Apache Git Service.
To respond to the message, pl
Sophie Blee-Goldman created KAFKA-10177:
---
Summary: Replace/improve/remove Percentiles metric
Key: KAFKA-10177
URL: https://issues.apache.org/jira/browse/KAFKA-10177
Project: Kafka
Issue
mjsax commented on pull request #8871:
URL: https://github.com/apache/kafka/pull/8871#issuecomment-645090904
Retest this please.
This is an automated message from the Apache Git Service.
To respond to the message, please log
guozhangwang commented on a change in pull request #8876:
URL: https://github.com/apache/kafka/pull/8876#discussion_r441229437
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
##
@@ -273,13 +273,13 @@ public boolean isRunning()
ableegoldman commented on pull request #8861:
URL: https://github.com/apache/kafka/pull/8861#issuecomment-645097409
Rebased on trunk and removed the TaskManager MethodLength suppression as
well (yay 🥳 ), can you kick off tests again @mjsax ?
---
abbccdda commented on a change in pull request #8876:
URL: https://github.com/apache/kafka/pull/8876#discussion_r441237199
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StoreChangelogReader.java
##
@@ -564,8 +576,15 @@ private void restoreCha
[
https://issues.apache.org/jira/browse/KAFKA-10176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17138037#comment-17138037
]
Luke Chen commented on KAFKA-10176:
---
hi [~psmolinski] , I think it is the issue in con
mjsax commented on pull request #8883:
URL: https://github.com/apache/kafka/pull/8883#issuecomment-645113722
Retest this please.
This is an automated message from the Apache Git Service.
To respond to the message, please log
mjsax commented on pull request #8883:
URL: https://github.com/apache/kafka/pull/8883#issuecomment-645113814
Retest this please.
This is an automated message from the Apache Git Service.
To respond to the message, please log
mjsax commented on a change in pull request #8876:
URL: https://github.com/apache/kafka/pull/8876#discussion_r441249511
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StoreChangelogReader.java
##
@@ -564,8 +576,15 @@ private void restoreChange
mjsax commented on a change in pull request #8876:
URL: https://github.com/apache/kafka/pull/8876#discussion_r441249855
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StoreChangelogReader.java
##
@@ -564,8 +574,16 @@ private void restoreChange
mjsax commented on a change in pull request #8876:
URL: https://github.com/apache/kafka/pull/8876#discussion_r441252009
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StoreChangelogReader.java
##
@@ -564,8 +576,15 @@ private void restoreChange
mjsax commented on a change in pull request #8876:
URL: https://github.com/apache/kafka/pull/8876#discussion_r441252894
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StoreChangelogReader.java
##
@@ -564,8 +574,16 @@ private void restoreChange
[
https://issues.apache.org/jira/browse/KAFKA-8264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen reassigned KAFKA-8264:
Assignee: Luke Chen
> Flaky Test PlaintextConsumerTest#testLowMaxFetchSizeForRequestAndPartition
>
showuon opened a new pull request #8885:
URL: https://github.com/apache/kafka/pull/8885
This flaky test exists for a long time, and it happened more frequently
recently. In KAFKA-8264 and KAFKA-8460, it described the issue for this test is
that
> Timed out before consuming expected 270
[
https://issues.apache.org/jira/browse/KAFKA-5636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman updated KAFKA-5636:
---
Labels: needs-kip (was: )
> Add Sliding-Window support for Aggregations
> --
[
https://issues.apache.org/jira/browse/KAFKA-5636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman updated KAFKA-5636:
---
Priority: Major (was: Minor)
> Add Sliding-Window support for Aggregations
> ---
[
https://issues.apache.org/jira/browse/KAFKA-8460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen reassigned KAFKA-8460:
Assignee: Luke Chen
> Flaky Test PlaintextConsumerTest#testLowMaxFetchSizeForRequestAndPartition
vvcephei commented on pull request #8882:
URL: https://github.com/apache/kafka/pull/8882#issuecomment-645126850
Rebased on trunk.
This is an automated message from the Apache Git Service.
To respond to the message, please log
showuon commented on pull request #8885:
URL: https://github.com/apache/kafka/pull/8885#issuecomment-645126965
@nepal @mjsax @abbccdda , could you review this PR to fix flaky test?
Thanks.
This is an automated message from
[
https://issues.apache.org/jira/browse/KAFKA-10160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17138068#comment-17138068
]
sats commented on KAFKA-10160:
--
Yes, It is hard-coded
[here|[https://github.com/apache/kaf
[
https://issues.apache.org/jira/browse/KAFKA-10160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17138068#comment-17138068
]
sats edited comment on KAFKA-10160 at 6/17/20, 3:36 AM:
Yes, It
[
https://issues.apache.org/jira/browse/KAFKA-8672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantine Karantasis reassigned KAFKA-8672:
-
Assignee: Konstantine Karantasis
> RebalanceSourceConnectorsIntegrationT
[
https://issues.apache.org/jira/browse/KAFKA-8672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantine Karantasis resolved KAFKA-8672.
---
Resolution: Fixed
The tests have been fixed and reenabled with
[https://git
[
https://issues.apache.org/jira/browse/KAFKA-8672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantine Karantasis updated KAFKA-8672:
--
Fix Version/s: 2.5.1
2.4.2
2.6.0
[
https://issues.apache.org/jira/browse/KAFKA-8864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma resolved KAFKA-8864.
Resolution: Duplicate
Given the version, it looks like a duplicate of KAFKA-7709.
> Kafka Producer
[
https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-9891:
--
Assignee: Matthias J. Sax (was: Boyang Chen)
> Invalid state store content after task
mjsax opened a new pull request #8886:
URL: https://github.com/apache/kafka/pull/8886
A StandbyTask must wipe its local state if EOS is enabled and no local
checkpoint file is found.
I left debug statement in on purpose to people can verify the test locally
if they want.
- whe
[
https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17138091#comment-17138091
]
Matthias J. Sax commented on KAFKA-9891:
[~mateuszjadczyk] [~bchen225242]: I thin
[
https://issues.apache.org/jira/browse/KAFKA-10072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17138103#comment-17138103
]
sats commented on KAFKA-10072:
--
[~qq619618919],
kafka-console-consumer.sh --consumer-prope
[
https://issues.apache.org/jira/browse/KAFKA-9194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17138106#comment-17138106
]
sats commented on KAFKA-9194:
-
[~tomasz.szlek], Its been a long time, looks the doc is not fi
[
https://issues.apache.org/jira/browse/KAFKA-9220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17138112#comment-17138112
]
sats commented on KAFKA-9220:
-
Yes for 'bin/kafka-leader-election.sh' this can be taken as a
[
https://issues.apache.org/jira/browse/KAFKA-9220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17138112#comment-17138112
]
sats edited comment on KAFKA-9220 at 6/17/20, 5:23 AM:
---
Yes for 'bi
satishbellapu commented on pull request #8877:
URL: https://github.com/apache/kafka/pull/8877#issuecomment-645159729
@mjsax can this be merged to trunk ? or need PR for any specific release ?
This is an automated message from
chia7712 commented on a change in pull request #8657:
URL: https://github.com/apache/kafka/pull/8657#discussion_r441289689
##
File path:
core/src/test/scala/unit/kafka/coordinator/group/GroupCoordinatorConcurrencyTest.scala
##
@@ -307,8 +307,14 @@ class GroupCoordinatorConcurr
kkonstantine commented on pull request #8859:
URL: https://github.com/apache/kafka/pull/8859#issuecomment-645162774
Tests ran but didn't show up here.
https://builds.apache.org/job/kafka-pr-jdk8-scala2.12/2984/
`org.apache.kafka.streams.integration.StoreUpgradeIntegrationTest.shouldM
[
https://issues.apache.org/jira/browse/KAFKA-10151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17138129#comment-17138129
]
Chia-Ping Tsai commented on KAFKA-10151:
[~ableegoldman] I feel you have resolve
[
https://issues.apache.org/jira/browse/KAFKA-10136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17138130#comment-17138130
]
jiamei xie commented on KAFKA-10136:
[~chia7712] Hi, should a KIP be created for thi
[
https://issues.apache.org/jira/browse/KAFKA-10136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17138150#comment-17138150
]
jiamei xie commented on KAFKA-10136:
[~chia7712] ConsumerPerformance for Kafka 0.9.0
[
https://issues.apache.org/jira/browse/KAFKA-10136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17138153#comment-17138153
]
Chia-Ping Tsai commented on KAFKA-10136:
{quote}
should a KIP be created for thi
[
https://issues.apache.org/jira/browse/KAFKA-10062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17136395#comment-17136395
]
William Bottrell commented on KAFKA-10062:
--
[~mjsax] yes, this helps, thank you
[
https://issues.apache.org/jira/browse/KAFKA-9220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17136402#comment-17136402
]
sats commented on KAFKA-9220:
-
This requires KIP.
The tool "kafka-preferred-replica-election
tombentley commented on pull request #8839:
URL: https://github.com/apache/kafka/pull/8839#issuecomment-644606253
Thanks @kkonstantine!
This is an automated message from the Apache Git Service.
To respond to the message, plea
[
https://issues.apache.org/jira/browse/KAFKA-10062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17136432#comment-17136432
]
Piotr Smolinski commented on KAFKA-10062:
-
The motivation is to use the same sou
dajac commented on a change in pull request #8768:
URL: https://github.com/apache/kafka/pull/8768#discussion_r440142597
##
File path: core/src/test/scala/unit/kafka/network/ConnectionQuotasTest.scala
##
@@ -302,21 +312,295 @@ class ConnectionQuotasTest {
}
// all
dajac commented on a change in pull request #8683:
URL: https://github.com/apache/kafka/pull/8683#discussion_r440658796
##
File path: clients/src/main/java/org/apache/kafka/clients/NetworkClient.java
##
@@ -678,7 +696,11 @@ public Node leastLoadedNode(long now) {
}
[
https://issues.apache.org/jira/browse/KAFKA-10062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17136446#comment-17136446
]
Piotr Smolinski commented on KAFKA-10062:
-
BTW, the SystemTime class might also
Wang Ge created KAFKA-10171:
---
Summary: SslTransportLayerTest.testServerCipherDynamicUpdate
failed for tlsv1.3
Key: KAFKA-10171
URL: https://issues.apache.org/jira/browse/KAFKA-10171
Project: Kafka
Viktor Utkin created KAFKA-10172:
Summary: [Kafka connect] connectors, tasks metrics doubled
Key: KAFKA-10172
URL: https://issues.apache.org/jira/browse/KAFKA-10172
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-10172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Viktor Utkin updated KAFKA-10172:
-
Description:
After re-balance of connect cluster (4 nodes in total) we noticed that metrics
* k
[
https://issues.apache.org/jira/browse/KAFKA-9332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17136585#comment-17136585
]
qianrui commented on KAFKA-9332:
This problem has been solved
> change how to get joinGr
[
https://issues.apache.org/jira/browse/KAFKA-9332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17136586#comment-17136586
]
qianrui commented on KAFKA-9332:
[This problem has been solved
https://github.com/apach
cadonna commented on a change in pull request #8876:
URL: https://github.com/apache/kafka/pull/8876#discussion_r440801026
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
##
@@ -369,6 +369,7 @@ public static StreamThread create
tombentley opened a new pull request #8878:
URL: https://github.com/apache/kafka/pull/8878
Currently the docs have HTML ids for each config key. That doesn't work
correctly for config keys like bootstrap.servers which occur across
producer, consumer, admin configs: We generate duplicat
tombentley commented on pull request #8878:
URL: https://github.com/apache/kafka/pull/8878#issuecomment-644772529
@mimaison I know you added the per-config-key anchors. Please could you take
a look at attempt to disambiguate the current situation with duplicated ids.
-
Karsten Schnitter created KAFKA-10173:
-
Summary: BufferUnderflowException during Kafka Streams Upgrade
Key: KAFKA-10173
URL: https://issues.apache.org/jira/browse/KAFKA-10173
Project: Kafka
abbccdda commented on a change in pull request #8876:
URL: https://github.com/apache/kafka/pull/8876#discussion_r440545343
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StoreChangelogReader.java
##
@@ -199,12 +204,19 @@ int bufferedLimitIndex
guozhangwang commented on a change in pull request #8876:
URL: https://github.com/apache/kafka/pull/8876#discussion_r440941715
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
##
@@ -369,6 +369,7 @@ public static StreamThread c
[
https://issues.apache.org/jira/browse/KAFKA-10171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wang Ge updated KAFKA-10171:
Description: (was:
`SslTransportLayerTest.testServerCipherDynamicUpdate` in ce-kafka is failing
for `
[
https://issues.apache.org/jira/browse/KAFKA-10171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wang Ge updated KAFKA-10171:
Summary: Please ignore (was:
SslTransportLayerTest.testServerCipherDynamicUpdate failed for tlsv1.3)
> P
[
https://issues.apache.org/jira/browse/KAFKA-10171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Manikumar resolved KAFKA-10171.
---
Resolution: Invalid
> Please ignore
> -
>
> Key: KAFKA-10171
>
[
https://issues.apache.org/jira/browse/KAFKA-8770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17136786#comment-17136786
]
Richard Yu commented on KAFKA-8770:
---
[~gyammine] Thanks for the comment! I apologize fo
[
https://issues.apache.org/jira/browse/KAFKA-8770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17136786#comment-17136786
]
Richard Yu edited comment on KAFKA-8770 at 6/16/20, 4:25 PM:
-
[
https://issues.apache.org/jira/browse/KAFKA-9220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17136787#comment-17136787
]
Matthias J. Sax commented on KAFKA-9220:
I am not familiar with the details. Howe
andrewegel opened a new pull request #8879:
URL: https://github.com/apache/kafka/pull/8879
Newer version of ducktape that updates some dependencies and adds some
features. You can see that diff here:
https://github.com/confluentinc/ducktape/compare/v0.7.7...v0.7.8
-
hachikuji commented on a change in pull request #8841:
URL: https://github.com/apache/kafka/pull/8841#discussion_r440984705
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java
##
@@ -675,36 +676,41 @@ private ListOffsetResult
fetchOffs
[
https://issues.apache.org/jira/browse/KAFKA-10131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vinoth Chandar updated KAFKA-10131:
---
Description:
Get the ducktape tests working without the --zookeeper flag (except for scram).
[
https://issues.apache.org/jira/browse/KAFKA-10131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vinoth Chandar updated KAFKA-10131:
---
Description:
Get the ducktape tests working without the --zookeeper flag (except for scram).
[
https://issues.apache.org/jira/browse/KAFKA-10151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17136822#comment-17136822
]
Sophie Blee-Goldman commented on KAFKA-10151:
-
[https://builds.apache.org/jo
Vinoth Chandar created KAFKA-10174:
--
Summary: Prefer --bootstrap-server ducktape tests using
kafka_configs.sh
Key: KAFKA-10174
URL: https://issues.apache.org/jira/browse/KAFKA-10174
Project: Kafka
mumrah commented on a change in pull request #8841:
URL: https://github.com/apache/kafka/pull/8841#discussion_r441007131
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java
##
@@ -675,36 +676,41 @@ private ListOffsetResult
fetchOffsets
guozhangwang opened a new pull request #8880:
URL: https://github.com/apache/kafka/pull/8880
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgrad
ConcurrencyPractitioner opened a new pull request #8881:
URL: https://github.com/apache/kafka/pull/8881
This is a continuation of the previous PR #8254, and will move to implement
emit on change support more extensively and cover most basic KTable operations.
-
guozhangwang commented on pull request #8856:
URL: https://github.com/apache/kafka/pull/8856#issuecomment-644897139
test this
This is an automated message from the Apache Git Service.
To respond to the message, please log on
guozhangwang commented on pull request #8856:
URL: https://github.com/apache/kafka/pull/8856#issuecomment-644897444
test this
This is an automated message from the Apache Git Service.
To respond to the message, please log on
guozhangwang commented on pull request #8646:
URL: https://github.com/apache/kafka/pull/8646#issuecomment-644902264
Cherry-picked to 2.6.
This is an automated message from the Apache Git Service.
To respond to the message, pl
guozhangwang merged pull request #8646:
URL: https://github.com/apache/kafka/pull/8646
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-10173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10173:
-
Priority: Blocker (was: Major)
> BufferUnderflowException during Kafka Streams Upgrade
> --
[
https://issues.apache.org/jira/browse/KAFKA-10173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10173:
-
Fix Version/s: 2.5.1
> BufferUnderflowException during Kafka Streams Upgrade
> -
[
https://issues.apache.org/jira/browse/KAFKA-10171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wang Ge closed KAFKA-10171.
---
> Please ignore
> -
>
> Key: KAFKA-10171
> URL: https://issues.apach
[
https://issues.apache.org/jira/browse/KAFKA-10173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17137089#comment-17137089
]
John Roesler commented on KAFKA-10173:
--
Thanks for the report [~karsten.schnitter]
guozhangwang merged pull request #8880:
URL: https://github.com/apache/kafka/pull/8880
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
ConcurrencyPractitioner commented on pull request #8881:
URL: https://github.com/apache/kafka/pull/8881#issuecomment-644904629
@vvcephei Just wanted to get your opinion on this. When adding
emit-on-change support to ```KTableFilter```, I found that the old value was
already available for u
guozhangwang commented on pull request #8880:
URL: https://github.com/apache/kafka/pull/8880#issuecomment-644905498
Cherry-picked to 2.6.
This is an automated message from the Apache Git Service.
To respond to the message, pl
[
https://issues.apache.org/jira/browse/KAFKA-10173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler reassigned KAFKA-10173:
Assignee: John Roesler
> BufferUnderflowException during Kafka Streams Upgrade
>
guozhangwang commented on a change in pull request #8856:
URL: https://github.com/apache/kafka/pull/8856#discussion_r441026485
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java
##
@@ -502,56 +494,24 @@ public void closeAndRecycleS
Vikas Singh created KAFKA-10175:
---
Summary: MetadataCache::getCluster returns null for offline
replicas
Key: KAFKA-10175
URL: https://issues.apache.org/jira/browse/KAFKA-10175
Project: Kafka
Is
1 - 100 of 147 matches
Mail list logo
