kkonstantine merged pull request #8693:
URL: https://github.com/apache/kafka/pull/8693
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
kkonstantine commented on pull request #7942:
URL: https://github.com/apache/kafka/pull/7942#issuecomment-631268323
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on
kkonstantine commented on pull request #8118:
URL: https://github.com/apache/kafka/pull/8118#issuecomment-631264425
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on
kkonstantine commented on pull request #8135:
URL: https://github.com/apache/kafka/pull/8135#issuecomment-631262289
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on
kkonstantine commented on pull request #8444:
URL: https://github.com/apache/kafka/pull/8444#issuecomment-631261878
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on
kkonstantine commented on a change in pull request #8511:
URL: https://github.com/apache/kafka/pull/8511#discussion_r427761810
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaConfigBackingStore.java
##
@@ -280,8 +280,8 @@ public void stop() {
kkonstantine commented on pull request #8608:
URL: https://github.com/apache/kafka/pull/8608#issuecomment-631254109
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on
mjsax commented on a change in pull request #8679:
URL: https://github.com/apache/kafka/pull/8679#discussion_r427752328
##
File path:
streams/src/test/java/org/apache/kafka/streams/kstream/internals/graph/StreamsGraphTest.java
##
@@ -254,6 +253,7 @@ private Topology
getTopolo
ableegoldman opened a new pull request #8697:
URL: https://github.com/apache/kafka/pull/8697
Kicking this off with just the min and max sensors for the INFO-level task
metrics.
There is an existing `Percentiles` sensor implementation, but I'm having
trouble convincing myself that it
ableegoldman commented on pull request #8697:
URL: https://github.com/apache/kafka/pull/8697#issuecomment-631225868
call for review @guozhangwang @mjsax @vvcephei
This is an automated message from the Apache Git Service.
To
chia7712 commented on a change in pull request #8657:
URL: https://github.com/apache/kafka/pull/8657#discussion_r427723802
##
File path: core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala
##
@@ -369,6 +369,31 @@ class GroupCoordinator(val brokerId: Int,
}
[
https://issues.apache.org/jira/browse/KAFKA-9982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111563#comment-17111563
]
Chris Egerton edited comment on KAFKA-9982 at 5/20/20, 2:43 AM:
---
[
https://issues.apache.org/jira/browse/KAFKA-8159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111694#comment-17111694
]
John Roesler commented on KAFKA-8159:
-
Hi [~ableegoldman] ,
Thanks for pointing this
hachikuji commented on pull request #8311:
URL: https://github.com/apache/kafka/pull/8311#issuecomment-631178938
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
mjsax commented on a change in pull request #6824:
URL: https://github.com/apache/kafka/pull/6824#discussion_r427675991
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java
##
@@ -700,12 +703,29 @@ public void process(final ProcessorS
mjsax commented on a change in pull request #6824:
URL: https://github.com/apache/kafka/pull/6824#discussion_r427675683
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorTopologyTest.java
##
@@ -213,6 +215,48 @@ public void testDrivingSt
mjsax commented on a change in pull request #8679:
URL: https://github.com/apache/kafka/pull/8679#discussion_r427674857
##
File path:
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/KStream.scala
##
@@ -232,10 +232,53 @@ class KStream[K, V](val inne
mjsax commented on pull request #8650:
URL: https://github.com/apache/kafka/pull/8650#issuecomment-631153303
Retest this please.
This is an automated message from the Apache Git Service.
To respond to the message, please log
gwenshap commented on pull request #8650:
URL: https://github.com/apache/kafka/pull/8650#issuecomment-631127554
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-10021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111584#comment-17111584
]
Arjun Satish commented on KAFKA-10021:
--
Thanks, [~hachikuji]!
> When reading to th
[
https://issues.apache.org/jira/browse/KAFKA-10021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson updated KAFKA-10021:
Comment: was deleted
(was: [~wicknicks] Each consumer instance has a separate connection t
[
https://issues.apache.org/jira/browse/KAFKA-10021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111581#comment-17111581
]
Jason Gustafson commented on KAFKA-10021:
-
[~wicknicks] Each consumer instance h
[
https://issues.apache.org/jira/browse/KAFKA-10021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111580#comment-17111580
]
Jason Gustafson commented on KAFKA-10021:
-
[~wicknicks] Each consumer instance h
pgwhalen commented on a change in pull request #6824:
URL: https://github.com/apache/kafka/pull/6824#discussion_r427629040
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java
##
@@ -700,12 +703,29 @@ public void process(final Process
pgwhalen commented on a change in pull request #6824:
URL: https://github.com/apache/kafka/pull/6824#discussion_r427628532
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorTopologyTest.java
##
@@ -213,6 +215,48 @@ public void testDrivin
guozhangwang merged pull request #8681:
URL: https://github.com/apache/kafka/pull/8681
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
vvcephei commented on a change in pull request #8679:
URL: https://github.com/apache/kafka/pull/8679#discussion_r427623832
##
File path:
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/KStream.scala
##
@@ -232,10 +232,53 @@ class KStream[K, V](val i
[
https://issues.apache.org/jira/browse/KAFKA-9982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton resolved KAFKA-9982.
--
Resolution: Not A Bug
> [kafka-connect] Source connector does not guarantee at least once deliv
[
https://issues.apache.org/jira/browse/KAFKA-9982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111563#comment-17111563
]
Chris Egerton commented on KAFKA-9982:
--
[~q.xu] I'd like to mark this closed, but if
vvcephei commented on a change in pull request #8679:
URL: https://github.com/apache/kafka/pull/8679#discussion_r427621713
##
File path:
streams/src/test/java/org/apache/kafka/streams/kstream/internals/graph/StreamsGraphTest.java
##
@@ -254,6 +253,7 @@ private Topology
getTop
vvcephei commented on a change in pull request #8679:
URL: https://github.com/apache/kafka/pull/8679#discussion_r427621177
##
File path: streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java
##
@@ -815,9 +815,10 @@
*
* @param topic the topic name
vvcephei commented on a change in pull request #8679:
URL: https://github.com/apache/kafka/pull/8679#discussion_r427617788
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/AbstractResetIntegrationTest.java
##
@@ -484,8 +493,14 @@ private Topology
setup
vvcephei commented on a change in pull request #8696:
URL: https://github.com/apache/kafka/pull/8696#discussion_r427615915
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/TaskAssignorConvergenceTest.java
##
@@ -338,7 +338,7 @@ privat
vvcephei opened a new pull request #8696:
URL: https://github.com/apache/kafka/pull/8696
We should treat standbys similarly to active stateful tasks and
re-assign them to instances that are already caught-up on them
while we warm them up on the desired destination, instead of
immedi
mjsax commented on a change in pull request #6824:
URL: https://github.com/apache/kafka/pull/6824#discussion_r427605702
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorTopologyTest.java
##
@@ -213,6 +215,48 @@ public void testDrivingSt
mjsax commented on a change in pull request #6824:
URL: https://github.com/apache/kafka/pull/6824#discussion_r427603579
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java
##
@@ -700,12 +703,29 @@ public void process(final ProcessorS
guozhangwang merged pull request #8682:
URL: https://github.com/apache/kafka/pull/8682
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
mjsax commented on a change in pull request #8049:
URL: https://github.com/apache/kafka/pull/8049#discussion_r427591063
##
File path:
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/Serdes.scala
##
@@ -30,12 +32,15 @@ object Serdes {
implicit def JavaLon
rnpridgeon commented on pull request #8691:
URL: https://github.com/apache/kafka/pull/8691#issuecomment-631074323
Since MetricsReporter instances are the ultimate consumers of the
MetadataContext instance I would like to propose moving construction
MetricsContext there. This would allow ea
[
https://issues.apache.org/jira/browse/KAFKA-10018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-10018:
Summary: Change command line tool from /bin/sh to /bin/bash (was: Change
sh to bash)
>
[
https://issues.apache.org/jira/browse/KAFKA-10018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-10018:
Summary: Change command line tools from /bin/sh to /bin/bash (was:
Change command line
ableegoldman commented on pull request #8682:
URL: https://github.com/apache/kafka/pull/8682#issuecomment-631072710
Well, `releaseLockedUnassignedTaskDirectories` does exactly that -- it only
releases the unassigned task directories (which we just lock in order to report
the offset sums in
guozhangwang commented on pull request #8682:
URL: https://github.com/apache/kafka/pull/8682#issuecomment-631070764
> @guozhangwang Why would we warn? You mean if we have any tasks leftover?
These are just tasks that are currently assigned
I think we would only have leftover tasks if
[
https://issues.apache.org/jira/browse/KAFKA-9929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jorge Esteban Quilcate Otoya updated KAFKA-9929:
Labels: needs-kip (was: )
> Support reverse iterator on WindowStor
ableegoldman commented on pull request #8682:
URL: https://github.com/apache/kafka/pull/8682#issuecomment-631068928
@guozhangwang Why would we warn? You mean if we have any tasks leftover?
These are just tasks that are currently assigned
---
guozhangwang commented on pull request #8682:
URL: https://github.com/apache/kafka/pull/8682#issuecomment-631068405
I think it is still better to log a warn at the end of
`releaseLockedUnassignedTaskDirectories` if the map is not empty at the end,
will add it before merging.
guozhangwang commented on pull request #8694:
URL: https://github.com/apache/kafka/pull/8694#issuecomment-631065860
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub a
mjsax commented on a change in pull request #8679:
URL: https://github.com/apache/kafka/pull/8679#discussion_r427581563
##
File path:
streams/src/test/java/org/apache/kafka/streams/kstream/internals/graph/StreamsGraphTest.java
##
@@ -254,6 +253,7 @@ private Topology
getTopolo
mjsax commented on a change in pull request #8679:
URL: https://github.com/apache/kafka/pull/8679#discussion_r427579474
##
File path: streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java
##
@@ -815,9 +815,10 @@
*
* @param topic the topic name
*
mjsax commented on a change in pull request #8679:
URL: https://github.com/apache/kafka/pull/8679#discussion_r427578311
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/AbstractResetIntegrationTest.java
##
@@ -484,8 +493,14 @@ private Topology
setupTop
mjsax commented on a change in pull request #8679:
URL: https://github.com/apache/kafka/pull/8679#discussion_r426211425
##
File path: streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java
##
@@ -846,16 +847,13 @@
* from the auto-generated topic using default
[
https://issues.apache.org/jira/browse/KAFKA-10016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111501#comment-17111501
]
Matthias J. Sax commented on KAFKA-10016:
-
Ah sorry. Linked the wrong KIP. The f
[
https://issues.apache.org/jira/browse/KAFKA-10021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111493#comment-17111493
]
Arjun Satish commented on KAFKA-10021:
--
[~hachikuji] [~skaundinya] do consumers in
[
https://issues.apache.org/jira/browse/KAFKA-4327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111489#comment-17111489
]
Matthias J. Sax commented on KAFKA-4327:
Not 100% sure. It's all a little tricky.
vvcephei commented on a change in pull request #8679:
URL: https://github.com/apache/kafka/pull/8679#discussion_r427543403
##
File path:
streams/src/test/java/org/apache/kafka/streams/StreamsBuilderTest.java
##
@@ -285,7 +286,28 @@ public void shouldProcessViaThroughTopic() {
rhauch commented on a change in pull request #8691:
URL: https://github.com/apache/kafka/pull/8691#discussion_r426971298
##
File path:
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorConnectorConfig.java
##
@@ -270,9 +272,15 @@ Duration adminTimeout() {
rhauch commented on pull request #8691:
URL: https://github.com/apache/kafka/pull/8691#issuecomment-631035724
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
nizhikov opened a new pull request #8695:
URL: https://github.com/apache/kafka/pull/8695
*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
[
https://issues.apache.org/jira/browse/KAFKA-9992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-9992:
Fix Version/s: 2.4.2
> EmbeddedKafkaCluster.deleteTopicAndWait not working with kafka_2.13
> --
hachikuji commented on a change in pull request #8376:
URL: https://github.com/apache/kafka/pull/8376#discussion_r427535098
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java
##
@@ -1098,8 +1098,20 @@ Node selectReadReplica(TopicPartit
vvcephei commented on a change in pull request #8679:
URL: https://github.com/apache/kafka/pull/8679#discussion_r426337376
##
File path: streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java
##
@@ -846,16 +847,13 @@
* from the auto-generated topic using defa
[
https://issues.apache.org/jira/browse/KAFKA-9992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111436#comment-17111436
]
Andras Katona commented on KAFKA-9992:
--
Okay :) cool!
> EmbeddedKafkaCluster.delete
glasser commented on pull request #8692:
URL: https://github.com/apache/kafka/pull/8692#issuecomment-631018459
I don't know why my name was mentioned here.
This is an automated message from the Apache Git Service.
To respond
[
https://issues.apache.org/jira/browse/KAFKA-9992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111433#comment-17111433
]
John Roesler commented on KAFKA-9992:
-
No problem, [~akatona] ! Thanks again for the
[
https://issues.apache.org/jira/browse/KAFKA-9992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-9992:
Fix Version/s: 2.5.1
> EmbeddedKafkaCluster.deleteTopicAndWait not working with kafka_2.13
> --
[
https://issues.apache.org/jira/browse/KAFKA-8638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111427#comment-17111427
]
Hai Lin commented on KAFKA-8638:
What's the current status is this kip? I see this will b
[
https://issues.apache.org/jira/browse/KAFKA-9992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-9992:
Fix Version/s: 2.6.0
> EmbeddedKafkaCluster.deleteTopicAndWait not working with kafka_2.13
> --
vvcephei merged pull request #8673:
URL: https://github.com/apache/kafka/pull/8673
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
vvcephei commented on pull request #8673:
URL: https://github.com/apache/kafka/pull/8673#issuecomment-631004738
The tests that failed are known to be flaky and seem unrelated to this
change:
org.apache.kafka.streams.integration.EosBetaUpgradeIntegrationTest.shouldUpgradeFromEosAlpha
vvcephei commented on pull request #8689:
URL: https://github.com/apache/kafka/pull/8689#issuecomment-631003896
Thanks, @cadonna !
This is an automated message from the Apache Git Service.
To respond to the message, please lo
vvcephei merged pull request #8689:
URL: https://github.com/apache/kafka/pull/8689
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
vvcephei commented on pull request #8689:
URL: https://github.com/apache/kafka/pull/8689#issuecomment-631002557
Test failures were unrelated:
kafka.api.SaslPlaintextConsumerTest.testCoordinatorFailover
and 3x:
org.apache.kafka.streams.integration.EosBetaUpgradeIntegrationTest.shou
[
https://issues.apache.org/jira/browse/KAFKA-10020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111397#comment-17111397
]
Matthias J. Sax commented on KAFKA-10020:
-
[~lmnet] I added you to the list of c
[
https://issues.apache.org/jira/browse/KAFKA-10020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-10020:
Labels: kip (was: )
> KIP-616: Rename implicit Serdes instances in kafka-streams-scala
>
[
https://issues.apache.org/jira/browse/KAFKA-10020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-10020:
---
Assignee: Yuriy Badalyantc
> KIP-616: Rename implicit Serdes instances in kafka-str
[
https://issues.apache.org/jira/browse/KAFKA-9216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111394#comment-17111394
]
Greg Harris commented on KAFKA-9216:
I believe that KAFKA-5087 has an intent similar
[
https://issues.apache.org/jira/browse/KAFKA-10016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111393#comment-17111393
]
David Mollitor commented on KAFKA-10016:
[~mjsax] looks like it was replaced wit
Sophie Blee-Goldman created KAFKA-10025:
---
Summary: Segfault in RocksDB Statistics
Key: KAFKA-10025
URL: https://issues.apache.org/jira/browse/KAFKA-10025
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-9987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111361#comment-17111361
]
Hai Lin commented on KAFKA-9987:
[~ableegoldman] do you think the pull request is ready t
[
https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111343#comment-17111343
]
Boyang Chen commented on KAFKA-9891:
Sorry I was oncall last week. Will take another
[
https://issues.apache.org/jira/browse/KAFKA-10021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111338#comment-17111338
]
Jason Gustafson commented on KAFKA-10021:
-
For a little more detail, the problem
Anna Povzner created KAFKA-10024:
Summary: Add dynamic configuration and enforce quota for per-IP
connection rate limits
Key: KAFKA-10024
URL: https://issues.apache.org/jira/browse/KAFKA-10024
Project
chia7712 commented on a change in pull request #8657:
URL: https://github.com/apache/kafka/pull/8657#discussion_r427435780
##
File path: core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala
##
@@ -369,6 +369,31 @@ class GroupCoordinator(val brokerId: Int,
}
[
https://issues.apache.org/jira/browse/KAFKA-9998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111317#comment-17111317
]
radai rosenblatt edited comment on KAFKA-9998 at 5/19/20, 4:23 PM:
[
https://issues.apache.org/jira/browse/KAFKA-9998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111317#comment-17111317
]
radai rosenblatt commented on KAFKA-9998:
-
i think thats wrong, for several reaso
hachikuji commented on a change in pull request #8657:
URL: https://github.com/apache/kafka/pull/8657#discussion_r427432140
##
File path: core/src/main/scala/kafka/cluster/Partition.scala
##
@@ -970,7 +970,16 @@ class Partition(val topicPartition: TopicPartition,
}
}
hachikuji commented on a change in pull request #8657:
URL: https://github.com/apache/kafka/pull/8657#discussion_r427430032
##
File path: core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala
##
@@ -369,6 +369,31 @@ class GroupCoordinator(val brokerId: Int,
}
abbccdda commented on pull request #8221:
URL: https://github.com/apache/kafka/pull/8221#issuecomment-630919038
@avalsa Hey there, just a reminder that we are one week away from the
feature freeze, so let's try to ramp up and get this into 2.6, thank you for
all the work so far!
abbccdda commented on pull request #8589:
URL: https://github.com/apache/kafka/pull/8589#issuecomment-630918452
@feyman2016 Thanks for the context. I don't worry too much for comment
vanish if you change the commit history, as they would not be gone but just
show as `outdated` on github. J
vvcephei commented on pull request #8689:
URL: https://github.com/apache/kafka/pull/8689#issuecomment-630915857
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please lo
vvcephei commented on pull request #8689:
URL: https://github.com/apache/kafka/pull/8689#issuecomment-630915569
test this please
This is an automated message from the Apache Git Service.
To respond to the message, please log
vvcephei commented on pull request #8689:
URL: https://github.com/apache/kafka/pull/8689#issuecomment-630915672
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and u
Anna Povzner created KAFKA-10023:
Summary: Enforce broker-wide and per-listener connection creation
rate (KIP-612, part 1)
Key: KAFKA-10023
URL: https://issues.apache.org/jira/browse/KAFKA-10023
Proje
[
https://issues.apache.org/jira/browse/KAFKA-9647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sören Henning updated KAFKA-9647:
-
Description:
*Preface:* This feature request originates from a [recently asked question on
Stack
ocadaruma commented on pull request #8693:
URL: https://github.com/apache/kafka/pull/8693#issuecomment-630884243
Fixed similar typos in those files. Thanks.
This is an automated message from the Apache Git Service.
To respond
bbejeck merged pull request #8622:
URL: https://github.com/apache/kafka/pull/8622
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 th
bbejeck commented on pull request #8622:
URL: https://github.com/apache/kafka/pull/8622#issuecomment-630882502
Thanks @showuon for the contribution!
This is an automated message from the Apache Git Service.
To respond to the
bbejeck commented on pull request #8622:
URL: https://github.com/apache/kafka/pull/8622#issuecomment-630882690
Merged #8622 into trunk.
This is an automated message from the Apache Git Service.
To respond to the message, plea
vvcephei commented on pull request #8673:
URL: https://github.com/apache/kafka/pull/8673#issuecomment-630880668
test this please
This is an automated message from the Apache Git Service.
To respond to the message, please log
vvcephei commented on pull request #8673:
URL: https://github.com/apache/kafka/pull/8673#issuecomment-630880367
test this please
This is an automated message from the Apache Git Service.
To respond to the message, please log
1 - 100 of 126 matches
Mail list logo
