Re: [DISCUSS] KIP-519: Make SSL context/engine configuration extensible

Ack. I should be able to get back to this on Friday. On Mon, Sep 23, 2019 at 10:35 AM Pellerin, Clement wrote: > When I worked on KIP-383 I was told the way to pass extra arguments to an > instance is to add extra arguments to configure. I would now suggest we do > like the KeySerializer. If

Kafka with kubernetes

Hi Team, I am planning to implement Kafka and planning to deploy same in kubernetes. Could you please help me what should be preferred architecture to deploy on kubernetes clusters. Regards Shivam Shukla

Request for Access to Create Jira Tickets

Hi, I recently signed up for an account for Apache Kafka's Jira project, and I would like permission to create tickets as there are a few bugs I've identified in the Kafka Connect code that I would like to report and submit a pull request for. Please let me know if this is possible. Thanks,

Re: [DISCUSS] Apache Kafka 2.4.0 release

Hi Gwen, Good question. I think we should stick to the schedule. As usual, some features will slip to the next release and that's ok, they'll get a bit more time to stabilize. In the past, we have allowed 1-2 days over the feature freeze date (i.e. end of the week instead of Wednesday) for

Re: [DISCUSS] Apache Kafka 2.4.0 release

Hi Mani and team, The feature freeze deadline is right next to Kafka Summit, making it a bit stressful for the committers and community members with PRs in flight. What do you think about delaying the feature freeze and code freeze by a week, to allow our community to enjoy Kafka Summit? Gwen

[jira] [Created] (KAFKA-8945) Incorrect null check in the constructor for ConnectorHealth and AbstractState

Sanjana Kaundinya created KAFKA-8945: Summary: Incorrect null check in the constructor for ConnectorHealth and AbstractState Key: KAFKA-8945 URL: https://issues.apache.org/jira/browse/KAFKA-8945

Kafka Meetup hosted by Confluent at San Francisco, Tuesday 6:30pm, October 1st, 2019

Hello folks, This is a kind reminder of the Bay Area Kafka® meetup next Tuesday 6:30pm, at Confluent's San Francisco office. *RSVP and Register* (if you intend to attend in person): https://www.meetup.com/KafkaBayArea/events/264562779/ *Date* 6:30pm, Tuesday, October 1st, 2019 *Location*

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

See -- [...truncated 4.15 KB...] at hudson.Proc$LocalProc.(Proc.java:218) at hudson.Launcher$LocalLauncher.launch(Launcher.java:936) at

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

