[jira] [Created] (KAFKA-5993) Kafka AdminClient does not support standard security settings

Stephane Maarek created KAFKA-5993: -- Summary: Kafka AdminClient does not support standard security settings Key: KAFKA-5993 URL: https://issues.apache.org/jira/browse/KAFKA-5993 Project: Kafka

[jira] [Created] (KAFKA-5992) Better Java Documentation for AdminClient Exceptions

Stephane Maarek created KAFKA-5992: -- Summary: Better Java Documentation for AdminClient Exceptions Key: KAFKA-5992 URL: https://issues.apache.org/jira/browse/KAFKA-5992 Project: Kafka Issue

[jira] [Updated] (KAFKA-5565) Add a broker metric specifying the number of consumer group rebalances in progress

[ https://issues.apache.org/jira/browse/KAFKA-5565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5565: --- Fix Version/s: 1.0.0 > Add a broker metric specifying the number of consumer group rebalances in >

[jira] [Updated] (KAFKA-4972) Kafka 0.10.0 Found a corrupted index file during Kafka broker startup

[ https://issues.apache.org/jira/browse/KAFKA-4972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4972: --- Fix Version/s: 1.0.0 > Kafka 0.10.0 Found a corrupted index file during Kafka broker startup >

[jira] [Commented] (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:comment-tabpanel=16185267#comment-16185267 ] ASF GitHub Bot commented on KAFKA-5957: --- Github user asfgit closed the pull request at:

[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=16185235#comment-16185235 ] ASF GitHub Bot commented on KAFKA-5746: --- GitHub user ijuma opened a pull request:

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

[ https://issues.apache.org/jira/browse/KAFKA-5989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-5989. Resolution: Duplicate \cc [~damianguy] It this is not a duplicate, please reopen. >

[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=16185167#comment-16185167 ] Matthias J. Sax commented on KAFKA-5967: It's correct. But I did not see any email from you. You

[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=16185158#comment-16185158 ] Ismael Juma commented on KAFKA-5473: [~prasincs], can you update this JIRA tomorrow with your progress

[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=16185144#comment-16185144 ] Prasanna Gautam commented on KAFKA-5473: Yeah, I'm OK if someone can pick it up too. I'm aiming

[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=16185128#comment-16185128 ] siva santhalingam commented on KAFKA-5967: -- [~mjsax] I sent an email to d...@kafka.apache.org.

[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=16185119#comment-16185119 ] ASF GitHub Bot commented on KAFKA-5967: --- GitHub user shivsantham opened a pull request:

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

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

[jira] [Commented] (KAFKA-2359) New consumer - partitions auto assigned only on poll

[ https://issues.apache.org/jira/browse/KAFKA-2359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16185102#comment-16185102 ] Nick West commented on KAFKA-2359: -- Work around, unsafe and brittle, but it works. {code} // Use

[jira] [Updated] (KAFKA-5991) Change Consumer per partition lag metrics to put topic-partition-id in tags instead of metric name

[ https://issues.apache.org/jira/browse/KAFKA-5991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Lu updated KAFKA-5991: Description:

[jira] [Updated] (KAFKA-5991) Change Consumer per partition lag metrics to put topic-partition-id in tags instead of metric name

[ https://issues.apache.org/jira/browse/KAFKA-5991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Lu updated KAFKA-5991: Description:

[jira] [Updated] (KAFKA-5991) Change Consumer per partition lag metrics to put topic-partition-id in tags instead of metric name

[ https://issues.apache.org/jira/browse/KAFKA-5991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Lu updated KAFKA-5991: Description:

[jira] [Updated] (KAFKA-5991) Change Consumer per partition lag metrics to put topic-partition-id in tags instead of metric name

[ https://issues.apache.org/jira/browse/KAFKA-5991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Lu updated KAFKA-5991: Description:

[jira] [Updated] (KAFKA-5991) Change Consumer per partition lag metrics to put topic-partition-id in tags instead of metric name

[ https://issues.apache.org/jira/browse/KAFKA-5991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Lu updated KAFKA-5991: Description:

[jira] [Updated] (KAFKA-5991) Change Consumer per partition lag metrics to put topic-partition-id in tags instead of metric name

[ https://issues.apache.org/jira/browse/KAFKA-5991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Lu updated KAFKA-5991: Description:

[jira] [Updated] (KAFKA-5991) Change Consumer per partition lag metrics to put topic-partition-id in tags instead of metric name

[ https://issues.apache.org/jira/browse/KAFKA-5991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Lu updated KAFKA-5991: Description:

[jira] [Updated] (KAFKA-5991) Change Consumer per partition lag metrics to put topic-partition-id in tags instead of metric name

[ https://issues.apache.org/jira/browse/KAFKA-5991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Lu updated KAFKA-5991: Description:

[jira] [Updated] (KAFKA-5991) Change Consumer per partition lag metrics to put topic-partition-id in tags instead of metric name

[ https://issues.apache.org/jira/browse/KAFKA-5991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Lu updated KAFKA-5991: Description:

[jira] [Updated] (KAFKA-5991) Change Consumer per partition lag metrics to put topic-partition-id in tags instead of metric name

[ https://issues.apache.org/jira/browse/KAFKA-5991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Lu updated KAFKA-5991: Description:

[jira] [Updated] (KAFKA-5991) Change Consumer per partition lag metrics to put topic-partition-id in tags instead of metric name

[ https://issues.apache.org/jira/browse/KAFKA-5991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Lu updated KAFKA-5991: Description:

[jira] [Updated] (KAFKA-5991) Change Consumer per partition lag metrics to put topic-partition-id in tags instead of metric name

[ https://issues.apache.org/jira/browse/KAFKA-5991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Lu updated KAFKA-5991: Description:

[jira] [Created] (KAFKA-5991) Change Consumer per partition lag metrics to put topic-partition-id in tags instead of metric name

Kevin Lu created KAFKA-5991: --- Summary: Change Consumer per partition lag metrics to put topic-partition-id in tags instead of metric name Key: KAFKA-5991 URL: https://issues.apache.org/jira/browse/KAFKA-5991

[jira] [Updated] (KAFKA-5991) Change Consumer per partition lag metrics to put topic-partition-id in tags instead of metric name

[ https://issues.apache.org/jira/browse/KAFKA-5991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Lu updated KAFKA-5991: Description:

[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:

[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-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:

[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=16184866#comment-16184866 ] ASF GitHub Bot commented on KAFKA-5746: --- Github user asfgit closed the pull request at:

[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=16184864#comment-16184864 ] ASF GitHub Bot commented on KAFKA-5949: --- GitHub user mjsax opened a pull request:

[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) >

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

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

[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=16184862#comment-16184862 ] Apurva Mehta commented on KAFKA-5870: - The only downside is that when previously sent batches expire,

[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-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=16184797#comment-16184797 ] Matthias J. Sax commented on KAFKA-5967: [~sssanthalingam] Please send an email with you user name

[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=16184796#comment-16184796 ] ASF GitHub Bot commented on KAFKA-5987: --- GitHub user rhauch opened a pull request:

[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=16184769#comment-16184769 ] ASF GitHub Bot commented on KAFKA-5888: --- Github user asfgit closed the pull request at:

[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

[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=16184683#comment-16184683 ] Ismael Juma commented on KAFKA-5473: We would need the PR to be submitted ASAP so that there's time

[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=16184653#comment-16184653 ] Prasanna Gautam commented on KAFKA-5473: Think I can make it to the code freeze. I'm at a

[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=16184644#comment-16184644 ] Ted Yu commented on KAFKA-5967: --- Once you send out pull request, a committer would assign to you. >

[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=16184626#comment-16184626 ] siva santhalingam commented on KAFKA-5967: -- [~te...@apache.org] Could you please assign this to

[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=16184607#comment-16184607 ] siva santhalingam commented on KAFKA-5967: -- [~te...@apache.org] Can i assign this to myself? >

[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-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=16184496#comment-16184496 ] Ismael Juma commented on KAFKA-5473: Do you think you can submit it within the next few days? The code

[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-5901) Create Connect metrics for source tasks

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

[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] [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-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-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] [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] [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=16184386#comment-16184386 ] Mikhail Lesyk commented on KAFKA-4477: -- Updated from 0.10.2.1 to 0.11.0.1 and started hitting this

[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=16184314#comment-16184314 ] Prasanna Gautam commented on KAFKA-5473: [~ijuma] Yes I intend to send a PR for this. I need to

[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

[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

[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

[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-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

[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=16184060#comment-16184060 ] ASF GitHub Bot commented on KAFKA-5986: --- GitHub user dguy opened a pull request:

[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

[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

[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

[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-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-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-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

[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

[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

[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-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

[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

[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=16184012#comment-16184012 ] Ismael Juma commented on KAFKA-5347: [~apurva], is this still an issue? > OutOfSequence error should

[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 >

[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=16184010#comment-16184010 ] Ismael Juma commented on KAFKA-3986: There have been many fixes to the Selector and SocketServer, so I

[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

[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

[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=16183998#comment-16183998 ] Ismael Juma commented on KAFKA-5870: [~apurva], just checking that it's OK to move this to 1.1.0? >

[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

[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

[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-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] [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=16183993#comment-16183993 ] Sandeep Kale commented on KAFKA-5153: - [~arpan.khagram0...@gmail.com] Any update on this? How u

[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-5552) testTransactionalProducerTopicAuthorizationExceptionInCommit fails

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

[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] [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

[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=16183983#comment-16183983 ] Ismael Juma commented on KAFKA-5764: The KIP missed the freeze deadline, so updated the fix version.

[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

[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=16183964#comment-16183964 ] ASF GitHub Bot commented on KAFKA-5976: --- Github user asfgit closed the pull request at:

[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=16183951#comment-16183951 ] ASF GitHub Bot commented on KAFKA-5979: --- Github user asfgit closed the pull request at:

[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=16183948#comment-16183948 ] Ismael Juma commented on KAFKA-4914: I am hoping to get this in before the code freeze since it's a

[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

[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=16183947#comment-16183947 ] ASF GitHub Bot commented on KAFKA-5949: --- Github user asfgit closed the pull request at:

[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=16183945#comment-16183945 ] Ismael Juma commented on KAFKA-3186: KIP-50 was never merged [~guozhang]. > KIP-50: Move Authorizer

[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. >

  1   2   >