[
https://issues.apache.org/jira/browse/KAFKA-9925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler reassigned KAFKA-9925:
---
Assignee: John Roesler
> Non-key KTable Joining may result in duplicate schema name in
[
https://issues.apache.org/jira/browse/KAFKA-9925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17094604#comment-17094604
]
John Roesler commented on KAFKA-9925:
-
Ah, right you are. So sorry I overlooked that part of the bug
[
https://issues.apache.org/jira/browse/KAFKA-9925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kin Siu updated KAFKA-9925:
---
Affects Version/s: 2.4.1
> Non-key KTable Joining result in duplicate schema name in confluence schema
>
Kin Siu created KAFKA-9925:
--
Summary: Non-key KTable Joining result in duplicate schema name in
confluence schema registry
Key: KAFKA-9925
URL: https://issues.apache.org/jira/browse/KAFKA-9925
Project:
[
https://issues.apache.org/jira/browse/KAFKA-9925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kin Siu updated KAFKA-9925:
---
Summary: Non-key KTable Joining may result in duplicate schema name in
confluence schema registry (was:
scoopex opened a new pull request #8573:
URL: https://github.com/apache/kafka/pull/8573
Provides the possibility to append connection infos to all executed commands:
```
$ export KAFKA_OPTS="--bootstrap-server
10.1.1.1:9092,10.1.1.1:9092,10.1.1.1:9092"
kafka-topics.sh --create
jeqo opened a new pull request #8572:
URL: https://github.com/apache/kafka/pull/8572
nit. Protocol docs describe partition numbers as follows:
> Topic partitions themselves are just ordered "commit logs" numbered 0, 1,
..., P.
I assume this is a typo, as partition numbers
[
https://issues.apache.org/jira/browse/KAFKA-9018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mario Molina updated KAFKA-9018:
Affects Version/s: 2.5.0
2.4.1
> Kafka Connect - throw clearer exceptions
[
https://issues.apache.org/jira/browse/KAFKA-9018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mario Molina updated KAFKA-9018:
Fix Version/s: 2.6.0
> Kafka Connect - throw clearer exceptions on serialisation errors
>
steverod commented on pull request #8543:
URL: https://github.com/apache/kafka/pull/8543#issuecomment-620710529
> @steverod : There seems to be compilation errors in JDK 8 test?
Hi @junrao -- Yes, there are, but they aren't mine (!!). No, really.
> @steverod : There seems to
pan3793 opened a new pull request #8575:
URL: https://github.com/apache/kafka/pull/8575
https://issues.apache.org/jira/browse/KAFKA-8713
https://cwiki.apache.org/confluence/display/KAFKA/KIP-581:+Value+of+optional+null+field+which+has+default+value
### Committer Checklist
guozhangwang commented on pull request #8564:
URL: https://github.com/apache/kafka/pull/8564#issuecomment-620783397
Also cherry-picked to 2.5.
This is an automated message from the Apache Git Service.
To respond to the
[
https://issues.apache.org/jira/browse/KAFKA-7317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17094781#comment-17094781
]
Matthias J. Sax commented on KAFKA-7317:
As reported on SO, when setting number of threads to
[
https://issues.apache.org/jira/browse/KAFKA-9925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17094799#comment-17094799
]
Matthias J. Sax commented on KAFKA-9925:
{quote}I'm wondering if now is a good time to deprecate
junrao commented on a change in pull request #8562:
URL: https://github.com/apache/kafka/pull/8562#discussion_r416760588
##
File path:
core/src/test/scala/unit/kafka/server/ReplicaAlterLogDirsThreadTest.scala
##
@@ -243,9 +245,9 @@ class ReplicaAlterLogDirsThreadTest {
[
https://issues.apache.org/jira/browse/KAFKA-9923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman updated KAFKA-9923:
---
Fix Version/s: 2.6.0
> Join window store duplicates can be compacted in changelog
>
[
https://issues.apache.org/jira/browse/KAFKA-9923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman updated KAFKA-9923:
---
Priority: Blocker (was: Critical)
> Join window store duplicates can be compacted
[
https://issues.apache.org/jira/browse/KAFKA-9925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17094772#comment-17094772
]
Guozhang Wang commented on KAFKA-9925:
--
[~vvcephei] Thanks for getting a look into this issue.
I'm
junrao commented on pull request #8566:
URL: https://github.com/apache/kafka/pull/8566#issuecomment-620701631
@leonardge : The failed test seems unrelated to the PR. Could you file a
separate PR to track that?
This is an
vvcephei opened a new pull request #8574:
URL: https://github.com/apache/kafka/pull/8574
* ensure that pseudo-topics get correctly prefixed with the app id at run
time
* update test to expect the app id prefix
### Committer Checklist (excluded from commit message)
- [ ] Verify
Wang Ge created KAFKA-9926:
--
Summary: Flaky test
PlaintextAdminIntegrationTest.testCreatePartitions
Key: KAFKA-9926
URL: https://issues.apache.org/jira/browse/KAFKA-9926
Project: Kafka
Issue Type:
ableegoldman commented on a change in pull request #8568:
URL: https://github.com/apache/kafka/pull/8568#discussion_r416814163
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/GlobalKTableEOSIntegrationTest.java
##
@@ -158,8 +158,9 @@ public void
guozhangwang commented on pull request #8574:
URL: https://github.com/apache/kafka/pull/8574#issuecomment-620787049
cc @abbccdda @mjsax to take a look?
This is an automated message from the Apache Git Service.
To respond to
[
https://issues.apache.org/jira/browse/KAFKA-7317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17094797#comment-17094797
]
Sophie Blee-Goldman commented on KAFKA-7317:
Also fixed via
kkonstantine commented on pull request #8204:
URL: https://github.com/apache/kafka/pull/8204#issuecomment-620795402
retest this please
This is an automated message from the Apache Git Service.
To respond to the message,
leonardge commented on pull request #8566:
URL: https://github.com/apache/kafka/pull/8566#issuecomment-620716514
Sure will do.
This is an automated message from the Apache Git Service.
To respond to the message, please log
cadonna commented on a change in pull request #8541:
URL: https://github.com/apache/kafka/pull/8541#discussion_r416761719
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/HighAvailabilityTaskAssignorTest.java
##
@@ -41,132 +54,107 @@
Jason Gustafson created KAFKA-9927:
--
Summary: Add support for varint types to message generator
Key: KAFKA-9927
URL: https://issues.apache.org/jira/browse/KAFKA-9927
Project: Kafka
Issue
hachikuji commented on pull request #8562:
URL: https://github.com/apache/kafka/pull/8562#issuecomment-620749823
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please
hachikuji commented on pull request #8562:
URL: https://github.com/apache/kafka/pull/8562#issuecomment-620749686
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on
hachikuji commented on pull request #8562:
URL: https://github.com/apache/kafka/pull/8562#issuecomment-620749977
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please
[
https://issues.apache.org/jira/browse/KAFKA-9925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17094729#comment-17094729
]
John Roesler commented on KAFKA-9925:
-
Ok, I've opened [https://github.com/apache/kafka/pull/8574] .
ableegoldman commented on a change in pull request #8568:
URL: https://github.com/apache/kafka/pull/8568#discussion_r416809469
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/OptimizedKTableIntegrationTest.java
##
@@ -163,8 +159,10 @@ public void
[
https://issues.apache.org/jira/browse/KAFKA-9127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17094791#comment-17094791
]
Matthias J. Sax commented on KAFKA-9127:
{quote}Does it qualify as a regression when the
[
https://issues.apache.org/jira/browse/KAFKA-9127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17092826#comment-17092826
]
Matthias J. Sax edited comment on KAFKA-9127 at 4/28/20, 6:54 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-9925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17094805#comment-17094805
]
Guozhang Wang commented on KAFKA-9925:
--
Ah yes!! Hope we can get KIP-591 by 2.6 :)
> Non-key KTable
kkonstantine commented on pull request #8204:
URL: https://github.com/apache/kafka/pull/8204#issuecomment-620803829
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log
pan3793 commented on pull request #7112:
URL: https://github.com/apache/kafka/pull/7112#issuecomment-620746182
I do a new implement at https://github.com/apache/kafka/pull/8575 follow the
ableegoldman commented on a change in pull request #8541:
URL: https://github.com/apache/kafka/pull/8541#discussion_r416810713
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/HighAvailabilityTaskAssignorTest.java
##
@@ -41,132
[
https://issues.apache.org/jira/browse/KAFKA-9916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17094777#comment-17094777
]
Matthias J. Sax commented on KAFKA-9916:
The original example was slightly different:
{code:java}
hachikuji commented on a change in pull request #8562:
URL: https://github.com/apache/kafka/pull/8562#discussion_r416760519
##
File path:
core/src/test/scala/unit/kafka/server/ReplicaAlterLogDirsThreadTest.scala
##
@@ -243,9 +245,9 @@ class ReplicaAlterLogDirsThreadTest {
vvcephei commented on a change in pull request #8574:
URL: https://github.com/apache/kafka/pull/8574#discussion_r416764158
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionWrapperSerde.java
##
@@ -76,6 +78,10 @@ public
leonardge commented on pull request #8566:
URL: https://github.com/apache/kafka/pull/8566#issuecomment-620735042
JIRA [here](https://issues.apache.org/jira/browse/KAFKA-9926).
This is an automated message from the Apache Git
[
https://issues.apache.org/jira/browse/KAFKA-9926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wang Ge updated KAFKA-9926:
---
Description:
Flaky test: kafka.api.PlaintextAdminIntegrationTest.testCreatePartitions
[
https://issues.apache.org/jira/browse/KAFKA-7317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17094800#comment-17094800
]
Matthias J. Sax commented on KAFKA-7317:
Sweet!
> Use collections subscription for main consumer
[
https://issues.apache.org/jira/browse/KAFKA-9127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17094801#comment-17094801
]
Sophie Blee-Goldman commented on KAFKA-9127:
Yep, if you can kick off tests on that PR and
vvcephei commented on pull request #8540:
URL: https://github.com/apache/kafka/pull/8540#issuecomment-620846265
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
vvcephei commented on pull request #8540:
URL: https://github.com/apache/kafka/pull/8540#issuecomment-620846462
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
vvcephei commented on a change in pull request #8568:
URL: https://github.com/apache/kafka/pull/8568#discussion_r416921971
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/EosIntegrationTest.java
##
@@ -810,21 +808,9 @@ private void
junrao commented on pull request #8543:
URL: https://github.com/apache/kafka/pull/8543#issuecomment-620879490
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please log
cmccabe commented on a change in pull request #8569:
URL: https://github.com/apache/kafka/pull/8569#discussion_r416961523
##
File path: core/src/main/scala/kafka/metrics/LinuxIoMetricsCollector.scala
##
@@ -0,0 +1,96 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF)
ijuma commented on pull request #8567:
URL: https://github.com/apache/kafka/pull/8567#issuecomment-620887867
2 jobs passed, 1 unrelated flaky test failed:
>
org.apache.kafka.streams.integration.QueryableStateIntegrationTest.shouldAllowConcurrentAccesses
guozhangwang commented on a change in pull request #8568:
URL: https://github.com/apache/kafka/pull/8568#discussion_r416910725
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/GlobalKTableEOSIntegrationTest.java
##
@@ -158,8 +158,9 @@ public void
fantayeneh opened a new pull request #8576:
URL: https://github.com/apache/kafka/pull/8576
small change fix string formatting
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ]
steverod commented on pull request #8542:
URL: https://github.com/apache/kafka/pull/8542#issuecomment-620893016
retest this please
This is an automated message from the Apache Git Service.
To respond to the message,
abbccdda commented on a change in pull request #8518:
URL: https://github.com/apache/kafka/pull/8518#discussion_r416879514
##
File path: tests/kafkatest/tests/core/downgrade_test.py
##
@@ -67,11 +67,18 @@ def setup_services(self, kafka_version, compression_types,
vvcephei commented on a change in pull request #8541:
URL: https://github.com/apache/kafka/pull/8541#discussion_r416916295
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/HighAvailabilityTaskAssignorTest.java
##
@@ -41,132 +54,107
vvcephei commented on a change in pull request #8578:
URL: https://github.com/apache/kafka/pull/8578#discussion_r416969713
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/GlobalThreadShutDownOrderTest.java
##
@@ -101,8 +102,8 @@ public void before()
Guozhang Wang created KAFKA-9928:
Summary: Flaky
GlobalKTableEOSIntegrationTest#shouldKStreamGlobalKTableLeftJoin[exactly_once_beta]
Key: KAFKA-9928
URL: https://issues.apache.org/jira/browse/KAFKA-9928
guozhangwang commented on pull request #8568:
URL: https://github.com/apache/kafka/pull/8568#issuecomment-620847306
I looked at the three failed tests:
* `OptimizedKTableIntegrationTest.shouldApplyUpdatesToStandbyStore` is
actually due to the issue that
[
https://issues.apache.org/jira/browse/KAFKA-9875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler reassigned KAFKA-9875:
---
Assignee: John Roesler
> Flaky Test
>
fantayeneh opened a new pull request #8577:
URL: https://github.com/apache/kafka/pull/8577
using the min, max might make the code a little easier to read.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage
guozhangwang commented on a change in pull request #8568:
URL: https://github.com/apache/kafka/pull/8568#discussion_r416944392
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/utils/IntegrationTestUtils.java
##
@@ -269,24 +271,20 @@ public static void
guozhangwang commented on a change in pull request #8568:
URL: https://github.com/apache/kafka/pull/8568#discussion_r416943907
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/StoreUpgradeIntegrationTest.java
##
@@ -337,8 +336,11 @@ public void
[
https://issues.apache.org/jira/browse/KAFKA-9928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17094902#comment-17094902
]
Guozhang Wang commented on KAFKA-9928:
--
I found that for the failed run, around the time when the
[
https://issues.apache.org/jira/browse/KAFKA-9921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17094900#comment-17094900
]
Georgi Petkov edited comment on KAFKA-9921 at 4/28/20, 10:23 PM:
-
kkonstantine commented on a change in pull request #8204:
URL: https://github.com/apache/kafka/pull/8204#discussion_r416866064
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java
##
@@ -220,6 +220,8 @@ public void stop() {
[
https://issues.apache.org/jira/browse/KAFKA-9921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17094835#comment-17094835
]
Sophie Blee-Goldman commented on KAFKA-9921:
> For 2 puts I would expect 2 entries regardless
vvcephei commented on a change in pull request #8568:
URL: https://github.com/apache/kafka/pull/8568#discussion_r416947800
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/utils/IntegrationTestUtils.java
##
@@ -269,24 +271,20 @@ public static void
junrao commented on pull request #8542:
URL: https://github.com/apache/kafka/pull/8542#issuecomment-620880304
@steverod : Does the JDK 8 and Scala 2.12 tests pass for you locally? Not
sure why the jenkins test failed.
This
cmccabe edited a comment on pull request #8569:
URL: https://github.com/apache/kafka/pull/8569#issuecomment-620884289
> In addition to block-level read/write, would there be a benefit to expose
file system read/write metrics?
It's better to have that discussion on the mailing list.
cmccabe commented on pull request #8569:
URL: https://github.com/apache/kafka/pull/8569#issuecomment-620884289
> In addition to block-level read/write, would there be a benefit to expose
file system read/write metrics?
It's better to have that discussion on the mailing list. This PR is
vvcephei opened a new pull request #8578:
URL: https://github.com/apache/kafka/pull/8578
The ticket is for a flaky test that failed to clean up topics _after_ the
test, which
isn't strictly necessary for test success.
* alter the "clean up after test" method to never throw an
[
https://issues.apache.org/jira/browse/KAFKA-9921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17094839#comment-17094839
]
Sophie Blee-Goldman commented on KAFKA-9921:
I take it you're using rocksdb, by the way? If
gwenshap commented on pull request #8518:
URL: https://github.com/apache/kafka/pull/8518#issuecomment-620826970
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-9921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman updated KAFKA-9921:
---
Fix Version/s: 2.5.1
> Caching is not working properly with WindowStateStore when
guozhangwang commented on a change in pull request #8568:
URL: https://github.com/apache/kafka/pull/8568#discussion_r416942992
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/EosIntegrationTest.java
##
@@ -810,21 +808,9 @@ private void
[
https://issues.apache.org/jira/browse/KAFKA-9921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17094900#comment-17094900
]
Georgi Petkov commented on KAFKA-9921:
--
[~ableegoldman]
Yeah, I agree that probably not much can be
kkonstantine commented on a change in pull request #8554:
URL: https://github.com/apache/kafka/pull/8554#discussion_r417055199
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/util/KafkaBasedLog.java
##
@@ -281,9 +281,18 @@ private void readToLogEnd() {
C0urante commented on pull request #8554:
URL: https://github.com/apache/kafka/pull/8554#issuecomment-620992508
Thanks @kkonstantine! These all seem like reasonable suggestions and I've
applied them all. Ready for the next round when you have time.
C0urante commented on a change in pull request #8554:
URL: https://github.com/apache/kafka/pull/8554#discussion_r417070806
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/util/KafkaBasedLog.java
##
@@ -281,9 +281,18 @@ private void readToLogEnd() {
[
https://issues.apache.org/jira/browse/KAFKA-9921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Georgi Petkov updated KAFKA-9921:
-
Summary: Caching is not working properly with WindowStateStore when
retaining duplicates (was:
kaushik srinivas created KAFKA-9934:
---
Summary: Information and doc update needed for support of
AclAuthorizer when protocol is PLAINTEXT
Key: KAFKA-9934
URL: https://issues.apache.org/jira/browse/KAFKA-9934
[
https://issues.apache.org/jira/browse/KAFKA-9921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17094844#comment-17094844
]
Sophie Blee-Goldman commented on KAFKA-9921:
I'm resolving the ticket because the PR to
vvcephei commented on pull request #8254:
URL: https://github.com/apache/kafka/pull/8254#issuecomment-620847005
Whew! System tests passed:
[
https://issues.apache.org/jira/browse/KAFKA-9928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-9928:
--
Assignee: Matthias J. Sax
> Flaky
>
[
https://issues.apache.org/jira/browse/KAFKA-9928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-9928:
---
Component/s: unit tests
streams
> Flaky
>
guozhangwang commented on pull request #8568:
URL: https://github.com/apache/kafka/pull/8568#issuecomment-620879654
Merged to trunk.
This is an automated message from the Apache Git Service.
To respond to the message, please
kaushik srinivas created KAFKA-9933:
---
Summary: Need doc update on the AclAuthorizer when SASL_SSL is the
protocol used.
Key: KAFKA-9933
URL: https://issues.apache.org/jira/browse/KAFKA-9933
ijuma opened a new pull request #8582:
URL: https://github.com/apache/kafka/pull/8582
If a broker contains 8k replicas, we would previously issue 8k ZK calls to
retrieve topic
configs when processing the first LeaderAndIsr request. That should
translate to 0 after
these changes.
Ismael Juma created KAFKA-9932:
--
Summary: First LeaderAndIsrRequest can take long due to
unnecessary ZK read
Key: KAFKA-9932
URL: https://issues.apache.org/jira/browse/KAFKA-9932
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-9932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma updated KAFKA-9932:
---
Fix Version/s: 2.6.0
> First LeaderAndIsrRequest can take long due to unnecessary ZK read
>
gwenshap commented on pull request #8518:
URL: https://github.com/apache/kafka/pull/8518#issuecomment-620932278
No failures, nice :)
Great update @lbradstreet and thanks for contributing.
This is an automated message from
Adem Efe Gencer created KAFKA-9930:
--
Summary: Prevent ReplicaFetcherThread from throwing
UnknownTopicOrPartitionException upon topic creation and deletion.
Key: KAFKA-9930
URL:
Randall Hauch created KAFKA-9931:
Summary: Kafka Connect should accept '-1' as a valid replication
factor
Key: KAFKA-9931
URL: https://issues.apache.org/jira/browse/KAFKA-9931
Project: Kafka
vvcephei commented on pull request #8580:
URL: https://github.com/apache/kafka/pull/8580#issuecomment-620962357
Hey @mjsax , do you have time for a quick review?
This bug seems to have been introduced by
https://github.com/apache/kafka/pull/8440/files#r407722022 , which attempts to
kkonstantine commented on pull request #8442:
URL: https://github.com/apache/kafka/pull/8442#issuecomment-620964908
retest this please
This is an automated message from the Apache Git Service.
To respond to the message,
kkonstantine commented on pull request #8442:
URL: https://github.com/apache/kafka/pull/8442#issuecomment-620964776
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log
ijuma commented on a change in pull request #8579:
URL: https://github.com/apache/kafka/pull/8579#discussion_r417044882
##
File path: core/src/main/scala/kafka/server/AbstractFetcherThread.scala
##
@@ -382,6 +382,11 @@ abstract class AbstractFetcherThread(name: String,
vvcephei commented on a change in pull request #8578:
URL: https://github.com/apache/kafka/pull/8578#discussion_r417044713
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/utils/IntegrationTestUtils.java
##
@@ -145,12 +162,12 @@ public static void
1 - 100 of 136 matches
Mail list logo
