Build failed in Jenkins: kafka-0.11.0-jdk7 #383

See -- [...truncated 2.45 MB...] org.apache.kafka.streams.integration.EosIntegrationTest > shouldBeAbleToCommitMultiplePartitionOffsets STARTED org.apache.kafka.streams.integration.EosI

Build failed in Jenkins: kafka-0.10.2-jdk7 #217

See -- [...truncated 1.31 MB...] org.apache.kafka.streams.processor.internals.StreamThreadTest > testStateChangeStartClose STARTED org.apache.kafka.streams.processor.internals.StreamThr

Re: [DISCUSS] KIP-317: Transparent Data Encryption

Hi Stephane, thanks for pointing out the broken pictures, I fixed those. Regarding encrypting before or after batching the messages, you are correct, I had not thought of compression and how this changes things. Encrypted data does not really encrypt well. My reasoning at the time of writing was

[jira] [Created] (KAFKA-7073) Allow retries to try different partitions where the use case allows it

moshe blumberg created KAFKA-7073: - Summary: Allow retries to try different partitions where the use case allows it Key: KAFKA-7073 URL: https://issues.apache.org/jira/browse/KAFKA-7073 Project: Kafka

[jira] [Resolved] (KAFKA-5348) kafka-consumer-groups.sh refuses to remove groups without ids

