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

See Changes: [colin] MINOR: Update Trogdor StringExpander regex to handle an epilogue (#6123) -- [...truncated 2.26 MB...] org.apache.kafka.streams.test.OutputVerifierTes

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

See Changes: [colin] MINOR: Update Trogdor StringExpander regex to handle an epilogue (#6123) -- [...truncated 2.26 MB...] org.apache.kafka.connect.converters.ByteArrayCo

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

See Changes: [me] KAFKA-7461: Add tests for logical types -- [...truncated 2.26 MB...] org.apache.kafka.streams.test.OutputVerifierTest > shouldPassIfKeyAndValueIsEqualW

Re: [VOTE] KIP-389: Introduce a configurable consumer group size limit

+1 (binding), thanks. On Fri, Jan 11, 2019, 1:09 AM Stanislav Kozlovski Hey folks, > > I'd like to initiate a vote thread about KIP-389 > < > https://cwiki.apache.org/confluence/display/KAFKA/KIP-389%3A+Introduce+a+configurable+consumer+group+size+limit > > > . > > -- > Best, > Stanislav >

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

See Changes: [me] KAFKA-7461: Add tests for logical types -- [...truncated 2.26 MB...] org.apache.kafka.streams.test.OutputVerifierTest > shouldFailIfValueIsDifferentWit

[jira] [Resolved] (KAFKA-6803) Caching is turned off for stream-stream Join

[ https://issues.apache.org/jira/browse/KAFKA-6803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6803. -- Resolution: Invalid > Caching is turned off for stream-stream Join > --

Re: [VOTE] KIP-389: Introduce a configurable consumer group size limit

+1 Thanks for the KIP! -Jason On Mon, Jan 14, 2019 at 12:54 AM Andrew Schofield wrote: > +1 (non-binding) > > Looks like a good improvement. > > Andrew Schofield > IBM Event Streams > > On 11/01/2019, 17:33, "Boyang Chen" wrote: > > +1 (non-binding) > > Thanks for the great work! > >

Re: [VOTE] KIP-379: Multiple Consumer Group Management

+1 Thanks for the KIP! -Jason On Mon, Jan 14, 2019 at 5:15 PM Gwen Shapira wrote: > I was also wondering about that. I think its for compatibility with > the existing output. > > We can have a separate KIP to add JSON output. > > On Mon, Jan 14, 2019 at 7:55 AM M. Manna wrote: > > > > Hi, > >

Re: [VOTE] KIP-379: Multiple Consumer Group Management

I was also wondering about that. I think its for compatibility with the existing output. We can have a separate KIP to add JSON output. On Mon, Jan 14, 2019 at 7:55 AM M. Manna wrote: > > Hi, > > Thanks for this KIP. Could you kindly clarify why CSV format is useful, but > not anything else? > >

Jenkins build is back to normal : kafka-2.0-jdk8 #214

See

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

See Changes: [github] MINOR: code cleanup (#6054) [me] KAFKA-7503: Connect integration test harness [junrao] Fix KAFKA-7789 by increasing the key size for the RSA keys generated for --

Re: [VOTE] KIP-349 Priorities for Source Topics

Hi Jan, As discussed, I’ve adopted the position that MessageChooser is orthogonal to topic prioritization and hence outside the scope of KIP-349. -- Nick > On Jan 14, 2019, at 12:47 AM, Jan Filipiak wrote: > > On 14.01.2019 02:48, n...@afshartous.com wrote:

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

See Changes: [github] MINOR: code cleanup (#6054) [me] KAFKA-7503: Connect integration test harness [junrao] Fix KAFKA-7789 by increasing the key size for the RSA keys generated for --

[jira] [Resolved] (KAFKA-7461) Connect Values converter should have coverage of logical types

[ https://issues.apache.org/jira/browse/KAFKA-7461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-7461. -- Resolution: Fixed Fix Version/s: 2.2.0 Issue resolved by pull request 60

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

See Changes: [me] KAFKA-7503: Connect integration test harness -- [...truncated 586.82 KB...] kafka.server.KafkaConfigTest > testInvalidInterBrokerSecurityProtocol STARTED k

[jira] [Resolved] (KAFKA-7818) Make the KafkaConsumer AutoCloseable

[ https://issues.apache.org/jira/browse/KAFKA-7818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fokko Driesprong resolved KAFKA-7818. - Resolution: Invalid > Make the KafkaConsumer AutoCloseable >

[jira] [Resolved] (KAFKA-7503) Integration Test Framework for Connect

[ https://issues.apache.org/jira/browse/KAFKA-7503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-7503. -- Resolution: Fixed Fix Version/s: 2.0.2 2.1.1

[jira] [Created] (KAFKA-7821) Default cache size can lose session windows in high-throughput deployment

Matthew Jarvie created KAFKA-7821: - Summary: Default cache size can lose session windows in high-throughput deployment Key: KAFKA-7821 URL: https://issues.apache.org/jira/browse/KAFKA-7821 Project: Ka

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

See Changes: [manikumar.reddy] MINOR: Fix typo in security.html (#6141) -- [...truncated 4.51 MB...] org.apache.kafka.streams.test.OutputVerifierTest > shouldFailIfValueI

[jira] [Resolved] (KAFKA-6627) Console producer default config values override explicitly provided properties

[ https://issues.apache.org/jira/browse/KAFKA-6627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kan Li resolved KAFKA-6627. --- Resolution: Fixed > Console producer default config values override explicitly provided properties >

[jira] [Created] (KAFKA-7820) distinct count kafka streams api

Vinoth Rajasekar created KAFKA-7820: --- Summary: distinct count kafka streams api Key: KAFKA-7820 URL: https://issues.apache.org/jira/browse/KAFKA-7820 Project: Kafka Issue Type: New Feature

Re: [DISCUSS] KIP-415: Incremental Cooperative Rebalancing in Kafka Connect

Hey Konstantine, great work for making this happen! Incremental rebalancing is super important for avoiding unnecessary resource shuffle and improving the overall Connect framework stability. After the first pass, two questions across my mind are: 1. For my understanding, the general rebala

Re: [DISCUSS] KIP-390: Add producer option to adjust compression level

I just realized that there was a missing hole in the KIP, so I fixed it. The draft implementation will be updated soon. In short, the proposed change did not regard the case of the topic or broker's 'compression.type' is 'producer'; in this case, the broker has to handle all kinds of the supported

Re: [DISCUSS] KIP-402: Improve fairness in SocketServer processors

+1 to include in 2.2. Thanks Rajini for sharing the details. On Mon, Jan 14, 2019, at 9:10 AM, Rajini Sivaram wrote: > This is the result of the tests Gardner did before deploying the patch > (thanks Gardner!): > > *We used the Trogdor `ConnectionStress` workload to test the lazy buffer > allocat

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

See

[jira] [Resolved] (KAFKA-7808) AdminClient#describeTopics should not throw InvalidTopicException if topic name is not found

[ https://issues.apache.org/jira/browse/KAFKA-7808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-7808. -- Resolution: Fixed Fix Version/s: 2.2.0 > AdminClient#describeTopics should not throw Inv

Re: [DISCUSS] KIP-402: Improve fairness in SocketServer processors

This is the result of the tests Gardner did before deploying the patch (thanks Gardner!): *We used the Trogdor `ConnectionStress` workload to test the lazy buffer allocation patch (which has already been merged to AK) and the bounded acceptor queue patch. We didn't see any performance difference b

Re: [VOTE] KIP-379: Multiple Consumer Group Management

Hi, Thanks for this KIP. Could you kindly clarify why CSV format is useful, but not anything else? CSV format is ancient and the only reason it keep existing is various application is because legacy applications aren't moving away from using them. Would you would consider JSON or YAML? Also, if

Re: [VOTE] KIP-379: Multiple Consumer Group Management

+1 thx On Mon, Jan 14, 2019, 8:06 AM Gwen Shapira +1. Thanks, that will be very helpful. > > On Mon, Jan 14, 2019, 4:43 AM Alex D > > Hello guys, > > > > We need your VOTES for the KIP-379: Multiple Consumer Group Management. > > > > KIP-379: > > > > > https://cwiki.apache.org/confluence/display

[jira] [Created] (KAFKA-7819) Trogdor - Improve RoundTripWorker

Stanislav Kozlovski created KAFKA-7819: -- Summary: Trogdor - Improve RoundTripWorker Key: KAFKA-7819 URL: https://issues.apache.org/jira/browse/KAFKA-7819 Project: Kafka Issue Type: Impro

Re: [VOTE] KIP-379: Multiple Consumer Group Management

+1. Thanks, that will be very helpful. On Mon, Jan 14, 2019, 4:43 AM Alex D Hello guys, > > We need your VOTES for the KIP-379: Multiple Consumer Group Management. > > KIP-379: > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-379%3A+Multiple+Consumer+Group+Management > > PR: https://gith

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

See

RE: [EXTERNAL] - Re: [DISCUSS] KIP-387: Fair Message Consumption Across Partitions in KafkaConsumer

Hi, I know everyone is busy. But I would appreciate someone letting me know what to do next. I started this effort back in last year early November... Thanks, CH -Original Message- From: ChienHsing Wu Sent: Monday, January 07, 2019 9:24 AM To: dev@kafka.apache.org Subject: RE: [EXTERN

[jira] [Resolved] (KAFKA-4325) Improve processing of late records for window operations

[ https://issues.apache.org/jira/browse/KAFKA-4325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-4325. - Resolution: Fixed Fix Version/s: 2.1.0 As [~mjsax] noted, this need was satisfied by KAFKA

[jira] [Created] (KAFKA-7818) Make the KafkaConsumer AutoCloseable

Fokko Driesprong created KAFKA-7818: --- Summary: Make the KafkaConsumer AutoCloseable Key: KAFKA-7818 URL: https://issues.apache.org/jira/browse/KAFKA-7818 Project: Kafka Issue Type: Bug

[VOTE] KIP-379: Multiple Consumer Group Management

Hello guys, We need your VOTES for the KIP-379: Multiple Consumer Group Management. KIP-379: https://cwiki.apache.org/confluence/display/KAFKA/KIP-379%3A+Multiple+Consumer+Group+Management PR: https://github.com/apache/kafka/pull/5726/ Let's start the voting session. Thank you, Alex Dunayevsk

[jira] [Created] (KAFKA-7817) Multiple Consumer Group Management with Regex

Alex Dunayevsky created KAFKA-7817: -- Summary: Multiple Consumer Group Management with Regex Key: KAFKA-7817 URL: https://issues.apache.org/jira/browse/KAFKA-7817 Project: Kafka Issue Type: N

Re: [VOTE] KIP-389: Introduce a configurable consumer group size limit

+1 (non-binding) Looks like a good improvement. Andrew Schofield IBM Event Streams On 11/01/2019, 17:33, "Boyang Chen" wrote: +1 (non-binding) Thanks for the great work! Get Outlook for iOS