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

See Changes: [rhauch] KAFKA-8404: Add HttpHeader to RestClient HTTP Request and Connector REST -- [...truncated 441.32 KB...] kafka.server.ClientQuotaManagerTest > testUserQ

Fwd: [DISCUSS] KIP-333 Consider a faster form of rebalancing

Just cycling back to this older KIP discussion. I still have some concerns about the proposal, and there was no activity for a long time. I am wondering if there is still interest in this KIP, or if we should discard it? -Matthias Forwarded Message Subject: Re: [DISCUSS] KIP-3

Jenkins build is back to normal : kafka-2.3-jdk8 #36

See

[jira] [Created] (KAFKA-8477) Cannot consume and request metadata for __consumer_offsets topic in Kafka 2.2

Mike Mintz created KAFKA-8477: - Summary: Cannot consume and request metadata for __consumer_offsets topic in Kafka 2.2 Key: KAFKA-8477 URL: https://issues.apache.org/jira/browse/KAFKA-8477 Project: Kafka

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

See

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

See Changes: [rajinisivaram] KAFKA-8426; Fix for keeping the ConfigProvider configs consistent with [rhauch] KAFKA-8449: Restart tasks on reconfiguration under incremental -

[jira] [Resolved] (KAFKA-8473) Adjust Connect system tests for incremental cooperative rebalancing and enable them for both eager and incremental cooperative rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-8473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-8473. -- Resolution: Fixed Reviewer: Randall Hauch > Adjust Connect system tests for incremental c

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

+1 (binding). On Sat, Jun 1, 2019 at 3:19 PM Matthias J. Sax wrote: > +1 (binding) > > On 5/31/19 10:58 PM, Dongjin Lee wrote: > > +1 (non-binding). > > > > Thanks, > > Dongjin > > > > < > https://www.avast.com/sig-email?utm_medium=email&utm_source=link&utm_campaign=sig-email&utm_content=webmail

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

I've made a pass on the KIP and it looks good to me as well. I think we can start a voting thread for it. On Thu, May 30, 2019 at 10:27 PM Matthias J. Sax wrote: > Thanks for the KIP Omkar. > > I think this is rather uncontroversial, and I also support this KIP. I > think you can start a VOTE. P

[jira] [Resolved] (KAFKA-8383) Write integration test for electLeaders