See Changes: [github] MINOR: Improve the org.apache.kafka.common.protocol code (#7344) [mumrah] MINOR: improve the Kafka RPC code generator (#7340) -- [...truncated 5.36

[jira] [Created] (KAFKA-8944) Compiler Warning

Matthias J. Sax created KAFKA-8944: -- Summary: Compiler Warning Key: KAFKA-8944 URL: https://issues.apache.org/jira/browse/KAFKA-8944 Project: Kafka Issue Type: Bug Components:

Re: [DISCUSS] Apache Kafka 2.4.0 release

Hi, Manikumar. Thanks for acting as release manager. Can we please add the following KIPs that have all been approved with PRs either merged or in progress: - https://cwiki.apache.org/confluence/display/KAFKA/KIP-415%3A+Incremental+Cooperative+Rebalancing+in+Kafka+Connect -

Re: [DISCUSS] KIP-514: Add a bounded flush() API to Kafka Producer

bump. so if no more concerns, can we move to a vote on this ? On Fri, Sep 13, 2019 at 10:05 AM radai wrote: > > we have a lot of processes that need a time-bounded checkpoint logic. > > the standard use case is some consume-process-produce logic of the > following form: > > while (alive) { >

Re: [VOTE] KIP-524: Allow users to choose config source when describing configs

Thanks for the KIP. +1 (binding). -Harsha On Wed, Sep 25, 2019 at 11:55 AM Satish Duggana wrote: > Thanks Jason for the KIP. It looks to be a minor improvement but very > useful. > > +1 (non-binding) > > On Wed, Sep 25, 2019 at 9:29 PM Rajini Sivaram > wrote: > > > > Thanks for the KIP,

Re: [VOTE] 2.3.1 RC0

Thanks, Jason. I agree we should include this. I'll produce RC1 once this patch is available. -David On Tue, Sep 24, 2019 at 6:02 PM Jason Gustafson wrote: > Hi David, > > Thanks for running the release. I think we should consider getting this bug > fixed:

Re: [VOTE] KIP-524: Allow users to choose config source when describing configs

Thanks Jason for the KIP. It looks to be a minor improvement but very useful. +1 (non-binding) On Wed, Sep 25, 2019 at 9:29 PM Rajini Sivaram wrote: > > Thanks for the KIP, Jason! > > +1 (binding) > > Regards, > > Rajini > > On Wed, Sep 25, 2019 at 4:41 PM Colin McCabe wrote: > > > Looks good.

Re: [DISCUSS] Apache Kafka 2.4.0 release

Hi Manikumar, let's add one more on the list that was voted on time and is straightforward: KIP-521: https://cwiki.apache.org/confluence/display/KAFKA/KIP-521%3A+Enable+redirection+of+Connect%27s+log4j+messages+to+a+file+by+default with jira ticket:

Re: [DISCUSS] Apache Kafka 2.4.0 release

Hi Manikumar, Would it be possible to add KIP-507 ( https://cwiki.apache.org/confluence/display/KAFKA/KIP-507%3A+Securing+Internal+Connect+REST+Endpoints) to the 2.4 release, as it has recently been accepted? Cheers, Chris On Tue, Sep 24, 2019 at 9:33 AM Kevin Lu wrote: > Hi Manikumar, > >

Re: [VOTE] KIP-507: Securing Internal Connect REST Endpoints

Hi all, Thanks for the votes! Since three complete business days have passed since the opening of this thread, I'd like to conclude voting on KIP-507, which has been accepted. The final results are: For (binding): Randall, Rajini, and Ewen For (non-binding): Konstantine Against (binding): None

[jira] [Resolved] (KAFKA-7273) Converters should have access to headers.

[ https://issues.apache.org/jira/browse/KAFKA-7273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-7273. -- Fix Version/s: 2.4.0 Reviewer: Randall Hauch Resolution: Fixed

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

See Changes: [github] MINOR: Improve the org.apache.kafka.common.protocol code (#7344) [mumrah] MINOR: improve the Kafka RPC code generator (#7340) [rhauch] KAFKA-7273: Extend Connect Converter to support

Re: [VOTE] KIP-524: Allow users to choose config source when describing configs

Thanks for the KIP, Jason! +1 (binding) Regards, Rajini On Wed, Sep 25, 2019 at 4:41 PM Colin McCabe wrote: > Looks good. +1 (binding) > > best, > Colin > > On Tue, Sep 24, 2019, at 09:42, Jason Gustafson wrote: > > Hi All, > > > > I'm starting a vote for KIP-524, which is a small change to

Re: [VOTE] KIP-524: Allow users to choose config source when describing configs

Looks good. +1 (binding) best, Colin On Tue, Sep 24, 2019, at 09:42, Jason Gustafson wrote: > Hi All, > > I'm starting a vote for KIP-524, which is a small change to the config > tool: >

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

See -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on H40 (ubuntu xenial) in workspace

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

See Changes: [github] KAFKA-8880: Docs on upgrade-guide (#7385) -- [...truncated 3.04 MB...] org.apache.kafka.streams.test.OutputVerifierTest >

[jira] [Created] (KAFKA-8943) Move SecurityProviderCreator to a public package

Rajini Sivaram created KAFKA-8943: - Summary: Move SecurityProviderCreator to a public package Key: KAFKA-8943 URL: https://issues.apache.org/jira/browse/KAFKA-8943 Project: Kafka Issue Type:

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

See Changes: [wangguoz] KAFKA-8179: do not suspend standby tasks during rebalance (#7321) [github] KAFKA-8880: Docs on upgrade-guide (#7385) -- [...truncated 2.53 MB...]

Re: [DISCUSS] KIP-502: Connect SinkTask.put(...) to specify ArrayList in Signature

Hi Cyrus, Thanks for the KIP. In the motivation I can see how having a guaranteed iteration order might be useful for some connectors, but I couldn't see how a Connector developer would benefit from using List.get(int). Could you elaborate? Can you offer any numbers to show that the cost of

[jira] [Created] (KAFKA-8942) Document RocksDB metrics

Bruno Cadonna created KAFKA-8942: Summary: Document RocksDB metrics Key: KAFKA-8942 URL: https://issues.apache.org/jira/browse/KAFKA-8942 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-8941) Add RocksDB Metrics that Could not be Added due to RocksDB Version

Bruno Cadonna created KAFKA-8941: Summary: Add RocksDB Metrics that Could not be Added due to RocksDB Version Key: KAFKA-8941 URL: https://issues.apache.org/jira/browse/KAFKA-8941 Project: Kafka

[jira] [Resolved] (KAFKA-8580) Compute RocksDB Metrics

[ https://issues.apache.org/jira/browse/KAFKA-8580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-8580. -- Resolution: Done > Compute RocksDB Metrics > --- > > Key: