Re: [DISCUSS] KIP-688: Support dynamic update of delete.topic.enable config

Harsha, I understand the concern, but the solution of using this flag is a bit weird. First, I can cause similar damage by setting retention.ms=1 on any topic. We also have APIs to delete data from topics directly. All without a "gating" flag. Because as a system we rely on access controls to

[jira] [Created] (KAFKA-10769) Remove JoinGroupRequest#containsValidPattern as it is duplicate to Topic#containsValidPattern

Chia-Ping Tsai created KAFKA-10769: -- Summary: Remove JoinGroupRequest#containsValidPattern as it is duplicate to Topic#containsValidPattern Key: KAFKA-10769 URL: https://issues.apache.org/jira/browse/KAFKA-10769

[jira] [Created] (KAFKA-10768) Make ByteBufferInputStream.read(byte[], int, int) to follow the contract

Chia-Ping Tsai created KAFKA-10768: -- Summary: Make ByteBufferInputStream.read(byte[], int, int) to follow the contract Key: KAFKA-10768 URL: https://issues.apache.org/jira/browse/KAFKA-10768

[jira] [Resolved] (KAFKA-10565) Console producer displays interactive prompt even when input is not interactive

[ https://issues.apache.org/jira/browse/KAFKA-10565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-10565. Fix Version/s: 2.8.0 Resolution: Fixed > Console producer displays interactive

Jenkins build is back to normal : Kafka » kafka-trunk-jdk8 #241

See

Build failed in Jenkins: Kafka » kafka-2.7-jdk8 #62

See Changes: -- [...truncated 6.70 MB...] org.apache.kafka.streams.test.OutputVerifierTest > shouldFailIfValueIsDifferentWithNullForCompareValueWithProducerRecord PASSED

Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #263

See Changes: [github] MINOR: fix listeners doc to close properly (#9655) -- [...truncated 3.48 MB...]

Re: [DISCUSS] KIP-688: Support dynamic update of delete.topic.enable config

Hi Gwen, Agree with you ACLs would be a better option. But not all installations will be able to have secure setup and authorizer. In a hosted service where they may not be ACLs or security setup this flag helps prevent accidental topic deletion. This config acted as a good gatekeeper to

Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #262

See Changes: [github] MINOR: Remove unnecessary statement from WorkerConnector#doRun (#9653) -- [...truncated 6.95 MB...]

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #240

See Changes: [github] MINOR: Remove unnecessary statement from WorkerConnector#doRun (#9653) -- [...truncated 6.90 MB...]

Re: [VOTE] 2.6.1 RC2

I am seeing this on every consumer start: 2020-11-25 13:54:34.858 INFO 42250 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-ktest26int-1, groupId=ktest26int] Rebalance failed. org.apache.kafka.common.errors.MemberIdRequiredException: The group

Jenkins build is back to normal : Kafka » kafka-trunk-jdk15 #286

See

Build failed in Jenkins: Kafka » kafka-2.7-jdk8 #61

See Changes: -- [...truncated 6.87 MB...] org.apache.kafka.streams.test.OutputVerifierTest > shouldNotAllowNullProducerRecordWithExpectedRecordForCompareKeyValue STARTED

[VOTE] 2.6.1 RC2

Hello Kafka users, developers and client-developers, This is the third candidate for release of Apache Kafka 2.6.1. Since RC1, the following JIRAs have been fixed: KAFKA-10758 Release notes for the 2.6.1 release: https://home.apache.org/~mimaison/kafka-2.6.1-rc2/RELEASE_NOTES.html *** Please

Re: [DISCUSS] KIP-688: Support dynamic update of delete.topic.enable config

Thanks for bringing this up! I disagree that " there is a valid use-case to keep the flag "delete.topic.enable" as "false" in server.properties configs, so that someone doesn't accidentally delete a topic,". The flag was added and set to "false" back in the days when topic deletion was not a

[DISCUSS] KIP-688: Support dynamic update of delete.topic.enable config

Hi, I've created KIP-688 to enable support for dynamic update of delete.topic.enable config. https://cwiki.apache.org/confluence/display/KAFKA/KIP-688%3A+Support+dynamic+update+of+delete.topic.enable+config Please take a look and let me know if you have any feedback. Thanks -- Prateek Agarwal

Re: [VOTE] 2.7.0 RC3

Hi Tom, Thanks for reviewing the docs and providing the fix. I agree that this doesn't necessarily meet the bar for a new RC, we'll fix the 2.7 HTML -Bill On Wed, Nov 25, 2020 at 11:17 AM Tom Bentley wrote: > Hi Bill, > > One very minor problem I just spotted is >

Re: [VOTE] 2.7.0 RC3

Hi Bill, One very minor problem I just spotted is https://kafka.apache.org/27/documentation.html#brokerconfigs_listeners, because the tag is not properly closed the HTML doesn't render property (in Chromium and Firefox at least) and all the rest of the configs are shown in a monospaced font. I

[VOTE] 2.7.0 RC3

This is the fourth candidate for the release of Apache Kafka 2.7.0. This is a major release that includes many new features, including: * Configurable TCP connection timeout and improve the initial metadata fetch * Enforce broker-wide and per-listener connection creation rate (KIP-612, part 1) *

Re: [VOTE] 2.7.0 RC2

Thanks for the notice, Sophie. Rolling a new RC now. On Tue, Nov 24, 2020 at 9:23 PM Sophie Blee-Goldman wrote: > The fix has been merged and cherrypicked to the 2.7 branch > > Thanks Bill! > > -Sophie > > On Mon, Nov 23, 2020 at 4:13 PM Bill Bejeck wrote: > > > Hi Sophie, > > > > Since this

[jira] [Created] (KAFKA-10767) Add Unit Test cases for missing methods in ThreadCacheTest

Sagar Rao created KAFKA-10767: - Summary: Add Unit Test cases for missing methods in ThreadCacheTest Key: KAFKA-10767 URL: https://issues.apache.org/jira/browse/KAFKA-10767 Project: Kafka Issue

[jira] [Created] (KAFKA-10766) Add Unit Test cases for RocksDbRangeIterator

Sagar Rao created KAFKA-10766: - Summary: Add Unit Test cases for RocksDbRangeIterator Key: KAFKA-10766 URL: https://issues.apache.org/jira/browse/KAFKA-10766 Project: Kafka Issue Type: