[
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
>
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
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
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
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
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 @@
+/*
+ *
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.
[
https://issues.apache.org/jira/browse/KAFKA-10381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17175147#comment-17175147
]
Yogesh BG commented on KAFKA-10381:
---
One more observation is that when i restart the leader node for
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-10223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17175094#comment-17175094
]
Dongjoon Hyun commented on KAFKA-10223:
---
Thank you for the confirmation, [~rsivaram].
>
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 {
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
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
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
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
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
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
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]
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 @@
[
https://issues.apache.org/jira/browse/KAFKA-10383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17175074#comment-17175074
]
John Roesler commented on KAFKA-10383:
--
Thanks for the report, [~marcolotz].
This seems like a
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:
[
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
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
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 {
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
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
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
[
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://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://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
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:
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 @@
* |
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
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_r468109791
##
File path: core/src/main/scala/kafka/controller/KafkaController.scala
##
@@ -1647,6 +1865,192 @@ class KafkaController(val config: KafkaConfig,
}
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 @@
* |
[
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
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,
}
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
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,
/**
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,
}
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
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
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
[
https://issues.apache.org/jira/browse/KAFKA-10357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17174986#comment-17174986
]
Sophie Blee-Goldman commented on KAFKA-10357:
-
How are we going to handle
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,
}
skaundinya15 commented on pull request #9143:
URL: https://github.com/apache/kafka/pull/9143#issuecomment-671506739
Link for system test run for this branch:
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
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)
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
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
skaundinya15 commented on pull request #9142:
URL: https://github.com/apache/kafka/pull/9142#issuecomment-671498810
Link to system test run from this branch:
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
[
https://issues.apache.org/jira/browse/KAFKA-10370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17174955#comment-17174955
]
Ning Zhang commented on KAFKA-10370:
Hi [~rhauch], when you have a chance, I would like to get your
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
[
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:
[
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-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
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
[
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
>
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)
[
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
>
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
[
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
>
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
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
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
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
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
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
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
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
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() }
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
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
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
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 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 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
[
https://issues.apache.org/jira/browse/KAFKA-10357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17174279#comment-17174279
]
Bruno Cadonna commented on KAFKA-10357:
---
I have a couple of questions regarding wild idea 1):
1)
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
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 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
[
https://issues.apache.org/jira/browse/KAFKA-10223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17174223#comment-17174223
]
Rajini Sivaram commented on KAFKA-10223:
[~dongjoon] This is not a 2.6.0 issue,
[
https://issues.apache.org/jira/browse/KAFKA-10377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17174202#comment-17174202
]
Bingkun.ji commented on KAFKA-10377:
[~dongjin] [~tombentley]
Thank you for your reply
>
[
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:
[
https://issues.apache.org/jira/browse/KAFKA-10377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17174183#comment-17174183
]
Dongjin Lee commented on KAFKA-10377:
-
[~tombentley] is right. Those codes are not useless.
[
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
>
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
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.
[
https://issues.apache.org/jira/browse/KAFKA-10377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17174157#comment-17174157
]
Tom Bentley commented on KAFKA-10377:
-
This is used to generate the [protocol
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-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
[
https://issues.apache.org/jira/browse/KAFKA-10038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17174125#comment-17174125
]
Luke Chen commented on KAFKA-10038:
---
This might need a KIP. Working on that.
>
showuon commented on pull request #9149:
URL: https://github.com/apache/kafka/pull/9149#issuecomment-671191319
@kkonstantine , could you help review this PR to improve logging? Thanks.
This is an automated message from the
showuon commented on a change in pull request #9149:
URL: https://github.com/apache/kafka/pull/9149#discussion_r467713932
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java
##
@@ -363,6 +363,7 @@ private boolean sendRecords() {
[
https://issues.apache.org/jira/browse/KAFKA-10340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17174105#comment-17174105
]
Luke Chen edited comment on KAFKA-10340 at 8/10/20, 6:45 AM:
-
After
showuon opened a new pull request #9149:
URL: https://github.com/apache/kafka/pull/9149
Improve the logging in `maybeCreateTopic` to let user know if
`!topicCreation.isTopicCreationRequired(topic)`, we won't create this topic
because the topic creation setting is disabled or the topic
1 - 100 of 104 matches
Mail list logo
