Re: [DISCUSS] KIP-278: Add version option to Kafka's commands

Hi Jason Thank you for helpful comments. I updated wiki based on your advice. I thought this option was relatively common and making maintenance easy was also important. However, as you said, it is not good that version option won't be shown up in help description. I thought accepting both si

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

Hi Guozhang, Thank you for the feedback! bq. I'm also in favor of making the `timestamp` a preserved config value along with `offset`, for which we would not go into the headers to look for the matching key, but directly look into the timestamp field of the message. Do you mean using an autom

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

See Changes: [rajinisivaram] Kafka-6693: Added consumer workload to Trogdor (#4775) -- [...truncated 412.09 KB...] kafka.zk.KafkaZkClientTest > testGetTopicPartitionStat

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

See Changes: [rajinisivaram] Kafka-6693: Added consumer workload to Trogdor (#4775) -- [...truncated 3.52 MB...] kafka.security.auth.SimpleAclAuthorizerTest > testDistr

[jira] [Created] (KAFKA-6770) 1.1.0 New Protocol Versions section in doc is empty

Mickael Maison created KAFKA-6770: - Summary: 1.1.0 New Protocol Versions section in doc is empty Key: KAFKA-6770 URL: https://issues.apache.org/jira/browse/KAFKA-6770 Project: Kafka Issue Typ

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

See Changes: [rajinisivaram] Make [Config]Resource.toString() consistent with existing code (#4845) -- [...truncated 412.57 KB...] kafka.network.SocketServerTest > testC

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

See Changes: [rajinisivaram] Make [Config]Resource.toString() consistent with existing code (#4845) -- [...truncated 1.48 MB...] kafka.zk.KafkaZkClientTest > testTopicAssig

Re: [VOTE] KIP-284 Set default retention ms for Streams repartition topics to Long.MAX_VALUE

+1 binding On Mon, 9 Apr 2018 at 21:20 Guozhang Wang wrote: > +1 (binding) > > On Mon, Apr 9, 2018 at 11:21 AM, Matthias J. Sax > wrote: > > > +1 (binding) > > > > -Matthias > > > > On 4/9/18 8:57 AM, Bill Bejeck wrote: > > > Thanks for the KIP. > > > > > > +1 > > > > > > -Bill > > > > > > On M

[jira] [Resolved] (KAFKA-6693) Add Consumer-only benchmark workload to Trogdor

[ https://issues.apache.org/jira/browse/KAFKA-6693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anna Povzner resolved KAFKA-6693. - Resolution: Fixed https://github.com/apache/kafka/pull/4775 > Add Consumer-only benchmark workloa

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

See

[jira] [Created] (KAFKA-6771) Make specifying partitions in RoundTripWorkload, ProduceBench more flexible

Colin P. McCabe created KAFKA-6771: -- Summary: Make specifying partitions in RoundTripWorkload, ProduceBench more flexible Key: KAFKA-6771 URL: https://issues.apache.org/jira/browse/KAFKA-6771 Project

[jira] [Created] (KAFKA-6772) Broker should load credentials from ZK before requests are allowed

Ismael Juma created KAFKA-6772: -- Summary: Broker should load credentials from ZK before requests are allowed Key: KAFKA-6772 URL: https://issues.apache.org/jira/browse/KAFKA-6772 Project: Kafka

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

See

[jira] [Created] (KAFKA-6773) Kafka consumer without group.id crashes when requesting offset on a topic-partition

Konstantine Karantasis created KAFKA-6773: - Summary: Kafka consumer without group.id crashes when requesting offset on a topic-partition Key: KAFKA-6773 URL: https://issues.apache.org/jira/browse/KAFKA-677

[jira] [Resolved] (KAFKA-3827) log.message.format.version should default to inter.broker.protocol.version

[ https://issues.apache.org/jira/browse/KAFKA-3827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-3827. Resolution: Won't Fix The currently implementation is easier to understand than what I proposed. Closing th

[jira] [Resolved] (KAFKA-5706) log the name of the error instead of the error code in response objects

[ https://issues.apache.org/jira/browse/KAFKA-5706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-5706. Resolution: Cannot Reproduce [~manasvigupta], this doesn't seem to be an issue any more now that we have co

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

See

[jira] [Created] (KAFKA-6774) Improve default groupId behavior in consumer

Jason Gustafson created KAFKA-6774: -- Summary: Improve default groupId behavior in consumer Key: KAFKA-6774 URL: https://issues.apache.org/jira/browse/KAFKA-6774 Project: Kafka Issue Type: Im

[jira] [Created] (KAFKA-6775) AbstractProcessor created in SimpleBenchmark should call super#init

Ted Yu created KAFKA-6775: - Summary: AbstractProcessor created in SimpleBenchmark should call super#init Key: KAFKA-6775 URL: https://issues.apache.org/jira/browse/KAFKA-6775 Project: Kafka Issue Ty

[jira] [Resolved] (KAFKA-4883) invalid client sasl.jaas.config triggers NullPointerException

[ https://issues.apache.org/jira/browse/KAFKA-4883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4883. -- Resolution: Fixed Assignee: Manikumar Fix Version/s: 1.2.0 > invalid client sasl.jaas.co

[jira] [Created] (KAFKA-6776) Connect Rest Extension Plugin

Magesh kumar Nandakumar created KAFKA-6776: -- Summary: Connect Rest Extension Plugin Key: KAFKA-6776 URL: https://issues.apache.org/jira/browse/KAFKA-6776 Project: Kafka Issue Type: I

Re: [DISCUSS] KIP-276: Add StreamsConfig prefix for different consumers

Hey Ewen, seems that your concern is resolved. Do you mind I move forward to the voting stage for this KIP? Thank you! Boyang From: Boyang Chen Sent: Sunday, April 8, 2018 2:46 AM To: dev@kafka.apache.org Subject: Re: [DISCUSS] KIP-276: Add StreamsConfig pref

[jira] [Created] (KAFKA-6777) Wrong reaction on Out Of Memory situation

Seweryn Habdank-Wojewodzki created KAFKA-6777: - Summary: Wrong reaction on Out Of Memory situation Key: KAFKA-6777 URL: https://issues.apache.org/jira/browse/KAFKA-6777 Project: Kafka