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

See Changes: [me] MINOR: Add comment for round robin partitioner with different -- [...truncated 6502 lines...] kafka.producer.AsyncProducerTest > testNoBroker PASSED kafka.producer.AsyncProdu

[jira] [Commented] (KAFKA-3800) java client can`t poll msg

[ https://issues.apache.org/jira/browse/KAFKA-3800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15320031#comment-15320031 ] frank commented on KAFKA-3800: -- i`m try this config.yet.the result is the same.curiously,same

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

See Changes: [me] MINOR: Add comment for round robin partitioner with different -- [...truncated 6524 lines...] kafka.security.auth.SimpleAclAuthorizerTest > testLoadCache PASSED kafka.integrat

[jira] [Commented] (KAFKA-3800) java client can`t poll msg

[ https://issues.apache.org/jira/browse/KAFKA-3800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15319975#comment-15319975 ] Ewen Cheslack-Postava commented on KAFKA-3800: -- This code will only read new

[jira] [Commented] (KAFKA-3800) java client can`t poll msg

[ https://issues.apache.org/jira/browse/KAFKA-3800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15319928#comment-15319928 ] frank commented on KAFKA-3800: -- i get kafka example on github. `Properties props = new Prope

[jira] [Commented] (KAFKA-3800) java client can`t poll msg

[ https://issues.apache.org/jira/browse/KAFKA-3800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15319913#comment-15319913 ] Ewen Cheslack-Postava commented on KAFKA-3800: -- [~frank_zg] Can you provide m

[GitHub] kafka pull request #1475: MINOR: Add comment for round robin partitioner wit...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1475 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[jira] [Commented] (KAFKA-3803) JsonConverter deserialized Struct containing bytes field does not return true for equals()

[ https://issues.apache.org/jira/browse/KAFKA-3803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15319879#comment-15319879 ] Ewen Cheslack-Postava commented on KAFKA-3803: -- Part of the problem might be

Re: [DISCUSS] KIP-54 Sticky Partition Assignment Strategy

Hi Jason, I updated the KIP and added some details about the user data, the assignment algorithm, and the alternative strategies to consider. https://cwiki.apache.org/confluence/display/KAFKA/KIP-54+-+Sticky+Partition+Assignment+Strategy Please let me know if I missed to add something. Thank you

[jira] [Comment Edited] (KAFKA-3803) JsonConverter deserialized Struct containing bytes field does not return true for equals()

[ https://issues.apache.org/jira/browse/KAFKA-3803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15319515#comment-15319515 ] Randall Hauch edited comment on KAFKA-3803 at 6/7/16 10:25 PM: -

[jira] [Commented] (KAFKA-3803) JsonConverter deserialized Struct containing bytes field does not return true for equals()

[ https://issues.apache.org/jira/browse/KAFKA-3803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15319529#comment-15319529 ] Randall Hauch commented on KAFKA-3803: -- BTW, I had no idea until I started looking in

[jira] [Commented] (KAFKA-3803) JsonConverter deserialized Struct containing bytes field does not return true for equals()

[ https://issues.apache.org/jira/browse/KAFKA-3803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15319515#comment-15319515 ] Randall Hauch commented on KAFKA-3803: -- The {{equals(...)}} method on {{org.apache.ka

[jira] [Resolved] (KAFKA-3804) Kafka Connect's Struct objects rehydrated with JSON converter are not equal

[ https://issues.apache.org/jira/browse/KAFKA-3804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-3804. -- Resolution: Duplicate > Kafka Connect's Struct objects rehydrated with JSON converter are not eq

[jira] [Updated] (KAFKA-3803) JsonConverter deserialized Struct containing bytes field does not return true for equals()

[ https://issues.apache.org/jira/browse/KAFKA-3803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3803: - Component/s: KafkaConnect > JsonConverter deserialized Struct containing bytes fie

[jira] [Created] (KAFKA-3803) JsonConverter deserialized Struct containing bytes field does not return true for equals()

Ewen Cheslack-Postava created KAFKA-3803: Summary: JsonConverter deserialized Struct containing bytes field does not return true for equals() Key: KAFKA-3803 URL: https://issues.apache.org/jira/browse/KAFK

[jira] [Created] (KAFKA-3804) Kafka Connect's Struct objects rehydrated with JSON converter are not equal

Randall Hauch created KAFKA-3804: Summary: Kafka Connect's Struct objects rehydrated with JSON converter are not equal Key: KAFKA-3804 URL: https://issues.apache.org/jira/browse/KAFKA-3804 Project: Ka

[jira] [Commented] (KAFKA-3762) Log.loadSegments() should log the message in exception

[ https://issues.apache.org/jira/browse/KAFKA-3762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15319487#comment-15319487 ] Ishita Mandhan commented on KAFKA-3762: --- [~junrao] Is this what you had in mind? ^

[jira] [Commented] (KAFKA-3762) Log.loadSegments() should log the message in exception

[ https://issues.apache.org/jira/browse/KAFKA-3762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15319485#comment-15319485 ] ASF GitHub Bot commented on KAFKA-3762: --- GitHub user imandhan opened a pull request:

[GitHub] kafka pull request #1480: KAFKA-3762 Log.loadSegments() should log the messa...

GitHub user imandhan opened a pull request: https://github.com/apache/kafka/pull/1480 KAFKA-3762 Log.loadSegments() should log the message in exception Adding an error logging message in Log.loadSegments() in the case when an index file corresponding to a log file exists but an exce

[VOTE] KIP-55: Secure quotas for authenticated users

I would like to initiate the vote for KIP-55. The KIP details are here: KIP-55: Secure quotas for authenticated users . The JIRA KAFKA-3492 has a

Re: [DISCUSS] KIP-55: Secure quotas for authenticated users

Jun, Thank you, I will start a vote. On Tue, Jun 7, 2016 at 8:49 PM, Jun Rao wrote: > Rajini, > > Thanks for the updated wiki. It looks good to me. Do you want to start a > vote on this? > > Jun > > On Fri, May 27, 2016 at 11:47 AM, Rajini Sivaram < > rajinisiva...@googlemail.com> wrote: > > >

[jira] [Commented] (KAFKA-1194) The kafka broker cannot delete the old log files after the configured time

[ https://issues.apache.org/jira/browse/KAFKA-1194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15319324#comment-15319324 ] Ravi Peri commented on KAFKA-1194: -- Sriharsha, Sure, I will send it as a PR on github.co

[jira] [Commented] (KAFKA-3802) log mtimes reset on broker restart

[ https://issues.apache.org/jira/browse/KAFKA-3802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15319321#comment-15319321 ] Andrew Otto commented on KAFKA-3802: I am running Kafka 0.9.01 on Debian Jessie, with

[jira] [Commented] (KAFKA-1194) The kafka broker cannot delete the old log files after the configured time

[ https://issues.apache.org/jira/browse/KAFKA-1194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15319281#comment-15319281 ] Sriharsha Chintalapani commented on KAFKA-1194: --- [~rperi] can you send the p

[jira] [Commented] (KAFKA-3693) Race condition between highwatermark-checkpoint thread and handleLeaderAndIsrRequest at broker start-up

[ https://issues.apache.org/jira/browse/KAFKA-3693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15319273#comment-15319273 ] Maysam Yabandeh commented on KAFKA-3693: Thanks for the grep hints [~junrao]. Acco

[jira] [Commented] (KAFKA-3802) log mtimes reset on broker restart

[ https://issues.apache.org/jira/browse/KAFKA-3802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15319233#comment-15319233 ] Dustin Cote commented on KAFKA-3802: I'm thinking that there's no partition reassignme

[jira] [Commented] (KAFKA-3796) SslTransportLayerTest.testInvalidEndpointIdentification fails on trunk

[ https://issues.apache.org/jira/browse/KAFKA-3796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15319236#comment-15319236 ] Rekha Joshi commented on KAFKA-3796: Actually strangely I was not able to replicate th

Re: [DISCUSS] KIP-55: Secure quotas for authenticated users

Rajini, Thanks for the updated wiki. It looks good to me. Do you want to start a vote on this? Jun On Fri, May 27, 2016 at 11:47 AM, Rajini Sivaram < rajinisiva...@googlemail.com> wrote: > Jun, > > Thank you for the review and the suggestions. I have updated the KIP with > the changes you sugge

[jira] [Commented] (KAFKA-3802) log mtimes reset on broker restart

[ https://issues.apache.org/jira/browse/KAFKA-3802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15319225#comment-15319225 ] Andrew Otto commented on KAFKA-3802: Possibly related to KAFKA-1379 > log mtimes rese

[jira] [Created] (KAFKA-3802) log mtimes reset on broker restart

Andrew Otto created KAFKA-3802: -- Summary: log mtimes reset on broker restart Key: KAFKA-3802 URL: https://issues.apache.org/jira/browse/KAFKA-3802 Project: Kafka Issue Type: Bug Affects Vers

[jira] [Commented] (KAFKA-3061) Get rid of Guava dependency

[ https://issues.apache.org/jira/browse/KAFKA-3061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15319155#comment-15319155 ] Ewen Cheslack-Postava commented on KAFKA-3061: -- Following up on this as I saw

Re: [DISCUSS] KIP-54 Sticky Partition Assignment Strategy

Hi Jason, Sorry about my misunderstanding, and thanks for sending the reference. The grammar you sent is correct; that is how the current assignments are preserved in the current implementation. I understand your point about limiting the policies provided with the Kafka release, and the value o

[jira] [Commented] (KAFKA-3797) Improve security of __consumer_offsets topic

[ https://issues.apache.org/jira/browse/KAFKA-3797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15318933#comment-15318933 ] Ismael Juma commented on KAFKA-3797: Seems to me that this would need a KIP, right? >

[jira] [Commented] (KAFKA-3797) Improve security of __consumer_offsets topic

[ https://issues.apache.org/jira/browse/KAFKA-3797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15318934#comment-15318934 ] Sriharsha Chintalapani commented on KAFKA-3797: --- [~hachikuji] for second opt

[jira] [Assigned] (KAFKA-3061) Get rid of Guava dependency

[ https://issues.apache.org/jira/browse/KAFKA-3061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rekha Joshi reassigned KAFKA-3061: -- Assignee: Rekha Joshi > Get rid of Guava dependency > --- > >

[jira] [Assigned] (KAFKA-3797) Improve security of __consumer_offsets topic

[ https://issues.apache.org/jira/browse/KAFKA-3797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian reassigned KAFKA-3797: -- Assignee: Vahid Hashemian > Improve security of __consumer_offsets topic >

[jira] [Commented] (KAFKA-3797) Improve security of __consumer_offsets topic

[ https://issues.apache.org/jira/browse/KAFKA-3797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15318896#comment-15318896 ] Vahid Hashemian commented on KAFKA-3797: [~hachikuji] Sounds good. I can't think o

[jira] [Commented] (KAFKA-3797) Improve security of __consumer_offsets topic

[ https://issues.apache.org/jira/browse/KAFKA-3797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15318854#comment-15318854 ] Todd Palino commented on KAFKA-3797: I think the first option is more reasonable, and

[jira] [Commented] (KAFKA-3797) Improve security of __consumer_offsets topic

[ https://issues.apache.org/jira/browse/KAFKA-3797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15318833#comment-15318833 ] Jason Gustafson commented on KAFKA-3797: [~vahid] Feel free to take it, but we sho

[jira] [Created] (KAFKA-3801) Provide static serialize() and deserialize() for use as method references

Jeff Klukas created KAFKA-3801: -- Summary: Provide static serialize() and deserialize() for use as method references Key: KAFKA-3801 URL: https://issues.apache.org/jira/browse/KAFKA-3801 Project: Kafka

[jira] [Updated] (KAFKA-1211) Hold the produce request with ack > 1 in purgatory until replicas' HW has larger than the produce offset

[ https://issues.apache.org/jira/browse/KAFKA-1211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-1211: --- Fix Version/s: (was: 0.10.1.0) 0.11.0.0 > Hold the produce request with ack > 1

[jira] [Commented] (KAFKA-1211) Hold the produce request with ack > 1 in purgatory until replicas' HW has larger than the produce offset

[ https://issues.apache.org/jira/browse/KAFKA-1211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15318817#comment-15318817 ] Ismael Juma commented on KAFKA-1211: Thanks Jun, I changed the fix version since I don

[jira] [Commented] (KAFKA-1211) Hold the produce request with ack > 1 in purgatory until replicas' HW has larger than the produce offset

[ https://issues.apache.org/jira/browse/KAFKA-1211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15318799#comment-15318799 ] Jun Rao commented on KAFKA-1211: This is still an issue. It can cause data loss if the lea

[jira] [Commented] (KAFKA-3711) Allow configuration of MetricsReporter subclasses

[ https://issues.apache.org/jira/browse/KAFKA-3711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15318768#comment-15318768 ] Jeff Klukas commented on KAFKA-3711: I submitted a PR above to call {{originals()}} wh

[jira] [Commented] (KAFKA-3711) Allow configuration of MetricsReporter subclasses

[ https://issues.apache.org/jira/browse/KAFKA-3711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15318756#comment-15318756 ] ASF GitHub Bot commented on KAFKA-3711: --- GitHub user jklukas opened a pull request:

[GitHub] kafka pull request #1479: KAFKA-3711: Ensure a RecordingMap is passed to con...

GitHub user jklukas opened a pull request: https://github.com/apache/kafka/pull/1479 KAFKA-3711: Ensure a RecordingMap is passed to configured instances See https://issues.apache.org/jira/browse/KAFKA-3711 I've tested locally that this change does indeed resolve the warning

[jira] [Commented] (KAFKA-3693) Race condition between highwatermark-checkpoint thread and handleLeaderAndIsrRequest at broker start-up

[ https://issues.apache.org/jira/browse/KAFKA-3693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15318753#comment-15318753 ] Jun Rao commented on KAFKA-3693: [~maysam], when broker 16 completes the shutdown, the con

[jira] [Commented] (KAFKA-3711) Allow configuration of MetricsReporter subclasses

[ https://issues.apache.org/jira/browse/KAFKA-3711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15318546#comment-15318546 ] Jeff Klukas commented on KAFKA-3711: I would love to see this fixed as well. I'd also

[jira] [Commented] (KAFKA-3753) Metrics for StateStores

[ https://issues.apache.org/jira/browse/KAFKA-3753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15318521#comment-15318521 ] Jeff Klukas commented on KAFKA-3753: It's good to know about MeteredKeyValueStore. And

[jira] [Commented] (KAFKA-3167) Use local to the workspace Gradle cache and recreate it on every build

[ https://issues.apache.org/jira/browse/KAFKA-3167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15318445#comment-15318445 ] Ismael Juma commented on KAFKA-3167: Posted to the Gradle forums: https://discuss.gra

[GitHub] kafka pull request #1478: KAFKA-3562: Handle topic deletion during a send

GitHub user rajinisivaram opened a pull request: https://github.com/apache/kafka/pull/1478 KAFKA-3562: Handle topic deletion during a send You can merge this pull request into a Git repository by running: $ git pull https://github.com/rajinisivaram/kafka KAFKA-3562 Alternativ

[jira] [Commented] (KAFKA-3562) Null Pointer Exception Found when delete topic and Using New Producer

[ https://issues.apache.org/jira/browse/KAFKA-3562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15318416#comment-15318416 ] ASF GitHub Bot commented on KAFKA-3562: --- GitHub user rajinisivaram opened a pull req

[jira] [Created] (KAFKA-3800) java client can`t poll msg

frank created KAFKA-3800: Summary: java client can`t poll msg Key: KAFKA-3800 URL: https://issues.apache.org/jira/browse/KAFKA-3800 Project: Kafka Issue Type: Bug Components: consumer A

[jira] [Assigned] (KAFKA-3562) Null Pointer Exception Found when delete topic and Using New Producer

[ https://issues.apache.org/jira/browse/KAFKA-3562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram reassigned KAFKA-3562: - Assignee: Rajini Sivaram > Null Pointer Exception Found when delete topic and Using New P

[jira] [Created] (KAFKA-3799) Turn on endpoint validation in SSL system tests

Rajini Sivaram created KAFKA-3799: - Summary: Turn on endpoint validation in SSL system tests Key: KAFKA-3799 URL: https://issues.apache.org/jira/browse/KAFKA-3799 Project: Kafka Issue Type: T

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

See

[jira] [Commented] (KAFKA-3748) Add consumer-property to console tools consumer (similar to --producer-property)

[ https://issues.apache.org/jira/browse/KAFKA-3748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15318004#comment-15318004 ] ASF GitHub Bot commented on KAFKA-3748: --- Github user asfgit closed the pull request

[GitHub] kafka pull request #1474: KAFKA-3748: Add consumer-property to console tools...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1474 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab