bob-barrett opened a new pull request #9302:
URL: https://github.com/apache/kafka/pull/9302
This patch removes the check for reassigning partitions when determining
whether to trigger automatic leader election. This check can cause problems
during long-running reassignments because a
abbccdda commented on a change in pull request #8725:
URL: https://github.com/apache/kafka/pull/8725#discussion_r490713327
##
File path:
clients/src/test/java/org/apache/kafka/clients/producer/internals/TransactionSimulationCoordinator.java
##
@@ -0,0 +1,316 @@
+/*
+ *
ijuma commented on pull request #9218:
URL: https://github.com/apache/kafka/pull/9218#issuecomment-694648140
Can you please rebase so that we get the new CI running?
This is an automated message from the Apache Git Service.
ijuma commented on a change in pull request #9294:
URL: https://github.com/apache/kafka/pull/9294#discussion_r490699517
##
File path:
clients/src/test/java/org/apache/kafka/clients/ClusterConnectionStatesTest.java
##
@@ -273,22 +273,21 @@ public void
ijuma commented on pull request #9294:
URL: https://github.com/apache/kafka/pull/9294#issuecomment-694647346
Have we cherry picked this to older branches? It seems like they will be
broken otherwise.
This is an automated
[
https://issues.apache.org/jira/browse/KAFKA-10495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
欧阳能达 resolved KAFKA-10495.
--
Resolution: Won't Fix
> Fix spelling mistake
>
>
> Key: KAFKA-10495
>
[
https://issues.apache.org/jira/browse/KAFKA-10495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17198095#comment-17198095
]
欧阳能达 commented on KAFKA-10495:
--
[~showuon] you are right!
> Fix spelling mistake
>
>
ouyangnengda closed pull request #9297:
URL: https://github.com/apache/kafka/pull/9297
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
showuon opened a new pull request #9301:
URL: https://github.com/apache/kafka/pull/9301
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including
showuon commented on pull request #9202:
URL: https://github.com/apache/kafka/pull/9202#issuecomment-694592201
Merge the latest trunk so that the flaky tests (addressed in
https://github.com/apache/kafka/pull/9294) can be fixed.
hachikuji commented on a change in pull request #8725:
URL: https://github.com/apache/kafka/pull/8725#discussion_r490627471
##
File path:
clients/src/test/java/org/apache/kafka/clients/producer/internals/TransactionEventSimulationTest.java
##
@@ -0,0 +1,147 @@
+/*
+ *
hachikuji commented on a change in pull request #9300:
URL: https://github.com/apache/kafka/pull/9300#discussion_r490604721
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -1732,45 +1732,57 @@ class KafkaApis(val requestChannel: RequestChannel,
mumrah commented on a change in pull request #9100:
URL: https://github.com/apache/kafka/pull/9100#discussion_r490594335
##
File path: core/src/main/scala/kafka/cluster/Partition.scala
##
@@ -618,9 +682,9 @@ class Partition(val topicPartition: TopicPartition,
// since
hachikuji commented on a change in pull request #9299:
URL: https://github.com/apache/kafka/pull/9299#discussion_r490586608
##
File path: core/src/main/scala/kafka/utils/Implicits.scala
##
@@ -46,4 +47,21 @@ object Implicits {
}
+ /**
+ * Exposes `foreachKv` which
hachikuji merged pull request #9279:
URL: https://github.com/apache/kafka/pull/9279
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
cmccabe commented on pull request #9279:
URL: https://github.com/apache/kafka/pull/9279#issuecomment-694510055
LGTM
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
hachikuji commented on pull request #9284:
URL: https://github.com/apache/kafka/pull/9284#issuecomment-694503921
@chia7712 Can you take a look at DynamicConnectionsQuotaTest? Looks like
this patch is causing it to fail.
mumrah commented on a change in pull request #9100:
URL: https://github.com/apache/kafka/pull/9100#discussion_r490562630
##
File path: core/src/main/scala/kafka/cluster/Partition.scala
##
@@ -920,7 +986,7 @@ class Partition(val topicPartition: TopicPartition,
* is
mumrah commented on a change in pull request #9100:
URL: https://github.com/apache/kafka/pull/9100#discussion_r490561028
##
File path: core/src/main/scala/kafka/cluster/Partition.scala
##
@@ -920,7 +986,7 @@ class Partition(val topicPartition: TopicPartition,
* is
mumrah commented on pull request #9294:
URL: https://github.com/apache/kafka/pull/9294#issuecomment-694490391
Thanks for the patch @jolshan!
This is an automated message from the Apache Git Service.
To respond to the
mumrah merged pull request #9294:
URL: https://github.com/apache/kafka/pull/9294
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
hachikuji commented on a change in pull request #9100:
URL: https://github.com/apache/kafka/pull/9100#discussion_r490530496
##
File path: core/src/main/scala/kafka/controller/KafkaController.scala
##
@@ -1763,6 +1768,143 @@ class KafkaController(val config: KafkaConfig,
}
mumrah commented on a change in pull request #9100:
URL: https://github.com/apache/kafka/pull/9100#discussion_r490542749
##
File path: core/src/main/scala/kafka/cluster/Partition.scala
##
@@ -200,9 +241,11 @@ class Partition(val topicPartition: TopicPartition,
// defined
hachikuji commented on a change in pull request #9100:
URL: https://github.com/apache/kafka/pull/9100#discussion_r490527627
##
File path: core/src/main/scala/kafka/cluster/Partition.scala
##
@@ -1246,6 +1364,50 @@ class Partition(val topicPartition: TopicPartition,
}
}
Prateek Agarwal created KAFKA-10499:
---
Summary: 4 Unit Tests are breaking after addition of a new A
record to "apache.org"
Key: KAFKA-10499
URL: https://issues.apache.org/jira/browse/KAFKA-10499
abbccdda commented on a change in pull request #8295:
URL: https://github.com/apache/kafka/pull/8295#discussion_r490509357
##
File path:
clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetcherTest.java
##
@@ -2496,46 +2501,81 @@ public void
abbccdda commented on a change in pull request #8295:
URL: https://github.com/apache/kafka/pull/8295#discussion_r490507674
##
File path:
clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetcherTest.java
##
@@ -2496,46 +2501,81 @@ public void
abbccdda commented on a change in pull request #8295:
URL: https://github.com/apache/kafka/pull/8295#discussion_r490506434
##
File path:
clients/src/test/java/org/apache/kafka/clients/admin/KafkaAdminClientTest.java
##
@@ -3732,41 +3734,43 @@ public void testListOffsets()
abbccdda commented on a change in pull request #8295:
URL: https://github.com/apache/kafka/pull/8295#discussion_r490504884
##
File path: clients/src/main/resources/common/message/ListOffsetResponse.json
##
@@ -48,7 +48,7 @@
"about": "The timestamp associated with
hachikuji commented on a change in pull request #9100:
URL: https://github.com/apache/kafka/pull/9100#discussion_r490464756
##
File path: core/src/main/scala/kafka/cluster/Partition.scala
##
@@ -157,6 +158,44 @@ case class OngoingReassignmentState(addingReplicas:
Seq[Int],
abbccdda commented on pull request #8295:
URL: https://github.com/apache/kafka/pull/8295#issuecomment-694430943
@mimaison Sorry was on the vacation, will take another look.
This is an automated message from the Apache Git
tombentley commented on pull request #8878:
URL: https://github.com/apache/kafka/pull/8878#issuecomment-694425788
@omkreddy I fixed a failing test. The rest look unrelated. Could you trigger
the build again please?
This is
jolshan commented on a change in pull request #9294:
URL: https://github.com/apache/kafka/pull/9294#discussion_r490461933
##
File path: clients/src/test/java/org/apache/kafka/clients/ClientUtilsTest.java
##
@@ -102,20 +102,20 @@ public void testResolveUnknownHostException()
dajac commented on pull request #8897:
URL: https://github.com/apache/kafka/pull/8897#issuecomment-694410433
@hachikuji @chia7712 FYI
This is an automated message from the Apache Git Service.
To respond to the message,
[
https://issues.apache.org/jira/browse/KAFKA-10497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17197885#comment-17197885
]
David Jacot commented on KAFKA-10497:
-
[~hachikuji] [~chia7712] FYI
> Convert group/transaction
[
https://issues.apache.org/jira/browse/KAFKA-10497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17197881#comment-17197881
]
David Jacot commented on KAFKA-10497:
-
I already have a PR for the consumer protocol part:
dongjinleekr commented on a change in pull request #9284:
URL: https://github.com/apache/kafka/pull/9284#discussion_r490449947
##
File path: core/src/main/scala/kafka/server/DynamicBrokerConfig.scala
##
@@ -910,6 +903,11 @@ class DynamicListenerConfig(server: KafkaServer)
rondagostino opened a new pull request #9300:
URL: https://github.com/apache/kafka/pull/9300
*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-10493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pedro Gontijo updated KAFKA-10493:
--
Affects Version/s: (was: 2.3.0)
> Ktable out-of-order updates are not being ignored
>
tombentley commented on pull request #9266:
URL: https://github.com/apache/kafka/pull/9266#issuecomment-694377628
@dongjinleekr done.
This is an automated message from the Apache Git Service.
To respond to the message,
jolshan commented on a change in pull request #9294:
URL: https://github.com/apache/kafka/pull/9294#discussion_r490423860
##
File path:
clients/src/test/java/org/apache/kafka/clients/ClusterConnectionStatesTest.java
##
@@ -273,22 +273,21 @@ public void
mumrah commented on a change in pull request #9294:
URL: https://github.com/apache/kafka/pull/9294#discussion_r490417685
##
File path:
clients/src/test/java/org/apache/kafka/clients/ClusterConnectionStatesTest.java
##
@@ -273,22 +273,21 @@ public void
Jason Gustafson created KAFKA-10498:
---
Summary: Consumer should do offset/epoch validation through
`Fetch` when possible
Key: KAFKA-10498
URL: https://issues.apache.org/jira/browse/KAFKA-10498
[
https://issues.apache.org/jira/browse/KAFKA-10283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
highluck reassigned KAFKA-10283:
Assignee: highluck
> Consolidate client-level and consumer-level assignment within ClientState
>
chia7712 commented on a change in pull request #9262:
URL: https://github.com/apache/kafka/pull/9262#discussion_r490405191
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateDirectory.java
##
@@ -280,7 +280,7 @@ synchronized void
Jason Gustafson created KAFKA-10497:
---
Summary: Convert group/transaction coordinator metadata schemas to
use generated protocol
Key: KAFKA-10497
URL: https://issues.apache.org/jira/browse/KAFKA-10497
chia7712 commented on pull request #9296:
URL: https://github.com/apache/kafka/pull/9296#issuecomment-694355722
@dongjinleekr thanks for review!
This is an automated message from the Apache Git Service.
To respond to the
dongjinleekr commented on a change in pull request #9266:
URL: https://github.com/apache/kafka/pull/9266#discussion_r490383726
##
File path: core/src/test/scala/kafka/utils/LoggingTest.scala
##
@@ -58,4 +60,20 @@ class LoggingTest extends Logging {
[
https://issues.apache.org/jira/browse/KAFKA-10491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ron Dagostino reassigned KAFKA-10491:
-
Assignee: Ron Dagostino
> Check authorizations before other criteria in KafkaApis
>
[
https://issues.apache.org/jira/browse/KAFKA-10372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison updated KAFKA-10372:
---
Fix Version/s: (was: 2.6.1)
> [JAVA 11] Unrecognized VM option PrintGCDateStamps
>
[
https://issues.apache.org/jira/browse/KAFKA-10496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan updated KAFKA-10496:
---
Description:
ClientUtilsTest and ClusterConnectionStatesTest currently use an external DNS
[
https://issues.apache.org/jira/browse/KAFKA-10496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan updated KAFKA-10496:
---
Description:
ClientUtilsTest and ClusterConnectionStatesTest currently use an external DNS
Justine Olshan created KAFKA-10496:
--
Summary: Create an in-memory DNS server for ClientUtilsTest and
ClusterConnectionStatesTest
Key: KAFKA-10496
URL: https://issues.apache.org/jira/browse/KAFKA-10496
jolshan commented on pull request #9294:
URL: https://github.com/apache/kafka/pull/9294#issuecomment-694325685
Also created the issue https://issues.apache.org/jira/browse/KAFKA-10496
This is an automated message from the
jolshan commented on pull request #9294:
URL: https://github.com/apache/kafka/pull/9294#issuecomment-694319833
I also like @dajac's suggestion. I've updated the PR so that the tests
assert more than 1 address as @mumrah said.
mimaison commented on a change in pull request #8730:
URL: https://github.com/apache/kafka/pull/8730#discussion_r490344407
##
File path:
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorConnectorsIntegrationTest.java
##
@@ -201,26 +213,24 @@ public void
ijuma commented on a change in pull request #9299:
URL: https://github.com/apache/kafka/pull/9299#discussion_r490344276
##
File path: core/src/main/scala/kafka/tools/GetOffsetShell.scala
##
@@ -133,7 +133,7 @@ object GetOffsetShell {
}
}
-
ijuma opened a new pull request #9299:
URL: https://github.com/apache/kafka/pull/9299
`foreachKv` invokes `foreachEntry` in Scala 2.13 and falls back to
`foreach` in Scala 2.12.
This change requires a newer version of scala-collection-compat, so
update it to the latest version
edoardocomar commented on a change in pull request #8730:
URL: https://github.com/apache/kafka/pull/8730#discussion_r490335096
##
File path:
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorConnectorsIntegrationTest.java
##
@@ -283,49 +296,140 @@ public void
ouyangnengda commented on pull request #9297:
URL: https://github.com/apache/kafka/pull/9297#issuecomment-694282470
ok
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-10313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17197722#comment-17197722
]
Varsha Abhinandan commented on KAFKA-10313:
---
The issue mentioned in KAFKA-9543 seems to
[
https://issues.apache.org/jira/browse/KAFKA-10313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17197722#comment-17197722
]
Varsha Abhinandan edited comment on KAFKA-10313 at 9/17/20, 2:26 PM:
-
showuon commented on pull request #9202:
URL: https://github.com/apache/kafka/pull/9202#issuecomment-694267556
@ijuma , thanks for the comments. I've updated in this commit:
https://github.com/apache/kafka/pull/9202/commits/97fe0a53d450d103e25dae0669c3ac803d7afe40.
Thank you!
showuon commented on a change in pull request #9202:
URL: https://github.com/apache/kafka/pull/9202#discussion_r490283148
##
File path:
core/src/main/scala/kafka/coordinator/group/GroupMetadataManager.scala
##
@@ -1139,6 +1139,7 @@ object GroupMetadataManager {
private
cadonna commented on a change in pull request #9262:
URL: https://github.com/apache/kafka/pull/9262#discussion_r490189904
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateDirectory.java
##
@@ -306,40 +306,55 @@ public synchronized void
tombentley commented on pull request #9266:
URL: https://github.com/apache/kafka/pull/9266#issuecomment-694255418
Many thanks @ijuma all fixed.
This is an automated message from the Apache Git Service.
To respond to the
ijuma commented on a change in pull request #9202:
URL: https://github.com/apache/kafka/pull/9202#discussion_r490262817
##
File path:
core/src/main/scala/kafka/coordinator/group/GroupMetadataManager.scala
##
@@ -1139,6 +1139,7 @@ object GroupMetadataManager {
private val
ijuma commented on a change in pull request #9266:
URL: https://github.com/apache/kafka/pull/9266#discussion_r490260948
##
File path: core/src/test/scala/kafka/utils/LoggingTest.scala
##
@@ -58,4 +60,22 @@ class LoggingTest extends Logging {
ijuma commented on a change in pull request #9266:
URL: https://github.com/apache/kafka/pull/9266#discussion_r490259458
##
File path: core/src/main/scala/kafka/utils/Log4jController.scala
##
@@ -29,6 +29,24 @@ import scala.jdk.CollectionConverters._
object Log4jController {
[
https://issues.apache.org/jira/browse/KAFKA-10495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17197699#comment-17197699
]
Luke Chen commented on KAFKA-10495:
---
*if and only if* (shortened as *iff*) , fyi
dongjinleekr commented on pull request #9297:
URL: https://github.com/apache/kafka/pull/9297#issuecomment-694245811
Hi @ouyangnengda,
I think it is not a problem. 'iff' means 'if and only if'. Please see
[here](https://www.oxfordlearnersdictionaries.com/definition/english/iff).
ijuma commented on a change in pull request #9266:
URL: https://github.com/apache/kafka/pull/9266#discussion_r490256227
##
File path: core/src/test/scala/kafka/utils/LoggingTest.scala
##
@@ -58,4 +60,20 @@ class LoggingTest extends Logging {
ijuma commented on a change in pull request #9223:
URL: https://github.com/apache/kafka/pull/9223#discussion_r490246634
##
File path:
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/record/RecordBatchBenchmarkSuite.java
##
@@ -0,0 +1,149 @@
+/*
+ * Licensed to the Apache
ijuma opened a new pull request #9298:
URL: https://github.com/apache/kafka/pull/9298
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgrade notes)
ouyangnengda opened a new pull request #9297:
URL: https://github.com/apache/kafka/pull/9297
The iff is wrong word.I fixed it to if.
This is an automated message from the Apache Git Service.
To respond to the message,
[
https://issues.apache.org/jira/browse/KAFKA-10494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andy Coates updated KAFKA-10494:
Description:
Calling `enableSendingOldValues` on many nodes, e.g. `KTableFilter`, is
mumrah commented on pull request #9294:
URL: https://github.com/apache/kafka/pull/9294#issuecomment-694216516
Agreed with @dajac's suggestion. Maybe for this change we could have the
assertion as > 1 rather than equalling a specific value
[
https://issues.apache.org/jira/browse/KAFKA-10494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andy Coates updated KAFKA-10494:
Description:
Calling `enableSendingOldValues` on many nodes, e.g. `KTableFilter`, is
[
https://issues.apache.org/jira/browse/KAFKA-10494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andy Coates updated KAFKA-10494:
Description:
Calling `enableSendingOldValues` on many nodes, e.g. `KTableFilter`, is
big-andy-coates commented on pull request #9156:
URL: https://github.com/apache/kafka/pull/9156#issuecomment-694203001
@mjsax - ready for another review.
- boolean `onlyIfMaterialized` is now flipped to `forceMaterialization`.
- `KTableFilter` constructor initialized internal
欧阳能达 created KAFKA-10495:
Summary: Fix spelling mistake
Key: KAFKA-10495
URL: https://issues.apache.org/jira/browse/KAFKA-10495
Project: Kafka
Issue Type: Improvement
Components: clients,
[
https://issues.apache.org/jira/browse/KAFKA-10494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andy Coates updated KAFKA-10494:
Description:
Calling `enableSendingOldValues` on many nodes, e.g. `KTableFilter`, is
[
https://issues.apache.org/jira/browse/KAFKA-10494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andy Coates updated KAFKA-10494:
Description:
Calling `enableSendingOldValues` on many nodes, e.g. `KTableFilter`, is
[
https://issues.apache.org/jira/browse/KAFKA-10488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17197622#comment-17197622
]
Mickael Maison commented on KAFKA-10488:
Hi [~vodevops],
This looks like a question about CMAK
big-andy-coates commented on a change in pull request #9156:
URL: https://github.com/apache/kafka/pull/9156#discussion_r487060524
##
File path:
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableFilterTest.java
##
@@ -295,12 +295,39 @@ public void
big-andy-coates commented on a change in pull request #9156:
URL: https://github.com/apache/kafka/pull/9156#discussion_r490154341
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableAbstractJoin.java
##
@@ -39,9 +39,15 @@
}
[
https://issues.apache.org/jira/browse/KAFKA-10494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andy Coates updated KAFKA-10494:
Description:
Calling `enableSendingOldValues` on many nodes, e.g. `KTableFilter`, is
big-andy-coates commented on a change in pull request #9156:
URL: https://github.com/apache/kafka/pull/9156#discussion_r490152263
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java
##
@@ -182,6 +182,8 @@ public String
Andy Coates created KAFKA-10494:
---
Summary: Streams: enableSendingOldValues should not call parent if
node is itself materialized
Key: KAFKA-10494
URL: https://issues.apache.org/jira/browse/KAFKA-10494
[
https://issues.apache.org/jira/browse/KAFKA-10494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andy Coates updated KAFKA-10494:
Description:
Calling `enableSendingOldValues` on many nodes, e.g. `KTableFilter`, is
big-andy-coates commented on a change in pull request #9156:
URL: https://github.com/apache/kafka/pull/9156#discussion_r490152263
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java
##
@@ -182,6 +182,8 @@ public String
big-andy-coates commented on a change in pull request #9156:
URL: https://github.com/apache/kafka/pull/9156#discussion_r490147517
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableAggregate.java
##
@@ -47,8 +47,10 @@
}
@Override
cadonna commented on a change in pull request #8892:
URL: https://github.com/apache/kafka/pull/8892#discussion_r490101377
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamsAssignmentScaleTest.java
##
@@ -0,0 +1,256 @@
+/*
+ * Licensed to
dajac commented on pull request #9294:
URL: https://github.com/apache/kafka/pull/9294#issuecomment-694131412
Netty used a in-memory DNS server for such tests:
https://github.com/netty/netty/blob/master/resolver-dns/src/test/java/io/netty/resolver/dns/TestDnsServer.java.
I suppose that we
omkreddy commented on pull request #8878:
URL: https://github.com/apache/kafka/pull/8878#issuecomment-694129604
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please
vgvineet4 commented on pull request #9254:
URL: https://github.com/apache/kafka/pull/9254#issuecomment-69400
@wcarlson5 please have a look
This is an automated message from the Apache Git Service.
To respond to the
Pedro Gontijo created KAFKA-10493:
-
Summary: Ktable out-of-order updates are not being ignored
Key: KAFKA-10493
URL: https://issues.apache.org/jira/browse/KAFKA-10493
Project: Kafka
Issue
tombentley commented on pull request #8878:
URL: https://github.com/apache/kafka/pull/8878#issuecomment-693954974
@mimaison @omkreddy could one of you do the build again?
This is an automated message from the Apache Git
tombentley commented on pull request #9252:
URL: https://github.com/apache/kafka/pull/9252#issuecomment-693953116
@abbccdda or perhaps @cmccabe or @dajac any chance one of you could take a
look?
This is an automated message
[
https://issues.apache.org/jira/browse/KAFKA-6791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17197411#comment-17197411
]
Jeff Widman commented on KAFKA-6791:
Should this be closed as "wontfix"?
The associated PR was
1 - 100 of 102 matches
Mail list logo
