Build failed in Jenkins: kafka-1.1-jdk7 #139

See Changes: [ismael] KAFKA-6760: Fix response logging in the Controller (#4834) -- [...truncated 226.15 KB...] kafka.api.SaslPlainPlaintextConsumerTest > testCoordinatorFai

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

See Changes: [ismael] KAFKA-6760: Fix response logging in the Controller (#4834) -- [...truncated 463.54 KB...] kafka.admin.ResetConsumerGroupOffsetTest > testResetOffsets

[jira] [Created] (KAFKA-6983) Error while deleting segments - The process cannot access the file because it is being used by another process

wade wu created KAFKA-6983: -- Summary: Error while deleting segments - The process cannot access the file because it is being used by another process Key: KAFKA-6983 URL: https://issues.apache.org/jira/browse/KAFKA-6983

[jira] [Created] (KAFKA-6982) java.lang.ArithmeticException: / by zero

wade wu created KAFKA-6982: -- Summary: java.lang.ArithmeticException: / by zero Key: KAFKA-6982 URL: https://issues.apache.org/jira/browse/KAFKA-6982 Project: Kafka Issue Type: Bug Componen

[jira] [Resolved] (KAFKA-6965) log4j:WARN log messages printed when running kafka-console-producer OOB

[ https://issues.apache.org/jira/browse/KAFKA-6965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-6965. Resolution: Not A Bug > log4j:WARN log messages printed when running kafka-console-producer OOB > -

[jira] [Resolved] (KAFKA-6760) responses not logged properly in controller

[ https://issues.apache.org/jira/browse/KAFKA-6760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-6760. Resolution: Fixed Fix Version/s: 1.1.1 2.0.0 > responses not logged prope

[jira] [Created] (KAFKA-6981) Missing Connector Config (errors.deadletterqueue.topic.name) kills Connect Clusters

Arjun Satish created KAFKA-6981: --- Summary: Missing Connector Config (errors.deadletterqueue.topic.name) kills Connect Clusters Key: KAFKA-6981 URL: https://issues.apache.org/jira/browse/KAFKA-6981 Proje

Build failed in Jenkins: kafka-1.0-jdk7 #194

See Changes: [wangguoz] KAFKA-6925: fix parentSensors memory leak (#5108) (#5119) -- [...truncated 373.13 KB...] kafka.admin.ResetConsumerGroupOffsetTest > testResetOffsetsT

[DISCUSS] KIP-308: GetOffsetShell: new KafkaConsumer API, support for multiple topics, minimize the number of requests to server

Hi, I have just created KIP that proposes enhancements to GetOffsetShell command line tool. KIP: https://cwiki.apache.org/confluence/display/KAFKA/KIP-308%3A+GetOffsetShell%3A+new+KafkaConsumer+API%2C+support+for+multiple+topics%2C+minimize+the+number+of+requests+to+server PR: https://github.com/

Someone to review KAFKA-6919, one line change for faulty documentation

Greetings, Poking for someone to have a quick look at this, It's a one-line change. I noticed the documentation about trogdor was pointing to a non-existing folder. Ticket: https://issues.apache.org/jira/browse/KAFKA-6919 PR: https://github.com/apache/kafka/pull/5040 Thanks.

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

Hello Luis, Please feel free to continue on the voting process as there seems be no further comments on this thread (I have synced with Jun and Ismael separately offline and they are in consent with the approach to add the fields in offset map for all cases). We can still continue on reviewing th

[jira] [Resolved] (KAFKA-5424) KafkaConsumer.listTopics() throws Exception when unauthorized topics exist in cluster

[ https://issues.apache.org/jira/browse/KAFKA-5424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5424. -- Resolution: Fixed This has been fixed via KAFKA-3396 > KafkaConsumer.listTopics() throws Exception whe

Re: [VOTE] KIP-231: Improve the Required ACL of ListGroups API

I'm bumping this vote thread up as the KIP requires only one binding +1 to pass. The KIP is very similar in nature to the recently approved KIP-277 ( https://cwiki.apache.org/confluence/display/KAFKA/KIP-277+-+Fine+Grained+ACL+for+CreateTopics+API ) and proposes a small improvement to make APIs' m

[jira] [Resolved] (KAFKA-5304) Kafka Producer throwing infinite NullPointerExceptions

[ https://issues.apache.org/jira/browse/KAFKA-5304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5304. -- Resolution: Auto Closed Closing inactive issue. Please reopen if the issue still exists. > Kafka Produ

[jira] [Resolved] (KAFKA-4751) kafka-clients-0.9.0.2.4.2.11-1 issue not throwing exception.

[ https://issues.apache.org/jira/browse/KAFKA-4751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4751. -- Resolution: Fixed This is addressed by KIP-266.  > kafka-clients-0.9.0.2.4.2.11-1 issue not throwing e

[jira] [Resolved] (KAFKA-4571) Consumer fails to retrieve messages if started before producer

[ https://issues.apache.org/jira/browse/KAFKA-4571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4571. -- Resolution: Auto Closed Closing inactive issue. Please reopen if the issue still exists. > Consumer fa

[jira] [Resolved] (KAFKA-3822) Kafka Consumer close() hangs indefinitely if Kafka Broker shutdown while connected

[ https://issues.apache.org/jira/browse/KAFKA-3822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3822. -- Resolution: Fixed This is addressed by KIP-266.  > Kafka Consumer close() hangs indefinitely if Kafka

[jira] [Resolved] (KAFKA-3457) KafkaConsumer.committed(...) hangs forever if port number is wrong

[ https://issues.apache.org/jira/browse/KAFKA-3457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3457. -- Resolution: Fixed This is addressed by KIP-266.  > KafkaConsumer.committed(...) hangs forever if port

[jira] [Resolved] (KAFKA-3011) Consumer.poll(0) blocks if Kafka not accessible

[ https://issues.apache.org/jira/browse/KAFKA-3011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3011. -- Resolution: Fixed This is addressed by KIP-266.  > Consumer.poll(0) blocks if Kafka not accessible > -

[jira] [Resolved] (KAFKA-3727) Consumer.poll() stuck in loop on non-existent topic manually assigned

[ https://issues.apache.org/jira/browse/KAFKA-3727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3727. -- Resolution: Fixed This is addressed by KIP-266. > Consumer.poll() stuck in loop on non-existent topic

[jira] [Resolved] (KAFKA-3899) Consumer.poll() stuck in loop if wrong credentials are supplied

[ https://issues.apache.org/jira/browse/KAFKA-3899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3899. -- Resolution: Fixed Assignee: (was: Edoardo Comar) Fix Version/s: 2.0.0 This is addre

[jira] [Resolved] (KAFKA-3503) Throw exception on missing/non-existent partition

[ https://issues.apache.org/jira/browse/KAFKA-3503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3503. -- Resolution: Duplicate > Throw exception on missing/non-existent partition > -

[jira] [Resolved] (KAFKA-3177) Kafka consumer can hang when position() is called on a non-existing partition.

[ https://issues.apache.org/jira/browse/KAFKA-3177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3177. -- Resolution: Fixed This is addressed by KIP-266. > Kafka consumer can hang when position() is called on

[jira] [Resolved] (KAFKA-6581) ConsumerGroupCommand hangs if even one of the partition is unavailable

[ https://issues.apache.org/jira/browse/KAFKA-6581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6581. -- Resolution: Fixed Fix Version/s: (was: 0.10.0.2) 2.0.0 This is addressed

[jira] [Resolved] (KAFKA-6973) setting invalid timestamp causes Kafka broker restart to fail

[ https://issues.apache.org/jira/browse/KAFKA-6973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-6973. Resolution: Fixed Fix Version/s: 2.0.0 > setting invalid timestamp causes Kafka broker resta

[jira] [Resolved] (KAFKA-6936) Scala API Wrapper for Streams uses default serializer for table aggregate

[ https://issues.apache.org/jira/browse/KAFKA-6936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6936. -- Resolution: Fixed Fix Version/s: 2.0.0 > Scala API Wrapper for Streams uses default seri

[jira] [Created] (KAFKA-6980) Recommended MaxDirectMemorySize for consumers

John Lu created KAFKA-6980: -- Summary: Recommended MaxDirectMemorySize for consumers Key: KAFKA-6980 URL: https://issues.apache.org/jira/browse/KAFKA-6980 Project: Kafka Issue Type: Wish Co

[jira] [Resolved] (KAFKA-3743) kafka-server-start.sh: Unhelpful error message

[ https://issues.apache.org/jira/browse/KAFKA-3743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3743. -- Resolution: Duplicate > kafka-server-start.sh: Unhelpful error message > --

Re: Apache Kafka 2.0.0 Release Progress

Hi all, I have moved one accepted KIP without a PR to the next release. We still have quite a few KIPs with PRs that are being reviewed, but haven't yet been merged. I have left all of these in since I think these are minor features that are not risky. Please ensure that all KIPs for 2.0.0 have be

RE: [VOTE] KIP-235 Add DNS alias support for secured connection

Hi, I have updated the PR to leverage an enum to drive client dns lookup behaviour. There are only 2 options for now, but this could be extended to support other behaviours (see attached from KIP-302 thread). 2 current options : resolve.canonical.bootstrap.servers.only : perform canonical name