[ https://issues.apache.org/jira/browse/KAFKA-5348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5348. -- Resolution: Auto Closed {color:#00}The Scala consumers have been deprecated and will be removed in

[jira] [Resolved] (KAFKA-6934) Csv reporter doesn't work for ConsoleConsumer

[ https://issues.apache.org/jira/browse/KAFKA-6934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6934. -- Resolution: Won't Fix Csv reporter works with old consumer. Old consumer related options will be remov

[jira] [Created] (KAFKA-7074) Race condition between Kafka log deletion and compaction

Phil Mikhailov created KAFKA-7074: - Summary: Race condition between Kafka log deletion and compaction Key: KAFKA-7074 URL: https://issues.apache.org/jira/browse/KAFKA-7074 Project: Kafka Issu

[jira] [Resolved] (KAFKA-6737) Is Kafka imapcted by critical vulnerqbilty CVE-2018-7489

[ https://issues.apache.org/jira/browse/KAFKA-6737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6737. -- Resolution: Fixed Fix Version/s: 2.0.0 This will be fixed part of upcoming 2.00, 1.1.1, 1.0.2 re

[jira] [Resolved] (KAFKA-6564) Fix broken links in Dockerfile

[ https://issues.apache.org/jira/browse/KAFKA-6564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6564. -- Resolution: Fixed Fix Version/s: 1.0.2 This will get fixed in upcoming 1.0.2 release. > Fix bro

Re: [DISCUSS] KIP-252: Extend ACLs to allow filtering based on ip ranges and subnets

Picking this back up, now that KIP-290 has been merged.. As Colin mentioned in an earlier mail this change could create a potential security issue if not all brokers are upgraded and a DENY Acl based on an IP range is created, as old brokers won't match this rule and still allow requests. As I sta

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

See

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

See Changes: [rajinisivaram] KAFKA-7012: Don't process SSL channels without data to process (#5237) [ismael] KAFKA-2983: Remove Scala consumers and related code (#5230) -- [

Re: [DISCUSS] - KIP-314: KTable to GlobalKTable Bi-directional Join

Matthias Thanks for the links. I have seen those before but I will dig deeper into them, especially around the CombinedKey and the flush + cache + rangescan functionality. I believe Jan had a PR with many of the changes in there, perhaps I can use some of the work that was done there to help lever

[jira] [Resolved] (KAFKA-6485) 'ConsumerGroupCommand' performance optimization for old consumer describe group

[ https://issues.apache.org/jira/browse/KAFKA-6485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6485. -- Resolution: Auto Closed The Scala consumers are deprecated. The old clients and related tools are remo

Jenkins build is back to normal : kafka-0.10.2-jdk7 #218

See

Jenkins build is back to normal : kafka-0.11.0-jdk7 #384

See

Re: [VOTE] KIP-291: Have separate queues for control requests and data requests

Hi Jun, Ismael, Can you please take a look when you get a chance? Thanks! Lucas On Mon, Jun 18, 2018 at 1:47 PM, Ted Yu wrote: > +1 > > On Mon, Jun 18, 2018 at 1:04 PM, Lucas Wang wrote: > > > Hi All, > > > > I've addressed a couple of comments in the discussion thread for KIP-291, > > and >

[jira] [Resolved] (KAFKA-7064) "Unexpected resource type GROUP" when describing broker configs using latest admin client

[ https://issues.apache.org/jira/browse/KAFKA-7064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-7064. Resolution: Fixed Merged [https://github.com/apache/kafka/pull/5245] to trunk and 2.0 branch. > "Unexpecte

[jira] [Resolved] (KAFKA-7066) Make Streams Runtime Error User Friendly in Case of Serialisation exception

[ https://issues.apache.org/jira/browse/KAFKA-7066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-7066. -- Resolution: Fixed > Make Streams Runtime Error User Friendly in Case of Serialisation exception

[jira] [Resolved] (KAFKA-6881) Kafka 1.1 Broker version crashes when deleting log

[ https://issues.apache.org/jira/browse/KAFKA-6881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dhruvil Shah resolved KAFKA-6881. - Resolution: Not A Bug Closing this JIRA because /tmp was being used as the log directory. > Kafk

[jira] [Created] (KAFKA-7075) Allow Topology#addGlobalStore to add a window store

Guozhang Wang created KAFKA-7075: Summary: Allow Topology#addGlobalStore to add a window store Key: KAFKA-7075 URL: https://issues.apache.org/jira/browse/KAFKA-7075 Project: Kafka Issue Type:

[VOTE] 1.1.1 RC0

Hello Kafka users, developers and client-developers, This is the first candidate for release of Apache Kafka 1.1.1. Apache Kafka 1.1.1 is a bug-fix release for the 1.1 branch that was first released with 1.1.0 about 3 months ago. We have fixed about 25 issues since that release. A few of the more

Re: [VOTE] 1.1.1 RC0

Re-send to kafka-clie...@googlegroups.com On Tue, Jun 19, 2018 at 4:29 PM, Dong Lin wrote: > Hello Kafka users, developers and client-developers, > > This is the first candidate for release of Apache Kafka 1.1.1. > > Apache Kafka 1.1.1 is a bug-fix release for the 1.1 branch that was first > rel

[jira] [Created] (KAFKA-7076) Broker startup could be inefficient when using old message format

Dhruvil Shah created KAFKA-7076: --- Summary: Broker startup could be inefficient when using old message format Key: KAFKA-7076 URL: https://issues.apache.org/jira/browse/KAFKA-7076 Project: Kafka

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

See Changes: [jason] MINOR: Handle segment splitting edge cases and fix recovery bug (#5169) [junrao] Kafka_7064 - bug introduced when switching config commands to -- [...tr

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

See Changes: [github] MINOR: Handle segment splitting edge cases and fix recovery bug (#5169) [junrao] Kafka_7064 - bug introduced when switching config commands to [wangguoz] KAFKA-7066 added better logging

Re: [VOTE] 1.1.1 RC0

+1 Ran unit test suite which passed. Checked signatures. On Tue, Jun 19, 2018 at 4:47 PM, Dong Lin wrote: > Re-send to kafka-clie...@googlegroups.com > > On Tue, Jun 19, 2018 at 4:29 PM, Dong Lin wrote: > > > Hello Kafka users, developers and client-developers, > > > > This is the first candi

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

See

[jira] [Created] (KAFKA-7077) producerProps.put(ProducerConfig.MAX_IN_FLIGHT_REQUESTS_PER_CONNECTION, "5") producerProps.put(ProducerConfig.ENABLE_IDEMPOTENCE, true)

Stephane Maarek created KAFKA-7077: -- Summary: producerProps.put(ProducerConfig.MAX_IN_FLIGHT_REQUESTS_PER_CONNECTION, "5") producerProps.put(ProducerConfig.ENABLE_IDEMPOTENCE, true) Key: KAFKA-7077 URL: https://

[DISCUSS] KIP-318: Make Kafka Connect Source idempotent

KIP link: https://cwiki.apache.org/confluence/display/KAFKA/KIP-318%3A+Make+Kafka+Connect+Source+idempotent By looking at the code, it seems Worker.java is where the magic happens, but do we need to also operate changes to KafkaBasedLog.java (~line 241) ? Love to hear your thoughts!