[
https://issues.apache.org/jira/browse/KAFKA-12286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17278673#comment-17278673
]
Tom Bentley commented on KAFKA-12286:
-
{quote}we will have options to deal with it i
[
https://issues.apache.org/jira/browse/KAFKA-12257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lqjacklee updated KAFKA-12257:
--
Attachment: KAFKA-12257-1.patch
> Consumer mishandles topics deleted and recreated with the same name
bob-barrett commented on a change in pull request #9902:
URL: https://github.com/apache/kafka/pull/9902#discussion_r570072638
##
File path: clients/src/test/java/org/apache/kafka/clients/NetworkClientTest.java
##
@@ -81,6 +85,19 @@
private final NetworkClient clientWithNoE
bob-barrett commented on pull request #9902:
URL: https://github.com/apache/kafka/pull/9902#issuecomment-773171300
@dajac @mimaison @satishd Thanks for your reviews!
In addition to PR feedback, I pushed a new change to
`ClusterConnectionStatesTest`. I noticed while testing locally th
[
https://issues.apache.org/jira/browse/KAFKA-12264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17278720#comment-17278720
]
Chia-Ping Tsai commented on KAFKA-12264:
How about making sub classes offer mess
vamossagar12 opened a new pull request #10051:
URL: https://github.com/apache/kafka/pull/10051
*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 te
vamossagar12 commented on pull request #9508:
URL: https://github.com/apache/kafka/pull/9508#issuecomment-773181642
Thanks @guozhangwang !
@cadonna I have added the doc here in this PR:
https://github.com/apache/kafka/pull/10051.
I will create a separate. ticket for the missing test c
tombentley commented on pull request #9972:
URL: https://github.com/apache/kafka/pull/9972#issuecomment-773183761
Rebased to trigger CI again.
@chia7712 please could to take another look when you have the chance?
This
[
https://issues.apache.org/jira/browse/KAFKA-12263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17278735#comment-17278735
]
Tom Bentley commented on KAFKA-12263:
-
[~hachikuji] any chance you could review my P
[
https://issues.apache.org/jira/browse/KAFKA-12264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17278737#comment-17278737
]
Jeff Kim commented on KAFKA-12264:
--
[~chia7712] yes, and a separate subclass to run spe
bob-barrett commented on a change in pull request #9902:
URL: https://github.com/apache/kafka/pull/9902#discussion_r570072638
##
File path: clients/src/test/java/org/apache/kafka/clients/NetworkClientTest.java
##
@@ -81,6 +85,19 @@
private final NetworkClient clientWithNoE
vamossagar12 commented on pull request #9756:
URL: https://github.com/apache/kafka/pull/9756#issuecomment-773204238
@hachikuji did you get a chance to review this?
This is an automated message from the Apache Git Service.
To
Sagar Rao created KAFKA-12289:
-
Summary: Add Tests for prefixScan in InMemoryKeyValueStore
Key: KAFKA-12289
URL: https://issues.apache.org/jira/browse/KAFKA-12289
Project: Kafka
Issue Type: Impro
[
https://issues.apache.org/jira/browse/KAFKA-12289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-12289:
-
Assignee: Sagar Rao (was: Rohit Deshpande)
> Add Tests for prefixScan in InMemoryKeyValueStore
[
https://issues.apache.org/jira/browse/KAFKA-12289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao updated KAFKA-12289:
--
Description: While reviewing, kIP-614, a comment was added to add a test
that directly tests the in-me
cadonna commented on a change in pull request #10051:
URL: https://github.com/apache/kafka/pull/10051#discussion_r570139416
##
File path: docs/streams/upgrade-guide.html
##
@@ -154,6 +154,14 @@ Streams API
turn on all higher levels, ie INFO and DEBUG. See https://cwiki
vamossagar12 opened a new pull request #10052:
URL: https://github.com/apache/kafka/pull/10052
*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 te
vamossagar12 commented on a change in pull request #9508:
URL: https://github.com/apache/kafka/pull/9508#discussion_r570153122
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryKeyValueStore.java
##
@@ -103,6 +105,20 @@ public void putAll(fin
mimaison commented on pull request #9902:
URL: https://github.com/apache/kafka/pull/9902#issuecomment-773243982
Tests passed on JDK 8.
The failure on JDK 11
(`kafka.api.TransactionsTest.testAbortTransactionTimeout()`) looks unrelated.
---
vamossagar12 commented on a change in pull request #9508:
URL: https://github.com/apache/kafka/pull/9508#discussion_r570157727
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/CachingKeyValueStore.java
##
@@ -291,6 +292,16 @@ public void putAll(fina
mimaison merged pull request #9902:
URL: https://github.com/apache/kafka/pull/9902
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
[
https://issues.apache.org/jira/browse/KAFKA-12193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison resolved KAFKA-12193.
Fix Version/s: 2.8.0
Resolution: Fixed
> Re-resolve IPs when a client is disconnect
tombentley commented on a change in pull request #10012:
URL: https://github.com/apache/kafka/pull/10012#discussion_r570158748
##
File path: clients/src/main/java/org/apache/kafka/common/utils/StringUtils.java
##
@@ -0,0 +1,33 @@
+/*
+ * Licensed to the Apache Software Foundati
tombentley commented on a change in pull request #10004:
URL: https://github.com/apache/kafka/pull/10004#discussion_r570162199
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java
##
@@ -591,7 +591,7 @@ public void handle(Joi
vamossagar12 commented on a change in pull request #10052:
URL: https://github.com/apache/kafka/pull/10052#discussion_r570171267
##
File path:
streams/src/test/java/org/apache/kafka/streams/state/internals/InMemoryKeyValueStoreTest.java
##
@@ -60,4 +67,22 @@ public void should
tang7526 closed pull request #10012:
URL: https://github.com/apache/kafka/pull/10012
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
tang7526 commented on a change in pull request #10012:
URL: https://github.com/apache/kafka/pull/10012#discussion_r570185975
##
File path: clients/src/main/java/org/apache/kafka/common/utils/StringUtils.java
##
@@ -0,0 +1,33 @@
+/*
+ * Licensed to the Apache Software Foundation
tang7526 commented on a change in pull request #10012:
URL: https://github.com/apache/kafka/pull/10012#discussion_r570185975
##
File path: clients/src/main/java/org/apache/kafka/common/utils/StringUtils.java
##
@@ -0,0 +1,33 @@
+/*
+ * Licensed to the Apache Software Foundation
omkreddy commented on a change in pull request #10002:
URL: https://github.com/apache/kafka/pull/10002#discussion_r570196800
##
File path: docs/security.html
##
@@ -320,10 +320,10 @@ SSL key and certificates in PEM format
listeners
If SSL is not enab
cadonna commented on a change in pull request #10052:
URL: https://github.com/apache/kafka/pull/10052#discussion_r570207387
##
File path:
streams/src/test/java/org/apache/kafka/streams/state/internals/InMemoryKeyValueStoreTest.java
##
@@ -60,4 +67,22 @@ public void shouldRemov
[
https://issues.apache.org/jira/browse/KAFKA-9527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Marco Lotz reassigned KAFKA-9527:
-
Assignee: Marco Lotz (was: jbfletch)
> Application Reset Tool Returns NPE when --to-datetime or
[
https://issues.apache.org/jira/browse/KAFKA-9527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17278825#comment-17278825
]
Marco Lotz commented on KAFKA-9527:
---
[~jeqo] Understood. About returning the latest off
[
https://issues.apache.org/jira/browse/KAFKA-9527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17278849#comment-17278849
]
Marco Lotz commented on KAFKA-9527:
---
PR ready.
Please let me know your thoughts and wha
dajac commented on pull request #9902:
URL: https://github.com/apache/kafka/pull/9902#issuecomment-773366825
I have picked the commit into 2.7 but could not pick it into 2.6 cleanly.
@bob-barrett Could you open a PR for 2.6?
[
https://issues.apache.org/jira/browse/KAFKA-12193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot updated KAFKA-12193:
Fix Version/s: 2.7.1
> Re-resolve IPs when a client is disconnected
>
rondagostino commented on a change in pull request #10005:
URL: https://github.com/apache/kafka/pull/10005#discussion_r570326339
##
File path: core/src/main/scala/kafka/server/KafkaServer.scala
##
@@ -348,15 +348,15 @@ class KafkaServer(
/* start processing requests
rondagostino commented on a change in pull request #10005:
URL: https://github.com/apache/kafka/pull/10005#discussion_r570342092
##
File path: core/src/main/scala/kafka/server/KafkaServer.scala
##
@@ -348,15 +348,15 @@ class KafkaServer(
/* start processing requests
vamossagar12 commented on pull request #10051:
URL: https://github.com/apache/kafka/pull/10051#issuecomment-773415951
done.
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
Chris Cairns created KAFKA-12290:
Summary: Adding a new topic or removing an existing topic to/from
--whitelist in mirrormaker config file stops all replication
Key: KAFKA-12290
URL: https://issues.apache.org/jira
jsancio commented on a change in pull request #10030:
URL: https://github.com/apache/kafka/pull/10030#discussion_r570367570
##
File path: metadata/src/main/java/org/apache/kafka/queue/KafkaEventQueue.java
##
@@ -0,0 +1,420 @@
+/*
+ * Licensed to the Apache Software Foundation (
abbccdda commented on a change in pull request #9579:
URL: https://github.com/apache/kafka/pull/9579#discussion_r570396673
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -1113,82 +1097,36 @@ class KafkaApis(val requestChannel: RequestChannel,
.setPa
kkonstantine merged pull request #9867:
URL: https://github.com/apache/kafka/pull/9867
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
hachikuji commented on a change in pull request #10005:
URL: https://github.com/apache/kafka/pull/10005#discussion_r570404954
##
File path: core/src/main/scala/kafka/server/ReplicaManager.scala
##
@@ -1881,7 +1884,11 @@ class ReplicaManager(val config: KafkaConfig,
logMana
[
https://issues.apache.org/jira/browse/KAFKA-12184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-12184:
--
Fix Version/s: (was: 3.0.0)
> Once the Error Classification is better update the default s
[
https://issues.apache.org/jira/browse/KAFKA-12264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Kim updated KAFKA-12264:
-
Description:
Classes that extend BaseRecordBatchBenchmark cannot run with (compression type
= ZSTD, mag
[
https://issues.apache.org/jira/browse/KAFKA-9588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-9588:
-
Fix Version/s: (was: 3.0.0)
> Add rocksdb event listeners in KS
> ---
hachikuji commented on pull request #9756:
URL: https://github.com/apache/kafka/pull/9756#issuecomment-773479357
@vamossagar12 Thanks, I missed the update. I will review today.
This is an automated message from the Apache Git
[
https://issues.apache.org/jira/browse/KAFKA-7271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-7271:
-
Priority: Blocker (was: Critical)
> Fix ignored test in streams_upgrade_test.py: test_upgrade_do
rhauch commented on pull request #9780:
URL: https://github.com/apache/kafka/pull/9780#issuecomment-773485918
Rebased on `trunk` to correct conflicts.
This is an automated message from the Apache Git Service.
To respond to th
Bruno Cadonna created KAFKA-12291:
-
Summary: Fix Ignored Upgrade Tests in streams_upgrade_test.py:
test_upgrade_downgrade_brokers
Key: KAFKA-12291
URL: https://issues.apache.org/jira/browse/KAFKA-12291
Bruno Cadonna created KAFKA-12292:
-
Summary: Fix Ignored Downgrade Tests in streams_upgrade_test.py:
test_upgrade_downgrade_brokers
Key: KAFKA-12292
URL: https://issues.apache.org/jira/browse/KAFKA-12292
[
https://issues.apache.org/jira/browse/KAFKA-7271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17279011#comment-17279011
]
Bruno Cadonna commented on KAFKA-7271:
--
Split the ticket into two tickets: KAFKA-122
levzem opened a new pull request #10053:
URL: https://github.com/apache/kafka/pull/10053
Signed-off-by: Lev Zemlyanov
*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 re
levzem commented on pull request #10053:
URL: https://github.com/apache/kafka/pull/10053#issuecomment-773495387
@kkonstantine would appreciate some 👀
This is an automated message from the Apache Git Service.
To respond to th
[
https://issues.apache.org/jira/browse/KAFKA-7271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna resolved KAFKA-7271.
--
Resolution: Duplicate
> Fix ignored test in streams_upgrade_test.py: test_upgrade_downgrade_bro
cmccabe commented on a change in pull request #10030:
URL: https://github.com/apache/kafka/pull/10030#discussion_r570442555
##
File path: metadata/src/main/java/org/apache/kafka/queue/KafkaEventQueue.java
##
@@ -0,0 +1,420 @@
+/*
+ * Licensed to the Apache Software Foundation (
cmccabe commented on a change in pull request #10030:
URL: https://github.com/apache/kafka/pull/10030#discussion_r570450458
##
File path: metadata/src/main/java/org/apache/kafka/queue/KafkaEventQueue.java
##
@@ -0,0 +1,420 @@
+/*
+ * Licensed to the Apache Software Foundation (
mumrah commented on a change in pull request #10049:
URL: https://github.com/apache/kafka/pull/10049#discussion_r570451366
##
File path: core/src/test/scala/unit/kafka/server/MetadataCacheTest.scala
##
@@ -483,61 +475,4 @@ class MetadataCacheTest {
assertEquals(initialBrok
cmccabe commented on pull request #10047:
URL: https://github.com/apache/kafka/pull/10047#issuecomment-773516371
Test failures are not related to the PR
This is an automated message from the Apache Git Service.
To respond to
junrao commented on a change in pull request #10030:
URL: https://github.com/apache/kafka/pull/10030#discussion_r570453181
##
File path: metadata/src/main/java/org/apache/kafka/queue/EventQueue.java
##
@@ -0,0 +1,263 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) u
jsancio commented on a change in pull request #10030:
URL: https://github.com/apache/kafka/pull/10030#discussion_r570462338
##
File path: metadata/src/main/java/org/apache/kafka/queue/KafkaEventQueue.java
##
@@ -0,0 +1,420 @@
+/*
+ * Licensed to the Apache Software Foundation (
jsancio commented on a change in pull request #10030:
URL: https://github.com/apache/kafka/pull/10030#discussion_r570367570
##
File path: metadata/src/main/java/org/apache/kafka/queue/KafkaEventQueue.java
##
@@ -0,0 +1,420 @@
+/*
+ * Licensed to the Apache Software Foundation (
cmccabe merged pull request #10019:
URL: https://github.com/apache/kafka/pull/10019
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
kkonstantine commented on a change in pull request #10053:
URL: https://github.com/apache/kafka/pull/10053#discussion_r570464187
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java
##
@@ -236,7 +236,7 @@ public Distri
mumrah commented on a change in pull request #10049:
URL: https://github.com/apache/kafka/pull/10049#discussion_r570474971
##
File path: core/src/test/scala/unit/kafka/server/MetadataCacheTest.scala
##
@@ -483,61 +475,4 @@ class MetadataCacheTest {
assertEquals(initialBrok
mumrah commented on a change in pull request #10049:
URL: https://github.com/apache/kafka/pull/10049#discussion_r570474971
##
File path: core/src/test/scala/unit/kafka/server/MetadataCacheTest.scala
##
@@ -483,61 +475,4 @@ class MetadataCacheTest {
assertEquals(initialBrok
abbccdda commented on a change in pull request #9579:
URL: https://github.com/apache/kafka/pull/9579#discussion_r570480399
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -1234,19 +1171,28 @@ class KafkaApis(val requestChannel: RequestChannel,
// In ve
vvcephei commented on pull request #9107:
URL: https://github.com/apache/kafka/pull/9107#issuecomment-773549603
Thanks, all, that Scala fix looks perfect to me.
This is an automated message from the Apache Git Service.
To res
[
https://issues.apache.org/jira/browse/KAFKA-12279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17279097#comment-17279097
]
prabhu biradar commented on KAFKA-12279:
Hi Sophie Blee-Goldman,
1) This error
abbccdda commented on a change in pull request #9579:
URL: https://github.com/apache/kafka/pull/9579#discussion_r570492221
##
File path: core/src/main/scala/kafka/server/AutoTopicCreationManager.scala
##
@@ -0,0 +1,139 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
abbccdda commented on a change in pull request #9579:
URL: https://github.com/apache/kafka/pull/9579#discussion_r570492431
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -1234,19 +1171,28 @@ class KafkaApis(val requestChannel: RequestChannel,
// In ve
ableegoldman commented on a change in pull request #1:
URL: https://github.com/apache/kafka/pull/1#discussion_r570495244
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java
##
@@ -227,6 +230,27 @@ public void initializeIfNee
mimaison commented on pull request #9726:
URL: https://github.com/apache/kafka/pull/9726#issuecomment-773567218
Thanks @kkonstantine for the feedback. I've pushed an update
This is an automated message from the Apache Git Ser
jsancio commented on a change in pull request #10045:
URL: https://github.com/apache/kafka/pull/10045#discussion_r570507065
##
File path: core/src/main/scala/kafka/server/MetadataSupport.scala
##
@@ -0,0 +1,109 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under
kkonstantine commented on a change in pull request #9726:
URL: https://github.com/apache/kafka/pull/9726#discussion_r570505650
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/resources/ConnectorsResource.java
##
@@ -188,6 +188,16 @@ public Con
[
https://issues.apache.org/jira/browse/KAFKA-12284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai reassigned KAFKA-12284:
--
Assignee: Chia-Ping Tsai
> Flaky Test
> MirrorConnectorsIntegrationSSLTest#testOneWa
[
https://issues.apache.org/jira/browse/KAFKA-12283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai reassigned KAFKA-12283:
--
Assignee: Chia-Ping Tsai
> Flaky Test
> RebalanceSourceConnectorsIntegrationTest#tes
[
https://issues.apache.org/jira/browse/KAFKA-12284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai reassigned KAFKA-12284:
--
Assignee: (was: Chia-Ping Tsai)
> Flaky Test
> MirrorConnectorsIntegrationSSLTes
chia7712 opened a new pull request #10054:
URL: https://github.com/apache/kafka/pull/10054
issue: https://issues.apache.org/jira/browse/KAFKA-12283
It seems to me the new tasks distribution (8, 4, 4) is valid if following
conditions are true.
1. all tasks are assigned to (single)
chia7712 commented on pull request #10054:
URL: https://github.com/apache/kafka/pull/10054#issuecomment-773582456
@ramesh-muthusamy Could you take a look? thanks!
This is an automated message from the Apache Git Service.
To r
Dejan Stojadinović created KAFKA-12293:
--
Summary: Remove JCenter and Bintray repositories mentions out of
Gradle build (sunset is announced for those repositories)
Key: KAFKA-12293
URL: https://issues.apache.
ableegoldman commented on a change in pull request #1:
URL: https://github.com/apache/kafka/pull/1#discussion_r570535029
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java
##
@@ -227,6 +230,27 @@ public void initializeIfNee
gardnervickers opened a new pull request #10055:
URL: https://github.com/apache/kafka/pull/10055
The original PR was #9902
The reason for back-porting this improved test infrastructure is to address
some flakes which we have seen when kafka.apache.org DNS changes, specifically
in t
dejan2609 opened a new pull request #10056:
URL: https://github.com/apache/kafka/pull/10056
Related jira ticket:
https://issues.apache.org/jira/browse/KAFKA-12293 **_Remove JCenter and
Bintray repositories mentions out of Gradle build (sunset is announced for
those repositories)_**
hachikuji merged pull request #10005:
URL: https://github.com/apache/kafka/pull/10005
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 t
[
https://issues.apache.org/jira/browse/KAFKA-12293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17279162#comment-17279162
]
Dejan Stojadinović commented on KAFKA-12293:
Note: at the moment I am not su
gardnervickers opened a new pull request #10057:
URL: https://github.com/apache/kafka/pull/10057
The original PR was #9902
The reason for back-porting this improved test infrastructure is to address
some flakes which we have seen when kafka.apache.org DNS changes, specifically
in th
mimaison commented on a change in pull request #9726:
URL: https://github.com/apache/kafka/pull/9726#discussion_r570545828
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/resources/ConnectorsResource.java
##
@@ -188,6 +188,16 @@ public Connect
gardnervickers opened a new pull request #10058:
URL: https://github.com/apache/kafka/pull/10058
The original PR was #9902
The reason for back-porting this improved test infrastructure is to address
some flakes which we have seen when kafka.apache.org DNS changes, specifically
in th
Boyang Chen created KAFKA-12294:
---
Summary: Consider using the forwarding mechanism for metadata auto
topic creation
Key: KAFKA-12294
URL: https://issues.apache.org/jira/browse/KAFKA-12294
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-12294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-12294:
Parent: (was: KAFKA-9705)
Issue Type: Improvement (was: Sub-task)
> Consider using th
[
https://issues.apache.org/jira/browse/KAFKA-12294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-12294:
Component/s: core
> Consider using the forwarding mechanism for metadata auto topic creation
> ---
abbccdda commented on a change in pull request #9579:
URL: https://github.com/apache/kafka/pull/9579#discussion_r570568151
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -1084,24 +1087,9 @@ class KafkaApis(val requestChannel: RequestChannel,
(response
dpoldrugo opened a new pull request #10059:
URL: https://github.com/apache/kafka/pull/10059
Description:
As suggested by @omkreddy in this
[comment](https://issues.apache.org/jira/browse/KAFKA-8562?focusedCommentId=16912437&page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tab
kkonstantine commented on a change in pull request #9726:
URL: https://github.com/apache/kafka/pull/9726#discussion_r570577845
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/resources/ConnectorsResource.java
##
@@ -188,6 +188,16 @@ public Con
C0urante commented on pull request #9726:
URL: https://github.com/apache/kafka/pull/9726#issuecomment-773648389
Just ran into a situation last night where this would have been super
helpful. Thanks for adding this @mimaison!
cmccabe commented on pull request #10030:
URL: https://github.com/apache/kafka/pull/10030#issuecomment-773648975
Test failure is
`org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationSSLTest`
which is not related.
cmccabe merged pull request #10030:
URL: https://github.com/apache/kafka/pull/10030
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
kkonstantine commented on a change in pull request #9780:
URL: https://github.com/apache/kafka/pull/9780#discussion_r570584036
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java
##
@@ -209,7 +229,8 @@ public Distribu
rohitrmd commented on a change in pull request #9744:
URL: https://github.com/apache/kafka/pull/9744#discussion_r570605728
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractProcessorContext.java
##
@@ -45,7 +45,6 @@
private boolean i
1 - 100 of 154 matches
Mail list logo