[ https://issues.apache.org/jira/browse/KAFKA-8383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-8383. Resolution: Fixed > Write integration test for electLeaders > -

[jira] [Created] (KAFKA-8476) Kafka 2.2.1 distribution contains JAX-RS API twice

Gunnar Morling created KAFKA-8476: - Summary: Kafka 2.2.1 distribution contains JAX-RS API twice Key: KAFKA-8476 URL: https://issues.apache.org/jira/browse/KAFKA-8476 Project: Kafka Issue Type

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

See Changes: [rhauch] KAFKA-8449: Restart tasks on reconfiguration under incremental -- [...truncated 2.49 MB...] org.apache.kafka.streams.test.OutputVerifierTest > shou

[jira] [Resolved] (KAFKA-8475) Temporarily restore SslFactory.sslContext() helper

[ https://issues.apache.org/jira/browse/KAFKA-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe resolved KAFKA-8475. Resolution: Fixed Fix Version/s: 2.3 > Temporarily restore SslFactory.sslContext() h

[jira] [Created] (KAFKA-8475) Temporarily restore SslFactory.sslContext() helper

Colin P. McCabe created KAFKA-8475: -- Summary: Temporarily restore SslFactory.sslContext() helper Key: KAFKA-8475 URL: https://issues.apache.org/jira/browse/KAFKA-8475 Project: Kafka Issue Ty

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

See Changes: [rajinisivaram] MINOR: Reordering the props modification with configs construction [rajinisivaram] KAFKA-8425: Fix for correctly handling immutable maps (KIP-421 bug)

[jira] [Resolved] (KAFKA-8469) Named Suppress Operator Needs to increment Name Counter

[ https://issues.apache.org/jira/browse/KAFKA-8469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8469. Resolution: Not A Problem > Named Suppress Operator Needs to increment Name Counter > -

[jira] [Created] (KAFKA-8474) Improve configuration layout on website

Mickael Maison created KAFKA-8474: - Summary: Improve configuration layout on website Key: KAFKA-8474 URL: https://issues.apache.org/jira/browse/KAFKA-8474 Project: Kafka Issue Type: Improveme

[jira] [Created] (KAFKA-8473) Adjust Connect system tests for incremental cooperative rebalancing and enable them for both eager and incremental cooperative rebalancing

Konstantine Karantasis created KAFKA-8473: - Summary: Adjust Connect system tests for incremental cooperative rebalancing and enable them for both eager and incremental cooperative rebalancing Key: KAFKA-8473

Re: [ANNOUNCE] Apache Kafka 2.2.1

That's fantastic! thanks a lot Vahid for managing the release. -- Jonathan On Mon, Jun 3, 2019 at 5:18 PM Mickael Maison wrote: > Thank you Vahid > > On Mon, Jun 3, 2019 at 5:12 PM Wladimir Schmidt > wrote: > > > > Thanks Vahid! > > > > On Mon, Jun 3, 2019, 16:23 Vahid Hashemian wrote: > >

Re: [ANNOUNCE] Apache Kafka 2.2.1

Thank you Vahid On Mon, Jun 3, 2019 at 5:12 PM Wladimir Schmidt wrote: > > Thanks Vahid! > > On Mon, Jun 3, 2019, 16:23 Vahid Hashemian wrote: > > > The Apache Kafka community is pleased to announce the release for Apache > > Kafka 2.2.1 > > > > This is a bugfix release for Kafka 2.2.0. All of t

[jira] [Created] (KAFKA-8472) Use composition for better isolation of fetcher logic

Jason Gustafson created KAFKA-8472: -- Summary: Use composition for better isolation of fetcher logic Key: KAFKA-8472 URL: https://issues.apache.org/jira/browse/KAFKA-8472 Project: Kafka Issue

Re: [ANNOUNCE] Apache Kafka 2.2.1

Thanks Vahid! On Mon, Jun 3, 2019, 16:23 Vahid Hashemian wrote: > The Apache Kafka community is pleased to announce the release for Apache > Kafka 2.2.1 > > This is a bugfix release for Kafka 2.2.0. All of the changes in this > release can be found in the release notes: > https://www.apache.org/

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

See

Re: [ANNOUNCE] Apache Kafka 2.2.1

Thank you Vahid! On Mon, Jun 3, 2019 at 7:49 AM Ismael Juma wrote: > Thanks for managing the release Vahid! > > Ismael > > On Mon, Jun 3, 2019 at 7:23 AM Vahid Hashemian wrote: > > > The Apache Kafka community is pleased to announce the release for Apache > > Kafka 2.2.1 > > > > This is a bugfi

[jira] [Created] (KAFKA-8471) Replace control requests/responses with automated protocol

Ismael Juma created KAFKA-8471: -- Summary: Replace control requests/responses with automated protocol Key: KAFKA-8471 URL: https://issues.apache.org/jira/browse/KAFKA-8471 Project: Kafka Issue Ty

[jira] [Created] (KAFKA-8470) State change logs should not be in TRACE level

Stanislav Kozlovski created KAFKA-8470: -- Summary: State change logs should not be in TRACE level Key: KAFKA-8470 URL: https://issues.apache.org/jira/browse/KAFKA-8470 Project: Kafka Issu

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

See

[jira] [Created] (KAFKA-8469) Named Suppress Operator Needs to increment Name Counter

Bill Bejeck created KAFKA-8469: -- Summary: Named Suppress Operator Needs to increment Name Counter Key: KAFKA-8469 URL: https://issues.apache.org/jira/browse/KAFKA-8469 Project: Kafka Issue Type:

Re: [ANNOUNCE] Apache Kafka 2.2.1

Thanks for managing the release Vahid! Ismael On Mon, Jun 3, 2019 at 7:23 AM Vahid Hashemian wrote: > The Apache Kafka community is pleased to announce the release for Apache > Kafka 2.2.1 > > This is a bugfix release for Kafka 2.2.0. All of the changes in this > release can be found in the rel

[ANNOUNCE] Apache Kafka 2.2.1

The Apache Kafka community is pleased to announce the release for Apache Kafka 2.2.1 This is a bugfix release for Kafka 2.2.0. All of the changes in this release can be found in the release notes: https://www.apache.org/dist/kafka/2.2.1/RELEASE_NOTES.html You can download the source and binary re

Re: Request for Contributor Permissions

Hi, You're all set now! Thanks for your interest in Apache Kafka. -Bill On Mon, Jun 3, 2019 at 4:30 AM John Park <87johnpar...@gmail.com> wrote: > Hi, > > My name is In Park and I would like to contribute to Apache Kafka. > Could you give me contributor permissions? > My Jira ID is : in-park

kafka connect stops consuming data when kafka broker goes down

Hello kafka dev, We are encountering an issue when kafka connect is running hdfs sink connector pulling data from kafka and writing to hdfs location. In between when the data is flowing in the pipeline from producer -> kafka topic -> kafka connect hdfs sink connector -> hdfs, If even one of the

[jira] [Created] (KAFKA-8468) AdminClient.deleteTopics doesn't wait until topic is deleted

Gabor Somogyi created KAFKA-8468: Summary: AdminClient.deleteTopics doesn't wait until topic is deleted Key: KAFKA-8468 URL: https://issues.apache.org/jira/browse/KAFKA-8468 Project: Kafka I

[jira] [Created] (KAFKA-8467) Trogdor - Add option to delete topic in RoundTripWorker

Stanislav Kozlovski created KAFKA-8467: -- Summary: Trogdor - Add option to delete topic in RoundTripWorker Key: KAFKA-8467 URL: https://issues.apache.org/jira/browse/KAFKA-8467 Project: Kafka

Re: [VOTE] KIP-334 Include partitions in exceptions raised during consumer record deserialization/validation

Do people agree with the approach I outlined in my last reply? On Mon, May 6, 2019 at 2:12 PM Stanislav Kozlovski wrote: > Hey there Kamal, > > I'm sincerely sorry for missing your earlier message. As I open this > thread up, I see I have an unsent draft message about resuming discussion > from

[jira] [Created] (KAFKA-8466) Remove 'jackson-module-scala' dependency (and replace it with some code)

Dejan Stojadinović created KAFKA-8466: - Summary: Remove 'jackson-module-scala' dependency (and replace it with some code) Key: KAFKA-8466 URL: https://issues.apache.org/jira/browse/KAFKA-8466 Proj

Request for Contributor Permissions

Hi, My name is In Park and I would like to contribute to Apache Kafka. Could you give me contributor permissions? My Jira ID is : in-park Regards, In