Re: [DISCUSS] KIP-474: To deprecate WindowStore#put(key, value)

Thanks for the KIP Omkar. I think this is rather uncontroversial, and I also support this KIP. I think you can start a VOTE. People can still chime in on the discuss thread if they have any concerns. -Matthias On 5/27/19 11:50 PM, Dongjin Lee wrote: > Hi Omkar, > > Looks good to me. Thanks! >

Build failed in Jenkins: kafka-trunk-jdk11 #590

See Changes: [matthias] MINOR:Replace duplicated code with common function in utils (#6819) -- [...truncated 2.50 MB...]

Build failed in Jenkins: kafka-2.2-jdk8 #129

See Changes: [matthias] KAFKA-8155: Add 2.1.1 release to system tests (#6596) -- [...truncated 2.71 MB...] kafka.controller.ReplicaStateMachineTest >

Re: [DISCUSS] KIP-469: Pre-registration support for static members

Hey there, it's been over a week (I know folks are busy with release), but still want to bump this thread if anyone is interested. Thank you! Boyang From: Boyang Chen Sent: Tuesday, May 21, 2019 5:55 AM To: dev@kafka.apache.org Subject: [DISCUSS] KIP-469:

Jenkins build is back to normal : kafka-2.1-jdk8 #200

See

Jenkins build is back to normal : kafka-trunk-jdk11 #589

See

[jira] [Created] (KAFKA-8452) Possible Suppress buffer optimization: de-duplicate prior value

John Roesler created KAFKA-8452: --- Summary: Possible Suppress buffer optimization: de-duplicate prior value Key: KAFKA-8452 URL: https://issues.apache.org/jira/browse/KAFKA-8452 Project: Kafka

Build failed in Jenkins: kafka-2.3-jdk8 #29

See Changes: [matthias] KAFKA-6455: Update integration tests to verify result timestamps (#6751) [rhauch] KAFKA-8418: Wait until REST resources are loaded when starting a Connect [matthias] KAFKA-8155: Add

Re: [VOTE] KIP-429: Kafka Consumer Incremental Rebalance Protocol

+1 (binding) from me as well. Thanks to everyone who have voted! I'm closing this vote thread with a tally: binding +1: 3 (Guozhang, Harsha, Matthias) non-binding +1: 2 (Boyang, Liquan) Guozhang On Wed, May 22, 2019 at 9:22 PM Matthias J. Sax wrote: > +1 (binding) > > > On 5/22/19 7:37 PM,

[jira] [Created] (KAFKA-8451) transaction support multiple producer instance

wenxuanguan created KAFKA-8451: -- Summary: transaction support multiple producer instance Key: KAFKA-8451 URL: https://issues.apache.org/jira/browse/KAFKA-8451 Project: Kafka Issue Type: Bug

Re: Permission to create KIP

Hi Ivan, Thanks for your interest in Apache Kafka. You should be all set now. Thanks, Bill On Thu, May 30, 2019 at 10:34 AM Ivan Yurchenko wrote: > Hi, > > I'd like to be able to create KIPs. Could someone please set up the > permissions for me? The username is ivanyu . > Thanks! > > Ivan >

Build failed in Jenkins: kafka-trunk-jdk11 #588

See Changes: [github] KAFKA-6455: Update integration tests to verify result timestamps (#6751) [rhauch] KAFKA-8418: Wait until REST resources are loaded when starting a Connect

Jenkins build is back to normal : kafka-trunk-jdk8 #3690

See

Build failed in Jenkins: kafka-2.0-jdk8 #272

See Changes: [rhauch] KAFKA-8418: Wait until REST resources are loaded when starting a Connect -- [...truncated 437.98 KB...] kafka.security.auth.SimpleAclAuthorizerTest >

[jira] [Created] (KAFKA-8450) Augment processed in MockProcessor as KeyValueAndTimestamp

Guozhang Wang created KAFKA-8450: Summary: Augment processed in MockProcessor as KeyValueAndTimestamp Key: KAFKA-8450 URL: https://issues.apache.org/jira/browse/KAFKA-8450 Project: Kafka

Build failed in Jenkins: kafka-1.0-jdk7 #271

See Changes: [rhauch] KAFKA-8418: Wait until REST resources are loaded when starting a Connect -- [...truncated 380.93 KB...] kafka.security.auth.ZkAuthorizationTest >

Build failed in Jenkins: kafka-2.1-jdk8 #199

See Changes: [bill] KAFKA-8187: Add wait time for other thread in the same jvm to free the -- [...truncated 924.64 KB...] kafka.zk.LiteralAclStoreTest >

Build failed in Jenkins: kafka-1.1-jdk7 #265

See Changes: [rhauch] KAFKA-8418: Wait until REST resources are loaded when starting a Connect -- [...truncated 613.09 KB...] kafka.server.KafkaConfigTest >

[jira] [Resolved] (KAFKA-8441) Flaky Test RegexSourceIntegrationTest#testRegexMatchesTopicsAWhenCreated

[ https://issues.apache.org/jira/browse/KAFKA-8441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-8441. -- Resolution: Invalid > Flaky Test RegexSourceIntegrationTest#testRegexMatchesTopicsAWhenCreated

[jira] [Resolved] (KAFKA-8440) Flaky Test KStreamAggregationIntegrationTest#shouldReduceSessionWindows

[ https://issues.apache.org/jira/browse/KAFKA-8440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-8440. -- Resolution: Invalid > Flaky Test KStreamAggregationIntegrationTest#shouldReduceSessionWindows

Jenkins build is back to normal : kafka-2.2-jdk8 #127

See

Build failed in Jenkins: kafka-2.3-jdk8 #28

See Changes: [bill] KAFKA-8187: Add wait time for other thread in the same jvm to free the [jason] KAFKA-8429; Handle offset change when OffsetForLeaderEpoch inflight --

[jira] [Resolved] (KAFKA-8418) Connect System tests are not waiting for REST resources to be registered

[ https://issues.apache.org/jira/browse/KAFKA-8418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-8418. -- Resolution: Fixed Reviewer: Randall Hauch Merged and backported all the way to `1.0`

Re: [DISCUSS] KIP-471: Expose RocksDB Metrics in Kafka Streams

Hi Bruno: Regarding 2) I think either way has some shortcomings: exposing the metrics per rocksDB instance for window / session stores exposed some implementation internals (that we use segmented stores) to enforce users to be aware of them. E.g. what if we want to silently change the internal

Build failed in Jenkins: kafka-trunk-jdk8 #3689

See Changes: [bbejeck] [MINOR] Improve docs for Global Store operations (#6803) [bbejeck] MINOR: Extend RocksDB section of Memory Management Docs (#6793) --

[jira] [Resolved] (KAFKA-8187) State store record loss across multiple reassignments when using standby tasks

[ https://issues.apache.org/jira/browse/KAFKA-8187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8187. Resolution: Fixed merged to trunk and cherry-picked to 2.3, 2.2 and 2.1 > State store record loss

Re: Kafka 2.3 release update

Hi All, Just a reminder that the code freeze is now in effect. Only blockers should be merged to the 2.3 branch. The first release candidate will be out shortly. Thanks, Jason On Mon, May 13, 2019 at 1:57 PM Colin McCabe wrote: > Hi all, > > The KIPs freeze for the 2.3 release has now

[jira] [Resolved] (KAFKA-8429) Consumer should handle offset change while OffsetForLeaderEpoch is inflight

[ https://issues.apache.org/jira/browse/KAFKA-8429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-8429. Resolution: Fixed Fix Version/s: (was: 2.3.0) > Consumer should handle offset

Build failed in Jenkins: kafka-2.3-jdk8 #27

See Changes: [bill] [MINOR] Improve docs for Global Store operations (#6803) [bill] MINOR: Extend RocksDB section of Memory Management Docs (#6793) -- [...truncated 2.87

Can kafka brokers have SASL_SSL, SSL and PLAINTEXT listener at same time?

Hi, I want to migrate from SSL to SASL_SSL on the Kafka. Is there a way to enable both SSL and SASL_SSL at the same time in a Kafka cluster. Also, I want PLAINTEXT (without SASL and SSL) to be enabled for the internal users. Is this possible in Kafka 1.1.1. If possible please walk me through it.

[jira] [Created] (KAFKA-8449) Restart task on reconfiguration under incremental cooperative rebalancing

Konstantine Karantasis created KAFKA-8449: - Summary: Restart task on reconfiguration under incremental cooperative rebalancing Key: KAFKA-8449 URL: https://issues.apache.org/jira/browse/KAFKA-8449

Permission to create KIP

Hi, I'd like to be able to create KIPs. Could someone please set up the permissions for me? The username is ivanyu . Thanks! Ivan

[jira] [Created] (KAFKA-8448) Too many kafka.log.Log instances (Memory Leak)

Juan Olivares created KAFKA-8448: Summary: Too many kafka.log.Log instances (Memory Leak) Key: KAFKA-8448 URL: https://issues.apache.org/jira/browse/KAFKA-8448 Project: Kafka Issue Type: Bug

[DISCUSS] KIP-475: New Metric to Measure Number of Tasks on a Connector

Hello Dev, I'd like to start the discussion of KIP-475: New Metric to Measure Number of Tasks on a Connector. https://cwiki.apache.org/confluence/display/KAFKA/KIP-475%3A+New+Metric+to+Measure+Number+of+Tasks+on+a+Connector The proposal is pretty straightforward -- to add a new metric to Connect