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
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
[
https://issues.apache.org/jira/browse/KAFKA-7271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17279011#comment-17279011
]
Bruno Cadonna commented on KAFKA-7271:
--
Split the ticket into two tickets: KAFKA-12292 and
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
[
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:
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
[
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,
[
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
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,
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,
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:
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
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=17278849#comment-17278849
]
Marco Lotz commented on KAFKA-9527:
---
PR ready.
Please let me know your thoughts and what needs changing
[
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
[
https://issues.apache.org/jira/browse/KAFKA-9527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17278825#comment-17278825
]
Marco Lotz commented on KAFKA-9527:
---
[~jeqo] Understood. About returning the latest offset - if we
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
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
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
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
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
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
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
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
[
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
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
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
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
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
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://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
[
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
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:
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
[
https://issues.apache.org/jira/browse/KAFKA-12264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17278737#comment-17278737
]
Jeff Kim commented on KAFKA-12264:
--
[~chia7712] yes, and a separate subclass to run specifically ZSTD +
[
https://issues.apache.org/jira/browse/KAFKA-12263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17278735#comment-17278735
]
Tom Bentley commented on KAFKA-12263:
-
[~hachikuji] any chance you could review my PR?
> Improve
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
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
[
https://issues.apache.org/jira/browse/KAFKA-12264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17278720#comment-17278720
]
Chia-Ping Tsai commented on KAFKA-12264:
How about making sub classes offer messageVersion?
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
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
[
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
[
https://issues.apache.org/jira/browse/KAFKA-12286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17278673#comment-17278673
]
Tom Bentley commented on KAFKA-12286:
-
{quote}we will have options to deal with it if it
101 - 154 of 154 matches
Mail list logo
