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

See Changes: [wangguoz] KAFKA-6844: Call shutdown on GlobalStreamThread after all StreamThreads [jason] KAFKA-6867; Corrected the typos in upgrade.html (#4970) [github] MINOR: Remove KafkaStreams#toString

Build failed in Jenkins: kafka-trunk-jdk7 #3402

See Changes: [github] MINOR: Remove KafkaStreams#toString (#4909) -- [...truncated 417.00 KB...] kafka.admin.ResetConsumerGroupOffsetTest > testResetOffsetsShiftPlus

Jenkins build is back to normal : kafka-trunk-jdk10 #79

See

Jenkins build is back to normal : kafka-trunk-jdk7 #3401

See

Re: [VOTE] KIP-219 - Improve Quota Communication

Per Rajini's request, I'd like to add one more discussion item. I added the THROTTLE_TIME_MS field to LeaderAndIsrResponse, UpdateMetadataResponse, SaslAuthenticateResponse and SaslHandshakeResponse. These are cluster actions and normally not throttled, but they can actually be throttled on

Re: [VOTE] KIP-266: Add TimeoutException for KafkaConsumer#position

Hi all, I would like to bump this thread since discussion in the KIP appears to be reaching its conclusion. On Thu, Mar 15, 2018 at 3:30 PM, Richard Yu wrote: > Hi all, > > Since there does not seem to be too much discussion in KIP-266, I will be > starting a

[jira] [Created] (KAFKA-6868) BufferUnderflowException in client when querying consumer group information

Xavier Léauté created KAFKA-6868: Summary: BufferUnderflowException in client when querying consumer group information Key: KAFKA-6868 URL: https://issues.apache.org/jira/browse/KAFKA-6868 Project:

[VOTE] KIP-266: Add TimeoutException to KafkaConsumer#position()

Hi all, It appears that discussion is coming to a close for KIP-266. I would like to start a voting thread for this KIP. Here is the link for reference. https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=75974886 Thanks, Richard

[jira] [Resolved] (KAFKA-6795) Add unit test for ReplicaAlterLogDirsThread

[ https://issues.apache.org/jira/browse/KAFKA-6795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anna Povzner resolved KAFKA-6795. - Resolution: Fixed Fix Version/s: 2.0.0 > Add unit test for ReplicaAlterLogDirsThread >

[jira] [Resolved] (KAFKA-6867) Typos in upgrade.html

[ https://issues.apache.org/jira/browse/KAFKA-6867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6867. Resolution: Fixed > Typos in upgrade.html > - > > Key:

Re: KIP-244: Add Record Header support to Kafka Streams

Hello Jorge, > Agree. Probably point 3 handles this. `Headers` been part of `RecordContext` would be handled the same way as other attributes. Today we do not have a clear inheritance protocol for other fields of RecordContext yet: although internally we do have some criterion on

[DISCUSS] KIP-294 - Enable TLS hostname verification by default

Hi all, I have submitted KIP-294 to make the default value of the config ` ssl.endpoint.identification.algorithm` secure: https://cwiki.apache.org/confluence/display/KAFKA/KIP-294+-+Enable+TLS+hostname+verification+by+default Feedback is welcome. Regards, Rajini

Re: [DISCUSS] KIP-280: Enhanced log compaction

Thanks Luís, I do not have other comments on this KIP. I'd also like to ping Jason and Jun to take a look at this one. Guozhang On Thu, May 3, 2018 at 1:40 AM, Luís Cabral wrote: > > Hi Guozhang, > > No worries, looking at the traffic on this project, I'm sure

[jira] [Created] (KAFKA-6867) Typos in upgrade.html

Jakob Homan created KAFKA-6867: -- Summary: Typos in upgrade.html Key: KAFKA-6867 URL: https://issues.apache.org/jira/browse/KAFKA-6867 Project: Kafka Issue Type: Improvement

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

See

Build failed in Jenkins: kafka-trunk-jdk10 #78

See Changes: [wangguoz] HOTFIX: fix streams tutorial code example -- [...truncated 1.49 MB...] kafka.tools.ConsoleConsumerTest >

[jira] [Resolved] (KAFKA-6865) Devops Insights

[ https://issues.apache.org/jira/browse/KAFKA-6865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6865. Resolution: Incomplete > Devops Insights > --- > > Key:

[jira] [Resolved] (KAFKA-6866) Increase memory

[ https://issues.apache.org/jira/browse/KAFKA-6866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6866. Resolution: Incomplete > Increase memory > --- > > Key:

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

See Changes: [wangguoz] KAFKA-6761: Part 1 of 3; Graph nodes (#4923) [github] MINOR: Removed deprecated schedule function (#4908) [wangguoz] KAFKA-5697: issue Consumer#wakeup during Streams shutdown

[jira] [Created] (KAFKA-6866) Increase memory

ravi created KAFKA-6866: --- Summary: Increase memory Key: KAFKA-6866 URL: https://issues.apache.org/jira/browse/KAFKA-6866 Project: Kafka Issue Type: Improvement Reporter: ravi Increase

[jira] [Resolved] (KAFKA-6861) Missing ')' in Kafka Streams documentation

[ https://issues.apache.org/jira/browse/KAFKA-6861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6861. -- Resolution: Fixed > Missing ')' in Kafka Streams documentation >

[jira] [Created] (KAFKA-6865) Devops Insights

ravi created KAFKA-6865: --- Summary: Devops Insights Key: KAFKA-6865 URL: https://issues.apache.org/jira/browse/KAFKA-6865 Project: Kafka Issue Type: New Feature Reporter: ravi Devops

[jira] [Resolved] (KAFKA-5697) StreamThread.shutdown() need to interrupt the stream threads to break the loop

[ https://issues.apache.org/jira/browse/KAFKA-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5697. -- Resolution: Fixed Fix Version/s: 2.0.0 Issue resolved by pull request 4930

Re: [VOTE] KIP-206: Add support for UUID serialization and deserialization

Hi Brandon, +1 (binding) Thanks for the KIP! Regards, Rajini On Fri, May 4, 2018 at 2:14 PM, Brandon Kirchner wrote: > I'd like to resurrect this one last time, any chance we can get some more > binding votes and move this forward? > > Brandon K. > > On Fri, Feb

Possible bug: KafkaConsumer.endOffsets can return partial data

Hello. When migrating to 1.1.0 I faced with changed behavior: KafkaConsumer.endOffsets can return partial data. As I see it was introduced with KAFKA-6397 (Consumer should not block setting initial positions of unavailable partitions). There is strange code at

Re: [VOTE] KIP-255: OAuth Authentication via SASL/OAUTHBEARER

Hi Ron, +1 (binding) Thanks for the KIP! Regards, Rajini On Fri, May 4, 2018 at 4:55 AM, Ron Dagostino wrote: > Hi everyone. I would like to start the vote for KIP-255: > https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=75968876 > > This KIP proposes to

[jira] [Resolved] (KAFKA-6857) LeaderEpochFileCache.endOffsetFor() should check for UNDEFINED_EPOCH explicitly

[ https://issues.apache.org/jira/browse/KAFKA-6857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6857. Resolution: Fixed Fix Version/s: 1.1.1 1.0.2

[jira] [Created] (KAFKA-6864) null is not passed to keyDeserialzer and valueDeserializer in Fetcher

Mathias Kub created KAFKA-6864: -- Summary: null is not passed to keyDeserialzer and valueDeserializer in Fetcher Key: KAFKA-6864 URL: https://issues.apache.org/jira/browse/KAFKA-6864 Project: Kafka

Re: [VOTE] KIP-206: Add support for UUID serialization and deserialization

I'd like to resurrect this one last time, any chance we can get some more binding votes and move this forward? Brandon K. On Fri, Feb 2, 2018 at 11:35 AM, Colin McCabe wrote: > Hi Brandon, > > I think people are generally busy working on the upcoming release now. > Sorry

[jira] [Created] (KAFKA-6863) Kafka clients should try to use multiple DNS resolved IP addresses if the first one fails

Edoardo Comar created KAFKA-6863: Summary: Kafka clients should try to use multiple DNS resolved IP addresses if the first one fails Key: KAFKA-6863 URL: https://issues.apache.org/jira/browse/KAFKA-6863

Re: [VOTE] #2 KIP-248: Create New ConfigCommand That Uses The New AdminClient

Hi Colin, > Rather than breaking compatibility, we should simply add a new "incremental" > boolean to AlterConfigsOptions. Callers can set this boolean to true when > they want the update to be incremental. It should default to false so that > old code continues to work. Agreed, let's do it

Re: KIP-244: Add Record Header support to Kafka Streams

Hi, For me this is a great first step to have Headers in streaming. My current use case is about distributed tracing (Zipkin) and with the headers in the processorContext() I'll be able to manage that for the most cases. The KIP-159 should follow after this but this is where all the major

[jira] [Created] (KAFKA-6862) test toolchain

ravi created KAFKA-6862: --- Summary: test toolchain Key: KAFKA-6862 URL: https://issues.apache.org/jira/browse/KAFKA-6862 Project: Kafka Issue Type: Test Components: build

Re: KIP 244 WIP

Hi Florian, I have updated this KIP and restarted the discussion to reduce scope to Processor API first, to then prepare another KIP to define behaviour on DSL functions. Feel free to validate the current WIP and give feedback to check that KIP is supporting your use-case. Cheers, Jorge. El

Jenkins build is back to normal : kafka-1.1-jdk7 #126

See

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

See Changes: [jason] KAFKA-6857; Leader should reply with undefined offset if undefined -- [...truncated 421.57 KB...] kafka.utils.json.JsonValueTest > testDecodeString