[jira] [Updated] (KAFKA-5962) java.io.IOException: Map failed

[ https://issues.apache.org/jira/browse/KAFKA-5962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mehmet Soner updated KAFKA-5962: Description: *OS:* HP-UX B.11.31 U ia64 Step to reproduce bug: *1) Starting zookeeper by using bel

[jira] [Created] (KAFKA-5985) Mention the need to close store iterators

Stanislav Chizhov created KAFKA-5985: Summary: Mention the need to close store iterators Key: KAFKA-5985 URL: https://issues.apache.org/jira/browse/KAFKA-5985 Project: Kafka Issue Type: I

[jira] [Updated] (KAFKA-5985) Mention the need to close store iterators

[ https://issues.apache.org/jira/browse/KAFKA-5985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Chizhov updated KAFKA-5985: - Description: Store iterators should be closed in all/most of the cases, but currently it i

[jira] [Updated] (KAFKA-5961) NullPointerException when consumer restore read messages with null key.

[ https://issues.apache.org/jira/browse/KAFKA-5961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andres Gomez Ferrer updated KAFKA-5961: --- Fix Version/s: 0.11.0.1 > NullPointerException when consumer restore read messages wit

[jira] [Updated] (KAFKA-5961) NullPointerException when consumer restore read messages with null key.

[ https://issues.apache.org/jira/browse/KAFKA-5961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andres Gomez Ferrer updated KAFKA-5961: --- Affects Version/s: (was: 0.11.0.0) > NullPointerException when consumer restore re

[jira] [Updated] (KAFKA-5961) NullPointerException when consumer restore read messages with null key.

[ https://issues.apache.org/jira/browse/KAFKA-5961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andres Gomez Ferrer updated KAFKA-5961: --- Fix Version/s: 0.11.0.0 > NullPointerException when consumer restore read messages wit

[jira] [Commented] (KAFKA-5961) NullPointerException when consumer restore read messages with null key.

[ https://issues.apache.org/jira/browse/KAFKA-5961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16183931#comment-16183931 ] Andres Gomez Ferrer commented on KAFKA-5961: Yeah, I test it with `0.11.0.0` a

[jira] [Resolved] (KAFKA-5961) NullPointerException when consumer restore read messages with null key.

[ https://issues.apache.org/jira/browse/KAFKA-5961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andres Gomez Ferrer resolved KAFKA-5961. Resolution: Fixed > NullPointerException when consumer restore read messages with nu

[jira] [Commented] (KAFKA-5958) User StoreListener not available for global stores

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

[jira] [Commented] (KAFKA-5960) Producer uses unsupported ProduceRequest version against older brokers

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

[jira] [Updated] (KAFKA-3186) KIP-50: Move Authorizer and related classes to separate package.

[ https://issues.apache.org/jira/browse/KAFKA-3186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3186: --- Fix Version/s: (was: 1.0.0) > KIP-50: Move Authorizer and related classes to separate package. > -

[jira] [Commented] (KAFKA-3186) KIP-50: Move Authorizer and related classes to separate package.

[ https://issues.apache.org/jira/browse/KAFKA-3186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16183945#comment-16183945 ] Ismael Juma commented on KAFKA-3186: KIP-50 was never merged [~guozhang]. > KIP-50: M

[jira] [Commented] (KAFKA-5949) User Callback Exceptions need to be handled properly

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

[jira] [Assigned] (KAFKA-4914) Partition re-assignment tool should check types before persisting state in ZooKeeper

[ https://issues.apache.org/jira/browse/KAFKA-4914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma reassigned KAFKA-4914: -- Assignee: Nick Travers > Partition re-assignment tool should check types before persisting stat

[jira] [Commented] (KAFKA-4914) Partition re-assignment tool should check types before persisting state in ZooKeeper

[ https://issues.apache.org/jira/browse/KAFKA-4914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16183948#comment-16183948 ] Ismael Juma commented on KAFKA-4914: I am hoping to get this in before the code freeze

[jira] [Commented] (KAFKA-5979) kip-120 changed internal streams topic naming

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

[jira] [Commented] (KAFKA-5976) RequestChannel.sendReponse records incorrect size for NetworkSend with TRACE logging

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

[jira] [Resolved] (KAFKA-5976) RequestChannel.sendReponse records incorrect size for NetworkSend with TRACE logging

[ https://issues.apache.org/jira/browse/KAFKA-5976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-5976. Resolution: Fixed Fix Version/s: 1.0.0 > RequestChannel.sendReponse records incorrect size fo

[jira] [Updated] (KAFKA-5764) KafkaShortnamer should allow for case-insensitive matches

[ https://issues.apache.org/jira/browse/KAFKA-5764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5764: --- Fix Version/s: (was: 1.0.0) 1.1.0 > KafkaShortnamer should allow for case-insen

[jira] [Updated] (KAFKA-2875) Class path contains multiple SLF4J bindings warnings when using scripts under bin

[ https://issues.apache.org/jira/browse/KAFKA-2875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-2875: --- Fix Version/s: (was: 1.0.0) > Class path contains multiple SLF4J bindings warnings when using scri

[jira] [Commented] (KAFKA-5764) KafkaShortnamer should allow for case-insensitive matches

[ https://issues.apache.org/jira/browse/KAFKA-5764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16183983#comment-16183983 ] Ismael Juma commented on KAFKA-5764: The KIP missed the freeze deadline, so updated th

[jira] [Updated] (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 ] Ismael Juma updated KAFKA-3177: --- Fix Version/s: (was: 1.0.0) 1.1.0 > Kafka consumer can hang when position() is

[jira] [Commented] (KAFKA-5552) testTransactionalProducerTopicAuthorizationExceptionInCommit fails

[ https://issues.apache.org/jira/browse/KAFKA-5552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16183990#comment-16183990 ] Ismael Juma commented on KAFKA-5552: Not sure if this is still possible, cc [~apurva]

[jira] [Updated] (KAFKA-4423) Drop support for Java 7

[ https://issues.apache.org/jira/browse/KAFKA-4423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4423: --- Fix Version/s: (was: 1.1.0) 2.0.0 > Drop support for Java 7 > -

[jira] [Updated] (KAFKA-5864) ReplicaFetcherThread should not die due to replica in offline log directory

[ https://issues.apache.org/jira/browse/KAFKA-5864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5864: --- Fix Version/s: (was: 1.1.0) 1.0.0 > ReplicaFetcherThread should not die due to

[jira] [Commented] (KAFKA-5153) KAFKA Cluster : 0.10.2.0 : Servers Getting disconnected : Service Impacting

[ https://issues.apache.org/jira/browse/KAFKA-5153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16183993#comment-16183993 ] Sandeep Kale commented on KAFKA-5153: - [~arpan.khagram0...@gmail.com] Any update on th

[jira] [Updated] (KAFKA-5212) Consumer ListOffsets request can starve group heartbeats

[ https://issues.apache.org/jira/browse/KAFKA-5212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5212: --- Fix Version/s: 1.0.1 > Consumer ListOffsets request can starve group heartbeats >

[jira] [Updated] (KAFKA-5503) Idempotent producer ignores shutdown while fetching ProducerId

[ https://issues.apache.org/jira/browse/KAFKA-5503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5503: --- Fix Version/s: 1.0.1 > Idempotent producer ignores shutdown while fetching ProducerId > --

[jira] [Updated] (KAFKA-5829) Speedup broker startup after unclean shutdown by reducing unnecessary snapshot files deletion

[ https://issues.apache.org/jira/browse/KAFKA-5829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5829: --- Fix Version/s: (was: 1.1.0) 1.0.0 > Speedup broker startup after unclean shutdo

[jira] [Updated] (KAFKA-5843) Mx4jLoader.maybeLoad should only be executed if kafka_mx4jenable is set to true

[ https://issues.apache.org/jira/browse/KAFKA-5843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5843: --- Fix Version/s: (was: 1.1.0) 1.0.0 > Mx4jLoader.maybeLoad should only be execute

[jira] [Updated] (KAFKA-5870) Idempotent producer: a producerId reset causes undesirable behavior for inflight batches to other partitions

[ https://issues.apache.org/jira/browse/KAFKA-5870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5870: --- Labels: exactly-once (was: ) > Idempotent producer: a producerId reset causes undesirable behavior fo

[jira] [Commented] (KAFKA-5870) Idempotent producer: a producerId reset causes undesirable behavior for inflight batches to other partitions

[ https://issues.apache.org/jira/browse/KAFKA-5870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16183998#comment-16183998 ] Ismael Juma commented on KAFKA-5870: [~apurva], just checking that it's OK to move thi

[jira] [Commented] (KAFKA-5879) Controller should read the latest IsrChangeNotification znodes when handling IsrChangeNotification event

[ https://issues.apache.org/jira/browse/KAFKA-5879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16183999#comment-16183999 ] Ismael Juma commented on KAFKA-5879: Discussion in progress on whether we need this fo

[jira] [Updated] (KAFKA-5879) Controller should read the latest IsrChangeNotification znodes when handling IsrChangeNotification event

[ https://issues.apache.org/jira/browse/KAFKA-5879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5879: --- Fix Version/s: (was: 1.1.0) 1.0.0 > Controller should read the latest IsrChange

[jira] [Resolved] (KAFKA-3986) completedReceives can contain closed channels

[ https://issues.apache.org/jira/browse/KAFKA-3986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-3986. Resolution: Fixed Fix Version/s: (was: 1.1.0) 1.0.0 > completedReceive

[jira] [Commented] (KAFKA-3986) completedReceives can contain closed channels

[ https://issues.apache.org/jira/browse/KAFKA-3986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16184010#comment-16184010 ] Ismael Juma commented on KAFKA-3986: There have been many fixes to the Selector and So

[jira] [Commented] (KAFKA-5347) OutOfSequence error should be fatal

[ https://issues.apache.org/jira/browse/KAFKA-5347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16184012#comment-16184012 ] Ismael Juma commented on KAFKA-5347: [~apurva], is this still an issue? > OutOfSequen

[jira] [Updated] (KAFKA-5957) Producer IllegalStateException due to second deallocate after aborting a batch

[ https://issues.apache.org/jira/browse/KAFKA-5957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5957: --- Fix Version/s: (was: 1.1.0) 1.0.0 > Producer IllegalStateException due to secon

[jira] [Updated] (KAFKA-2435) More optimally balanced partition assignment strategy

[ https://issues.apache.org/jira/browse/KAFKA-2435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-2435: --- Fix Version/s: (was: 1.0.0) 1.1.0 > More optimally balanced partition assignmen

[jira] [Updated] (KAFKA-5018) LogCleaner tests to verify behaviour of message format v2

[ https://issues.apache.org/jira/browse/KAFKA-5018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5018: --- Fix Version/s: (was: 1.0.0) 1.1.0 > LogCleaner tests to verify behaviour of mes

[jira] [Updated] (KAFKA-3190) KafkaProducer should not invoke callback in send()

[ https://issues.apache.org/jira/browse/KAFKA-3190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3190: --- Fix Version/s: (was: 1.0.0) 1.1.0 > KafkaProducer should not invoke callback in

[jira] [Updated] (KAFKA-5214) Re-add KafkaAdminClient#apiVersions

[ https://issues.apache.org/jira/browse/KAFKA-5214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5214: --- Fix Version/s: (was: 1.0.0) 1.1.0 > Re-add KafkaAdminClient#apiVersions > -

[jira] [Updated] (KAFKA-5759) Allow user to specify relative path as log directory

[ https://issues.apache.org/jira/browse/KAFKA-5759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5759: --- Fix Version/s: (was: 1.0.0) 1.1.0 > Allow user to specify relative path as log

[jira] [Updated] (KAFKA-2651) Remove deprecated config alteration from TopicCommand in 0.9.1.0

[ https://issues.apache.org/jira/browse/KAFKA-2651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-2651: --- Fix Version/s: (was: 1.0.0) 2.0.0 > Remove deprecated config alteration from To

[jira] [Created] (KAFKA-5986) Streams State Restoration never completes when logging is disabled

Damian Guy created KAFKA-5986: - Summary: Streams State Restoration never completes when logging is disabled Key: KAFKA-5986 URL: https://issues.apache.org/jira/browse/KAFKA-5986 Project: Kafka I

[jira] [Updated] (KAFKA-3247) kafka-topic tool can use an option to see just "unbalanced partitions"

[ https://issues.apache.org/jira/browse/KAFKA-3247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3247: --- Fix Version/s: (was: 1.0.0) > kafka-topic tool can use an option to see just "unbalanced partition

[jira] [Updated] (KAFKA-3331) Refactor TopicCommand to make it testable and add unit tests

[ https://issues.apache.org/jira/browse/KAFKA-3331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3331: --- Fix Version/s: (was: 1.0.0) > Refactor TopicCommand to make it testable and add unit tests > -

[jira] [Updated] (KAFKA-3252) compression type for a topic should be used during log compaction

[ https://issues.apache.org/jira/browse/KAFKA-3252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3252: --- Fix Version/s: (was: 1.0.0) > compression type for a topic should be used during log compaction >

[jira] [Updated] (KAFKA-3300) Calculate the initial/max size of offset index files and reduce the memory footprint for memory mapped index files.

[ https://issues.apache.org/jira/browse/KAFKA-3300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3300: --- Fix Version/s: (was: 1.0.0) > Calculate the initial/max size of offset index files and reduce the

[jira] [Updated] (KAFKA-3436) Speed up controlled shutdown.

[ https://issues.apache.org/jira/browse/KAFKA-3436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3436: --- Fix Version/s: (was: 1.0.0) 1.1.0 > Speed up controlled shutdown. > ---

[jira] [Updated] (KAFKA-3438) Rack Aware Replica Reassignment should warn of overloaded brokers

[ https://issues.apache.org/jira/browse/KAFKA-3438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3438: --- Fix Version/s: (was: 1.0.0) 1.1.0 > Rack Aware Replica Reassignment should warn

[jira] [Updated] (KAFKA-3866) KerberosLogin refresh time bug and other improvements

[ https://issues.apache.org/jira/browse/KAFKA-3866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3866: --- Fix Version/s: (was: 0.11.0.2) (was: 1.0.0) 1.0.1

[jira] [Updated] (KAFKA-3554) Generate actual data with specific compression ratio and add multi-thread support in the ProducerPerformance tool.

[ https://issues.apache.org/jira/browse/KAFKA-3554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3554: --- Fix Version/s: (was: 1.0.0) 1.1.0 > Generate actual data with specific compress

[jira] [Updated] (KAFKA-4862) Kafka client connect to a shutdown node will block for a long time

[ https://issues.apache.org/jira/browse/KAFKA-4862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4862: --- Fix Version/s: (was: 1.0.0) 1.1.0 > Kafka client connect to a shutdown node wil

[jira] [Updated] (KAFKA-4808) send of null key to a compacted topic should throw error back to user

[ https://issues.apache.org/jira/browse/KAFKA-4808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4808: --- Fix Version/s: (was: 1.0.0) 1.1.0 > send of null key to a compacted topic shoul

[jira] [Updated] (KAFKA-5163) Support replicas movement between log directories (KIP-113)

[ https://issues.apache.org/jira/browse/KAFKA-5163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5163: --- Fix Version/s: (was: 1.0.0) 1.1.0 > Support replicas movement between log direc

[jira] [Updated] (KAFKA-5276) Support derived and prefixed configs in DescribeConfigs (KIP-133)

[ https://issues.apache.org/jira/browse/KAFKA-5276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5276: --- Fix Version/s: (was: 1.0.0) 1.1.0 > Support derived and prefixed configs in Des

[jira] [Updated] (KAFKA-5403) Transactions system test should dedup consumed messages by offset

[ https://issues.apache.org/jira/browse/KAFKA-5403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5403: --- Fix Version/s: (was: 1.0.0) 1.1.0 > Transactions system test should dedup consu

[jira] [Updated] (KAFKA-5313) Improve exception handling on coordinator interactions

[ https://issues.apache.org/jira/browse/KAFKA-5313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5313: --- Fix Version/s: (was: 1.0.0) 1.1.0 > Improve exception handling on coordinator i

[jira] [Commented] (KAFKA-5986) Streams State Restoration never completes when logging is disabled

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

[jira] [Updated] (KAFKA-3297) More optimally balanced partition assignment strategy (new consumer)

[ https://issues.apache.org/jira/browse/KAFKA-3297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3297: --- Fix Version/s: (was: 1.0.0) 1.1.0 > More optimally balanced partition assignmen

[jira] [Updated] (KAFKA-4333) Report consumer group coordinator id when '--list' option is used

[ https://issues.apache.org/jira/browse/KAFKA-4333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4333: --- Fix Version/s: (was: 1.0.0) 1.1.0 > Report consumer group coordinator id when '

[jira] [Updated] (KAFKA-5123) Refactor ZkUtils readData* methods

[ https://issues.apache.org/jira/browse/KAFKA-5123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5123: --- Fix Version/s: (was: 1.0.0) 1.1.0 > Refactor ZkUtils readData* methods > -

[jira] [Updated] (KAFKA-5359) Exceptions from RequestFuture lack parts of the stack trace

[ https://issues.apache.org/jira/browse/KAFKA-5359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5359: --- Fix Version/s: (was: 1.0.0) 1.1.0 > Exceptions from RequestFuture lack parts of

[jira] [Updated] (KAFKA-2394) Use RollingFileAppender by default in log4j.properties

[ https://issues.apache.org/jira/browse/KAFKA-2394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-2394: --- Fix Version/s: (was: 1.0.0) 1.1.0 > Use RollingFileAppender by default in log4j

[jira] [Updated] (KAFKA-3999) Consumer bytes-fetched metric uses decompressed message size

[ https://issues.apache.org/jira/browse/KAFKA-3999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3999: --- Fix Version/s: (was: 1.0.0) 1.1.0 > Consumer bytes-fetched metric uses decompre

[jira] [Updated] (KAFKA-4126) No relevant log when the topic is non-existent

[ https://issues.apache.org/jira/browse/KAFKA-4126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4126: --- Fix Version/s: (was: 1.0.0) 1.1.0 > No relevant log when the topic is non-exist

[jira] [Commented] (KAFKA-5473) handle ZK session expiration properly when a new session can't be established

[ https://issues.apache.org/jira/browse/KAFKA-5473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16184314#comment-16184314 ] Prasanna Gautam commented on KAFKA-5473: [~ijuma] Yes I intend to send a PR for th

[jira] [Commented] (KAFKA-4477) Node reduces its ISR to itself, and doesn't recover. Other nodes do not take leadership, cluster remains sick until node is restarted.

[ https://issues.apache.org/jira/browse/KAFKA-4477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16184386#comment-16184386 ] Mikhail Lesyk commented on KAFKA-4477: -- Updated from 0.10.2.1 to 0.11.0.1 and started

[jira] [Assigned] (KAFKA-5859) Avoid retaining AbstractRequest in RequestChannel.Request

[ https://issues.apache.org/jira/browse/KAFKA-5859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sean Glover reassigned KAFKA-5859: -- Assignee: Sean Glover > Avoid retaining AbstractRequest in RequestChannel.Request > ---

[jira] [Updated] (KAFKA-5302) Improve exception handling on streams client (communication with brokers)

[ https://issues.apache.org/jira/browse/KAFKA-5302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5302: --- Fix Version/s: (was: 1.0.0) > Improve exception handling on streams client (communication

[jira] [Commented] (KAFKA-5859) Avoid retaining AbstractRequest in RequestChannel.Request

[ https://issues.apache.org/jira/browse/KAFKA-5859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16184419#comment-16184419 ] Ismael Juma commented on KAFKA-5859: [~huxi_2b], it needs needs the `ApiKeys` instance

[jira] [Updated] (KAFKA-5217) Improve Streams internal exception handling

[ https://issues.apache.org/jira/browse/KAFKA-5217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5217: --- Fix Version/s: (was: 1.0.0) > Improve Streams internal exception handling > --

[jira] [Updated] (KAFKA-5158) Options for handling exceptions during processing

[ https://issues.apache.org/jira/browse/KAFKA-5158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5158: --- Fix Version/s: (was: 1.0.0) > Options for handling exceptions during processing >

[jira] [Updated] (KAFKA-5301) Improve exception handling on consumer path

[ https://issues.apache.org/jira/browse/KAFKA-5301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5301: --- Fix Version/s: (was: 1.0.0) > Improve exception handling on consumer path > --

[jira] [Updated] (KAFKA-5156) Options for handling exceptions in streams

[ https://issues.apache.org/jira/browse/KAFKA-5156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5156: --- Fix Version/s: (was: 1.0.0) > Options for handling exceptions in streams > ---

[jira] [Resolved] (KAFKA-5901) Create Connect metrics for source tasks

[ https://issues.apache.org/jira/browse/KAFKA-5901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-5901. -- Resolution: Fixed Issue resolved by pull request 3959 [https://github.com/apache

[jira] [Commented] (KAFKA-5901) Create Connect metrics for source tasks

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

[jira] [Updated] (KAFKA-5985) Mention the need to close store iterators

[ https://issues.apache.org/jira/browse/KAFKA-5985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5985: --- Component/s: streams > Mention the need to close store iterators > ---

[jira] [Commented] (KAFKA-5473) handle ZK session expiration properly when a new session can't be established

[ https://issues.apache.org/jira/browse/KAFKA-5473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16184496#comment-16184496 ] Ismael Juma commented on KAFKA-5473: Do you think you can submit it within the next fe

[jira] [Updated] (KAFKA-5473) handle ZK session expiration properly when a new session can't be established

[ https://issues.apache.org/jira/browse/KAFKA-5473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5473: --- Fix Version/s: (was: 1.0.1) 1.0.0 > handle ZK session expiration properly when

[jira] [Commented] (KAFKA-5967) Ineffective check of negative value in CompositeReadOnlyKeyValueStore#approximateNumEntries()

[ https://issues.apache.org/jira/browse/KAFKA-5967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16184607#comment-16184607 ] siva santhalingam commented on KAFKA-5967: -- [~te...@apache.org] Can i assign this

[jira] [Commented] (KAFKA-5967) Ineffective check of negative value in CompositeReadOnlyKeyValueStore#approximateNumEntries()

[ https://issues.apache.org/jira/browse/KAFKA-5967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16184616#comment-16184616 ] Ted Yu commented on KAFKA-5967: --- Please go ahead. > Ineffective check of negative value in

[jira] [Commented] (KAFKA-5967) Ineffective check of negative value in CompositeReadOnlyKeyValueStore#approximateNumEntries()

[ https://issues.apache.org/jira/browse/KAFKA-5967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16184626#comment-16184626 ] siva santhalingam commented on KAFKA-5967: -- [~te...@apache.org] Could you please

[jira] [Commented] (KAFKA-5967) Ineffective check of negative value in CompositeReadOnlyKeyValueStore#approximateNumEntries()

[ https://issues.apache.org/jira/browse/KAFKA-5967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16184644#comment-16184644 ] Ted Yu commented on KAFKA-5967: --- Once you send out pull request, a committer would assign to

[jira] [Commented] (KAFKA-5473) handle ZK session expiration properly when a new session can't be established

[ https://issues.apache.org/jira/browse/KAFKA-5473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16184653#comment-16184653 ] Prasanna Gautam commented on KAFKA-5473: Think I can make it to the code freeze. I

[jira] [Commented] (KAFKA-5473) handle ZK session expiration properly when a new session can't be established

[ https://issues.apache.org/jira/browse/KAFKA-5473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16184683#comment-16184683 ] Ismael Juma commented on KAFKA-5473: We would need the PR to be submitted ASAP so that

[jira] [Created] (KAFKA-5987) Kafka metrics templates used in document generation should maintain order of tags

Randall Hauch created KAFKA-5987: Summary: Kafka metrics templates used in document generation should maintain order of tags Key: KAFKA-5987 URL: https://issues.apache.org/jira/browse/KAFKA-5987 Proje

[jira] [Commented] (KAFKA-5888) Transactions system test should check for message order

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

[jira] [Commented] (KAFKA-5987) Kafka metrics templates used in document generation should maintain order of tags

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

[jira] [Commented] (KAFKA-5967) Ineffective check of negative value in CompositeReadOnlyKeyValueStore#approximateNumEntries()

[ https://issues.apache.org/jira/browse/KAFKA-5967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16184797#comment-16184797 ] Matthias J. Sax commented on KAFKA-5967: [~sssanthalingam] Please send an email wi

[jira] [Updated] (KAFKA-5562) Do streams state directory cleanup on a single thread

[ https://issues.apache.org/jira/browse/KAFKA-5562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5562: --- Fix Version/s: 0.11.0.1 > Do streams state directory cleanup on a single thread >

[jira] [Commented] (KAFKA-5870) Idempotent producer: a producerId reset causes undesirable behavior for inflight batches to other partitions

[ https://issues.apache.org/jira/browse/KAFKA-5870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16184862#comment-16184862 ] Apurva Mehta commented on KAFKA-5870: - The only downside is that when previously sent

[jira] [Resolved] (KAFKA-5552) testTransactionalProducerTopicAuthorizationExceptionInCommit fails

[ https://issues.apache.org/jira/browse/KAFKA-5552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apurva Mehta resolved KAFKA-5552. - Resolution: Cannot Reproduce Fix Version/s: (was: 1.1.0) > testTransactionalProducerTop

[jira] [Commented] (KAFKA-5552) testTransactionalProducerTopicAuthorizationExceptionInCommit fails

[ https://issues.apache.org/jira/browse/KAFKA-5552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16184863#comment-16184863 ] Apurva Mehta commented on KAFKA-5552: - I have not seen this test fail in ages, and can

[jira] [Commented] (KAFKA-5949) User Callback Exceptions need to be handled properly

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

[jira] [Commented] (KAFKA-5746) Add new metrics to support health checks

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

[jira] [Created] (KAFKA-5988) Consider removing StreamThread#STREAM_THREAD_ID_SEQUENCE

Ted Yu created KAFKA-5988: - Summary: Consider removing StreamThread#STREAM_THREAD_ID_SEQUENCE Key: KAFKA-5988 URL: https://issues.apache.org/jira/browse/KAFKA-5988 Project: Kafka Issue Type: Improvem

[jira] [Created] (KAFKA-5989) disableLogging() causes an initialization loop

Tuan Nguyen created KAFKA-5989: -- Summary: disableLogging() causes an initialization loop Key: KAFKA-5989 URL: https://issues.apache.org/jira/browse/KAFKA-5989 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-5990) Add generated documentation for Connect metrics

Randall Hauch created KAFKA-5990: Summary: Add generated documentation for Connect metrics Key: KAFKA-5990 URL: https://issues.apache.org/jira/browse/KAFKA-5990 Project: Kafka Issue Type: Sub

  1   2   >