[
https://issues.apache.org/jira/browse/KAFKA-10038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17174125#comment-17174125
]
Luke Chen commented on KAFKA-10038:
---
This might need a KIP. Working on that.
> Consum
[
https://issues.apache.org/jira/browse/KAFKA-9839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Viktor Somogyi-Vass updated KAFKA-9839:
---
Affects Version/s: 2.2.1
Detected this issue in a customer's environment, I've backpo
viktorsomogyi opened a new pull request #9150:
URL: https://github.com/apache/kafka/pull/9150
This is a backport of #8509.
A broker throws IllegalStateException if the broker epoch in the
LeaderAndIsr/UpdateMetadataRequest/StopReplicaRequest is larger than its
current broker epoch.
[
https://issues.apache.org/jira/browse/KAFKA-10377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17174157#comment-17174157
]
Tom Bentley commented on KAFKA-10377:
-
This is used to generate the [protocol
docum
viktorsomogyi commented on pull request #9150:
URL: https://github.com/apache/kafka/pull/9150#issuecomment-671213384
@apovzner @hachikuji would you please review this backport?
And while I'm at it, I can backport these onto the 2.3 and 2.4 lines as well.
showuon commented on a change in pull request #9149:
URL: https://github.com/apache/kafka/pull/9149#discussion_r467755721
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java
##
@@ -430,7 +434,7 @@ private void maybeCreateTopic(Str
[
https://issues.apache.org/jira/browse/KAFKA-8362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen reassigned KAFKA-8362:
Assignee: Luke Chen
> LogCleaner gets stuck after partition move between log directories
> ---
[
https://issues.apache.org/jira/browse/KAFKA-10377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17174183#comment-17174183
]
Dongjin Lee commented on KAFKA-10377:
-
[~tombentley] is right. Those codes are not u
[
https://issues.apache.org/jira/browse/KAFKA-10377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bingkun.ji resolved KAFKA-10377.
Resolution: Not A Problem
> Delete Useless Code
> ---
>
> Key: KAF
[
https://issues.apache.org/jira/browse/KAFKA-10377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17174202#comment-17174202
]
Bingkun.ji commented on KAFKA-10377:
[~dongjin] [~tombentley]
Thank you for you
[
https://issues.apache.org/jira/browse/KAFKA-10223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17174223#comment-17174223
]
Rajini Sivaram commented on KAFKA-10223:
[~dongjoon] This is not a 2.6.0 issue,
viktorsomogyi opened a new pull request #9152:
URL: https://github.com/apache/kafka/pull/9152
A broker throws IllegalStateException if the broker epoch in the
LeaderAndIsr/UpdateMetadataRequest/StopReplicaRequest is larger than its
current broker epoch. However, there is no guarantee that
viktorsomogyi opened a new pull request #9151:
URL: https://github.com/apache/kafka/pull/9151
A broker throws IllegalStateException if the broker epoch in the
LeaderAndIsr/UpdateMetadataRequest/StopReplicaRequest is larger than its
current broker epoch. However, there is no guarantee that
viktorsomogyi commented on pull request #9150:
URL: https://github.com/apache/kafka/pull/9150#issuecomment-671323114
2.3: https://github.com/apache/kafka/pull/9151
2.4: https://github.com/apache/kafka/pull/9151
This is an
viktorsomogyi edited a comment on pull request #9150:
URL: https://github.com/apache/kafka/pull/9150#issuecomment-671323114
2.3: https://github.com/apache/kafka/pull/9151
2.4: https://github.com/apache/kafka/pull/9152
This
[
https://issues.apache.org/jira/browse/KAFKA-10357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17174279#comment-17174279
]
Bruno Cadonna commented on KAFKA-10357:
---
I have a couple of questions regarding wi
cadonna opened a new pull request #9153:
URL: https://github.com/apache/kafka/pull/9153
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgrade
cadonna commented on a change in pull request #9153:
URL: https://github.com/apache/kafka/pull/9153#discussion_r467871730
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
##
@@ -93,7 +95,7 @@
* | +-+
cadonna commented on a change in pull request #9153:
URL: https://github.com/apache/kafka/pull/9153#discussion_r467872227
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
##
@@ -80,11 +80,13 @@
* | +-+--
cadonna commented on pull request #9153:
URL: https://github.com/apache/kafka/pull/9153#issuecomment-671328193
Call for review: @guozhangwang @ableegoldman
This is an automated message from the Apache Git Service.
To respond
chia7712 commented on pull request #9102:
URL: https://github.com/apache/kafka/pull/9102#issuecomment-671337544
@guozhangwang @abbccdda More comments?
This is an automated message from the Apache Git Service.
To respond to t
astubbs opened a new pull request #9154:
URL: https://github.com/apache/kafka/pull/9154
*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 s
vvcephei commented on a change in pull request #9073:
URL: https://github.com/apache/kafka/pull/9073#discussion_r467975526
##
File path: build.gradle
##
@@ -1266,6 +1266,27 @@ project(':streams') {
if( !generatedDocsDir.exists() ) { generatedDocsDir.mkdirs() }
standar
abbccdda commented on a change in pull request #9144:
URL: https://github.com/apache/kafka/pull/9144#discussion_r467975394
##
File path:
clients/src/main/java/org/apache/kafka/server/authorizer/AuthorizableRequestContext.java
##
@@ -69,4 +69,11 @@
* Returns the correlati
abbccdda commented on a change in pull request #9144:
URL: https://github.com/apache/kafka/pull/9144#discussion_r467975757
##
File path:
clients/src/main/java/org/apache/kafka/common/requests/RequestHeader.java
##
@@ -37,11 +37,22 @@ public RequestHeader(Struct struct, short h
tombentley commented on a change in pull request #9136:
URL: https://github.com/apache/kafka/pull/9136#discussion_r467984879
##
File path:
clients/src/main/java/org/apache/kafka/common/config/provider/DirectoryConfigProvider.java
##
@@ -0,0 +1,98 @@
+/*
+ * Licensed to the Apa
tombentley commented on pull request #9136:
URL: https://github.com/apache/kafka/pull/9136#issuecomment-671424344
@mimaison done.
This is an automated message from the Apache Git Service.
To respond to the message, please log
stanislavkozlovski opened a new pull request #9155:
URL: https://github.com/apache/kafka/pull/9155
This patch ensures we use a force resolution strategy for the scala-library
dependency
I've tested this locally and saw a difference in the output:
With the change (using 2.4 and the
stanislavkozlovski commented on pull request #9155:
URL: https://github.com/apache/kafka/pull/9155#issuecomment-671429610
In 2.4 we use `def defaultScala212Version = '2.12.10'` yet it gets updated
to `2.12.12` due to the jackson-module-scala library using the 2.12.12 version
of scala-libra
abbccdda commented on a change in pull request #9144:
URL: https://github.com/apache/kafka/pull/9144#discussion_r468005080
##
File path: core/src/main/scala/kafka/network/SocketServer.scala
##
@@ -88,15 +88,17 @@ class SocketServer(val config: KafkaConfig,
private val memory
rajinisivaram commented on a change in pull request #9032:
URL: https://github.com/apache/kafka/pull/9032#discussion_r467848781
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/ScramMechanism.java
##
@@ -0,0 +1,81 @@
+/*
+ * Licensed to the Apache Software Fo
[
https://issues.apache.org/jira/browse/KAFKA-10381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yogesh BG updated KAFKA-10381:
--
Priority: Trivial (was: Major)
> Add broker to a cluster not rebalancing partitions
> ---
Yogesh BG created KAFKA-10381:
-
Summary: Add broker to a cluster not rebalancing partitions
Key: KAFKA-10381
URL: https://issues.apache.org/jira/browse/KAFKA-10381
Project: Kafka
Issue Type: Bug
junrao commented on a change in pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#discussion_r467279790
##
File path: clients/src/main/resources/common/message/UpdateFeaturesRequest.json
##
@@ -0,0 +1,33 @@
+// Licensed to the Apache Software Foundation (ASF) u
[
https://issues.apache.org/jira/browse/KAFKA-10381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yogesh BG updated KAFKA-10381:
--
Priority: Major (was: Trivial)
> Add broker to a cluster not rebalancing partitions
> ---
[
https://issues.apache.org/jira/browse/KAFKA-10381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yogesh BG updated KAFKA-10381:
--
Affects Version/s: 2.3.0
> Add broker to a cluster not rebalancing partitions
> --
ijuma commented on pull request #9155:
URL: https://github.com/apache/kafka/pull/9155#issuecomment-671482140
ok to test
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-10370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ning Zhang updated KAFKA-10370:
---
Fix Version/s: (was: 2.6.0)
2.7.0
> WorkerSinkTask: IllegalStateException cas
[
https://issues.apache.org/jira/browse/KAFKA-10370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ning Zhang updated KAFKA-10370:
---
Reviewer: Randall Hauch
> WorkerSinkTask: IllegalStateException cased by consumer.seek(tp, offsets)
[
https://issues.apache.org/jira/browse/KAFKA-10077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andy Coates updated KAFKA-10077:
Summary: Filter downstream of state-store results in spurious tombstones
(was: Filter downstream
[
https://issues.apache.org/jira/browse/KAFKA-10370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ning Zhang updated KAFKA-10370:
---
Comment: was deleted
(was: https://github.com/apache/kafka/pull/9145)
> WorkerSinkTask: IllegalStat
big-andy-coates opened a new pull request #9156:
URL: https://github.com/apache/kafka/pull/9156
fixes: [KAFKA-10077](https://issues.apache.org/jira/browse/KAFKA-10077).
Enable sending old values on `KTable.filter` call to avoid the filter
forwarding tombstones for rows that do not ex
[
https://issues.apache.org/jira/browse/KAFKA-10370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17174955#comment-17174955
]
Ning Zhang commented on KAFKA-10370:
Hi [~rhauch], when you have a chance, I would l
Antony Stubbs created KAFKA-10382:
-
Summary: MockProducer is not ThreadSafe, ideally it should be as
the implementation it mocks is
Key: KAFKA-10382
URL: https://issues.apache.org/jira/browse/KAFKA-10382
skaundinya15 commented on pull request #9142:
URL: https://github.com/apache/kafka/pull/9142#issuecomment-671498810
Link to system test run from this branch:
http://confluent-kafka-branch-builder-system-test-results.s3-us-west-2.amazonaws.com/2020-08-07--001.1596866417--skaundinya15--minor-
hachikuji commented on pull request #9112:
URL: https://github.com/apache/kafka/pull/9112#issuecomment-671500806
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
big-andy-coates commented on pull request #9156:
URL: https://github.com/apache/kafka/pull/9156#issuecomment-671501927
@mjsax as discussed. Please review.
I think this change makes the output from the table filter semantically
correct, i.e. we no longer output tombstones for rows tha
kowshik commented on a change in pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#discussion_r468084269
##
File path: clients/src/main/resources/common/message/UpdateFeaturesRequest.json
##
@@ -0,0 +1,33 @@
+// Licensed to the Apache Software Foundation (ASF)
kowshik commented on a change in pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#discussion_r468085443
##
File path: clients/src/main/resources/common/message/UpdateFeaturesResponse.json
##
@@ -0,0 +1,33 @@
+// Licensed to the Apache Software Foundation (ASF)
skaundinya15 commented on pull request #9143:
URL: https://github.com/apache/kafka/pull/9143#issuecomment-671506739
Link for system test run for this branch:
http://confluent-kafka-branch-builder-system-test-results.s3-us-west-2.amazonaws.com/2020-08-07--001.1596860596--skaundinya15--minor-
kowshik commented on a change in pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#discussion_r468089357
##
File path: core/src/main/scala/kafka/controller/KafkaController.scala
##
@@ -266,6 +275,199 @@ class KafkaController(val config: KafkaConfig,
}
}
[
https://issues.apache.org/jira/browse/KAFKA-10357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17174986#comment-17174986
]
Sophie Blee-Goldman commented on KAFKA-10357:
-
How are we going to handle re
dajac commented on a change in pull request #9144:
URL: https://github.com/apache/kafka/pull/9144#discussion_r468090360
##
File path:
clients/src/main/java/org/apache/kafka/common/requests/RequestContext.java
##
@@ -74,7 +77,9 @@ public RequestAndSize parseRequest(ByteBuffer b
dajac commented on a change in pull request #9136:
URL: https://github.com/apache/kafka/pull/9136#discussion_r468093788
##
File path:
clients/src/main/java/org/apache/kafka/common/config/provider/DirectoryConfigProvider.java
##
@@ -0,0 +1,108 @@
+/*
+ * Licensed to the Apache
lct45 opened a new pull request #9157:
URL: https://github.com/apache/kafka/pull/9157
Handles records that fall between 0 and the timeDifference that would
normally create negative windows. This puts a new record that falls into this
range in a window from [0, timeDifference] and creates t
kowshik commented on a change in pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#discussion_r468097360
##
File path: core/src/main/scala/kafka/controller/KafkaController.scala
##
@@ -266,6 +275,199 @@ class KafkaController(val config: KafkaConfig,
}
}
kowshik commented on a change in pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#discussion_r468101982
##
File path: core/src/main/scala/kafka/controller/KafkaController.scala
##
@@ -977,14 +1179,30 @@ class KafkaController(val config: KafkaConfig,
/**
junrao commented on pull request #8657:
URL: https://github.com/apache/kafka/pull/8657#issuecomment-671520491
@chia7712 : I agree mostly with your assessment. For most delayed
operations, the checking for the completeness of the operation and the calling
of onComplete() don't have to be pr
kowshik commented on a change in pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#discussion_r468103224
##
File path: core/src/main/scala/kafka/controller/KafkaController.scala
##
@@ -1647,6 +1865,192 @@ class KafkaController(val config: KafkaConfig,
}
[
https://issues.apache.org/jira/browse/KAFKA-9659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-9659.
--
Fix Version/s: 2.6.0
Resolution: Fixed
> Kafka Streams / Consumer configured for static
ableegoldman commented on a change in pull request #9153:
URL: https://github.com/apache/kafka/pull/9153#discussion_r468104424
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
##
@@ -93,7 +95,7 @@
* | +-
kowshik commented on a change in pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#discussion_r468109791
##
File path: core/src/main/scala/kafka/controller/KafkaController.scala
##
@@ -1647,6 +1865,192 @@ class KafkaController(val config: KafkaConfig,
}
kowshik commented on a change in pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#discussion_r468111300
##
File path: core/src/main/scala/kafka/server/FinalizedFeatureCache.scala
##
@@ -82,18 +110,54 @@ object FinalizedFeatureCache extends Logging {
"
kowshik commented on a change in pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#discussion_r468111785
##
File path: core/src/main/scala/kafka/server/BrokerFeatures.scala
##
@@ -0,0 +1,192 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
cadonna commented on a change in pull request #9153:
URL: https://github.com/apache/kafka/pull/9153#discussion_r468121273
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
##
@@ -93,7 +95,7 @@
* | +-+
Marco Lotz created KAFKA-10383:
--
Summary: KTable Join on Foreign key is opinionated
Key: KAFKA-10383
URL: https://issues.apache.org/jira/browse/KAFKA-10383
Project: Kafka
Issue Type: Improvemen
[
https://issues.apache.org/jira/browse/KAFKA-10383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Marco Lotz updated KAFKA-10383:
---
Description:
*Status Quo:*
The current implementation of [KIP-213
|[https://cwiki.apache.org/confl
[
https://issues.apache.org/jira/browse/KAFKA-10383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Marco Lotz updated KAFKA-10383:
---
Description:
*Status Quo:*
The current implementation of [KIP-213
|[https://cwiki.apache.org/confl
[
https://issues.apache.org/jira/browse/KAFKA-10383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Marco Lotz updated KAFKA-10383:
---
Description:
*Status Quo:*
The current implementation of [KIP-213
|[https://cwiki.apache.org/confl
Colin McCabe created KAFKA-10384:
Summary: Separate converters from generated messages
Key: KAFKA-10384
URL: https://issues.apache.org/jira/browse/KAFKA-10384
Project: Kafka
Issue Type: Bug
ijuma commented on pull request #9155:
URL: https://github.com/apache/kafka/pull/9155#issuecomment-671562430
2 builds passed, 1 flaky test failure for Java 8.
This is an automated message from the Apache Git Service.
To respo
ijuma merged pull request #9155:
URL: https://github.com/apache/kafka/pull/9155
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
apovzner commented on a change in pull request #8768:
URL: https://github.com/apache/kafka/pull/8768#discussion_r468175154
##
File path: core/src/test/scala/unit/kafka/network/ConnectionQuotasTest.scala
##
@@ -70,37 +80,38 @@ class ConnectionQuotasTest {
blockedPercent
guozhangwang merged pull request #9153:
URL: https://github.com/apache/kafka/pull/9153
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-10383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10383:
-
Component/s: (was: core)
streams
> KTable Join on Foreign key is opinionate
skaundinya15 commented on pull request #9143:
URL: https://github.com/apache/kafka/pull/9143#issuecomment-671599091
I re-ran the system tests for `streams_broker_compatibility_test` here:
http://confluent-kafka-branch-builder-system-test-results.s3-us-west-2.amazonaws.com/2020-08-10--001.15
[
https://issues.apache.org/jira/browse/KAFKA-10383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17175074#comment-17175074
]
John Roesler commented on KAFKA-10383:
--
Thanks for the report, [~marcolotz].
This
vvcephei commented on a change in pull request #9141:
URL: https://github.com/apache/kafka/pull/9141#discussion_r468206463
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/CogroupedStreamAggregateBuilder.java
##
@@ -85,68 +160,38 @@
group
vvcephei commented on pull request #9141:
URL: https://github.com/apache/kafka/pull/9141#issuecomment-671609419
All the tests were green except for the flaky
```
org.apache.kafka.streams.integration.EosBetaUpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosBeta[false]
org
vvcephei commented on a change in pull request #9039:
URL: https://github.com/apache/kafka/pull/9039#discussion_r468214782
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/SlidingWindows.java
##
@@ -0,0 +1,141 @@
+/*
+ * Licensed to the Apache Software Foun
vvcephei commented on a change in pull request #9039:
URL: https://github.com/apache/kafka/pull/9039#discussion_r468214782
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/SlidingWindows.java
##
@@ -0,0 +1,141 @@
+/*
+ * Licensed to the Apache Software Foun
ijuma commented on pull request #9155:
URL: https://github.com/apache/kafka/pull/9155#issuecomment-671617848
Merged to master and cherry-picked to 2.6, 2.5 and 2.4 branches.
This is an automated message from the Apache Git Se
vvcephei merged pull request #9141:
URL: https://github.com/apache/kafka/pull/9141
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 t
vvcephei commented on pull request #9141:
URL: https://github.com/apache/kafka/pull/9141#issuecomment-671622789
Verified the last commit only changed whitespace before merging.
This is an automated message from the Apache Git
rondagostino commented on a change in pull request #9032:
URL: https://github.com/apache/kafka/pull/9032#discussion_r468149236
##
File path: clients/src/main/java/org/apache/kafka/clients/admin/Admin.java
##
@@ -1214,6 +1215,64 @@ default AlterClientQuotasResult
alterClientQuo
kowshik commented on a change in pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#discussion_r468111300
##
File path: core/src/main/scala/kafka/server/FinalizedFeatureCache.scala
##
@@ -82,18 +110,54 @@ object FinalizedFeatureCache extends Logging {
"
[
https://issues.apache.org/jira/browse/KAFKA-10223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17175094#comment-17175094
]
Dongjoon Hyun commented on KAFKA-10223:
---
Thank you for the confirmation, [~rsivara
hachikuji commented on a change in pull request #9112:
URL: https://github.com/apache/kafka/pull/9112#discussion_r468270027
##
File path: core/src/test/scala/unit/kafka/server/MetadataCacheTest.scala
##
@@ -229,7 +205,7 @@ class MetadataCacheTest {
[
https://issues.apache.org/jira/browse/KAFKA-10381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17175147#comment-17175147
]
Yogesh BG commented on KAFKA-10381:
---
One more observation is that when i restart the l
apovzner commented on pull request #8768:
URL: https://github.com/apache/kafka/pull/8768#issuecomment-671684203
@rajinisivaram Thanks for your review. I updated this PR to expose
'connection-accept-rate' metrics, addressed the remaining comments, and the
test should also be fixed.
ableegoldman commented on a change in pull request #9039:
URL: https://github.com/apache/kafka/pull/9039#discussion_r468218540
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/SlidingWindowedCogroupedKStreamImpl.java
##
@@ -0,0 +1,148 @@
+/*
+ * L
showuon opened a new pull request #9158:
URL: https://github.com/apache/kafka/pull/9158
After the new website launched, the quickstart link also changed. Update the
quickstart link in readme.md.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and impleme
showuon commented on pull request #9158:
URL: https://github.com/apache/kafka/pull/9158#issuecomment-671702480
@rhauch , could you review this small PR to update quickstart link? Thanks.
This is an automated message from the
stanislavkozlovski commented on pull request #9155:
URL: https://github.com/apache/kafka/pull/9155#issuecomment-671714884
I just updated the PR description to mention that both tests were using
Jackson `2.10.5`. Apologies for the misleading, I must have got confused by the
numerous tests I
guozhangwang commented on a change in pull request #8549:
URL: https://github.com/apache/kafka/pull/8549#discussion_r468327920
##
File path:
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java
##
@@ -1366,6 +1366,10 @@ public void handleRe
[
https://issues.apache.org/jira/browse/KAFKA-10378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen reassigned KAFKA-10378:
-
Assignee: Luke Chen
> issue when create producer using java
> -
showuon opened a new pull request #9159:
URL: https://github.com/apache/kafka/pull/9159
change `jacksonDatabind` as `compile` dependency
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
showuon commented on pull request #9159:
URL: https://github.com/apache/kafka/pull/9159#issuecomment-671748891
@ijuma , could you review this PR? Thanks.
This is an automated message from the Apache Git Service.
To respond to
chia7712 commented on pull request #8657:
URL: https://github.com/apache/kafka/pull/8657#issuecomment-671749755
> Both operations are done under the same group lock. If we relax the lock,
it seems that the condition "all members have joined" may no longer be true
when we get to DelayedJoin
99 matches
Mail list logo
