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
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
[
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
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
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
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
[
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
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-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
> ---
[
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-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
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
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
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
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 (
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
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
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
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
[
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
>
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-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
[
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
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
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
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
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
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
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
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
[
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
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
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 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_r570153122
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryKeyValueStore.java
##
@@ -103,6 +105,20 @@ public void putAll(fin
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
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
[
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
[
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
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
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
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
[
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
[
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
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
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
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
[
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
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
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
[
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
[
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
101 - 154 of 154 matches
Mail list logo