[jira] [Commented] (KAFKA-1524) Implement transactional producer

[ https://issues.apache.org/jira/browse/KAFKA-1524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15371788#comment-15371788 ] Sriram Subramanian commented on KAFKA-1524: --- We hope to provide an update on thi

[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=15394900#comment-15394900 ] Sriram Subramanian commented on KAFKA-3986: --- Given that it cannot be consistentl

[jira] [Updated] (KAFKA-5251) Producer should drop queued sends when transaction is aborted

[ https://issues.apache.org/jira/browse/KAFKA-5251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriram Subramanian updated KAFKA-5251: -- Labels: exactly-once (was: ) > Producer should drop queued sends when transaction is ab

[jira] [Updated] (KAFKA-5249) Transaction index recovery does not snapshot properly

[ https://issues.apache.org/jira/browse/KAFKA-5249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriram Subramanian updated KAFKA-5249: -- Labels: exactly-once (was: ) > Transaction index recovery does not snapshot properly >

[jira] [Commented] (KAFKA-5151) Refactor TransactionCoordinator in-memory structure and error handling logic

[ https://issues.apache.org/jira/browse/KAFKA-5151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16011385#comment-16011385 ] Sriram Subramanian commented on KAFKA-5151: --- [~guozhang] can we close this? > R

[jira] [Assigned] (KAFKA-5024) Old clients don't support message format V2

[ https://issues.apache.org/jira/browse/KAFKA-5024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriram Subramanian reassigned KAFKA-5024: - Assignee: (was: Apurva Mehta) > Old clients don't support message format V2 >

[jira] [Assigned] (KAFKA-5032) Think through implications of max.message.size affecting record batches in message format V2

[ https://issues.apache.org/jira/browse/KAFKA-5032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriram Subramanian reassigned KAFKA-5032: - Assignee: (was: Apurva Mehta) > Think through implications of max.message.siz

[jira] [Assigned] (KAFKA-5251) Producer should drop queued sends when transaction is aborted

[ https://issues.apache.org/jira/browse/KAFKA-5251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriram Subramanian reassigned KAFKA-5251: - Assignee: (was: Apurva Mehta) > Producer should drop queued sends when transa

[jira] [Assigned] (KAFKA-5093) Load only batch header when rebuilding producer ID map

[ https://issues.apache.org/jira/browse/KAFKA-5093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriram Subramanian reassigned KAFKA-5093: - Assignee: (was: Jason Gustafson) > Load only batch header when rebuilding pro

[jira] [Assigned] (KAFKA-5282) Transactions integration test: Use factory methods to keep track of open producers and consumers and close them all on tearDown

[ https://issues.apache.org/jira/browse/KAFKA-5282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriram Subramanian reassigned KAFKA-5282: - Assignee: (was: Apurva Mehta) > Transactions integration test: Use factory me

[jira] [Updated] (KAFKA-5322) Resolve AddPartitions response error code inconsistency

[ https://issues.apache.org/jira/browse/KAFKA-5322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriram Subramanian updated KAFKA-5322: -- Labels: exactly-once (was: ) > Resolve AddPartitions response error code inconsistency

[jira] [Commented] (KAFKA-1258) Delete temporary data directory after unit test finishes

[ https://issues.apache.org/jira/browse/KAFKA-1258?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13898861#comment-13898861 ] Sriram Subramanian commented on KAFKA-1258: --- Look into http://junit.org/javadoc/

[jira] [Commented] (KAFKA-930) Integrate preferred replica election logic into kafka

[ https://issues.apache.org/jira/browse/KAFKA-930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13910155#comment-13910155 ] Sriram Subramanian commented on KAFKA-930: -- Updated reviewboard https://reviews.ap

[jira] [Updated] (KAFKA-930) Integrate preferred replica election logic into kafka

[ https://issues.apache.org/jira/browse/KAFKA-930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriram Subramanian updated KAFKA-930: - Attachment: KAFKA-930_2014-02-24_01:59:46.patch > Integrate preferred replica election log

[jira] [Commented] (KAFKA-930) Integrate preferred replica election logic into kafka

[ https://issues.apache.org/jira/browse/KAFKA-930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13911396#comment-13911396 ] Sriram Subramanian commented on KAFKA-930: -- final changes pushed to 0.8.1 and trun

[jira] [Commented] (KAFKA-1289) Misc. nitpicks in log cleaner

[ https://issues.apache.org/jira/browse/KAFKA-1289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13919022#comment-13919022 ] Sriram Subramanian commented on KAFKA-1289: --- +1 > Misc. nitpicks in log cleaner

[jira] [Commented] (KAFKA-1298) Controlled shutdown tool doesn't seem to work out of the box

[ https://issues.apache.org/jira/browse/KAFKA-1298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13923378#comment-13923378 ] Sriram Subramanian commented on KAFKA-1298: --- I dont think we have enabled it by

[jira] [Commented] (KAFKA-1546) Automate replica lag tuning

[ https://issues.apache.org/jira/browse/KAFKA-1546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14068731#comment-14068731 ] Sriram Subramanian commented on KAFKA-1546: --- the lagBegin does not persist acros

[jira] [Commented] (KAFKA-1539) Due to OS caching Kafka might loose offset files which causes full reset of data

[ https://issues.apache.org/jira/browse/KAFKA-1539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14068848#comment-14068848 ] Sriram Subramanian commented on KAFKA-1539: --- I had encountered the same issue in

[jira] [Commented] (KAFKA-1555) provide strong consistency with reasonable availability

[ https://issues.apache.org/jira/browse/KAFKA-1555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14142967#comment-14142967 ] Sriram Subramanian commented on KAFKA-1555: --- Sorry to be late here but I think t

[jira] [Commented] (KAFKA-977) Implement generation/term per leader to reconcile messages correctly

[ https://issues.apache.org/jira/browse/KAFKA-977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14142990#comment-14142990 ] Sriram Subramanian commented on KAFKA-977: -- I would like to bring this issue to di

[jira] [Commented] (KAFKA-1034) Improve partition reassignment to optimize writes to zookeeper

[ https://issues.apache.org/jira/browse/KAFKA-1034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14142999#comment-14142999 ] Sriram Subramanian commented on KAFKA-1034: --- At the high level, we were making t

[jira] [Commented] (KAFKA-1555) provide strong consistency with reasonable availability

[ https://issues.apache.org/jira/browse/KAFKA-1555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14143578#comment-14143578 ] Sriram Subramanian commented on KAFKA-1555: --- [~gwenshap] A key thing I would lik

[jira] [Commented] (KAFKA-1555) provide strong consistency with reasonable availability

[ https://issues.apache.org/jira/browse/KAFKA-1555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14143628#comment-14143628 ] Sriram Subramanian commented on KAFKA-1555: --- Surviving the leader crash makes se

[jira] [Commented] (KAFKA-1555) provide strong consistency with reasonable availability

[ https://issues.apache.org/jira/browse/KAFKA-1555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14146751#comment-14146751 ] Sriram Subramanian commented on KAFKA-1555: --- Jun, I am not arguing that we shou

[jira] [Comment Edited] (KAFKA-1555) provide strong consistency with reasonable availability

[ https://issues.apache.org/jira/browse/KAFKA-1555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14146751#comment-14146751 ] Sriram Subramanian edited comment on KAFKA-1555 at 9/24/14 9:32 PM:

[jira] [Commented] (KAFKA-1555) provide strong consistency with reasonable availability

[ https://issues.apache.org/jira/browse/KAFKA-1555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14147474#comment-14147474 ] Sriram Subramanian commented on KAFKA-1555: --- 1. Great. Not supporting all values

[jira] [Commented] (KAFKA-1555) provide strong consistency with reasonable availability

[ https://issues.apache.org/jira/browse/KAFKA-1555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14147967#comment-14147967 ] Sriram Subramanian commented on KAFKA-1555: --- ack = -1 with clean leader election

[jira] [Commented] (KAFKA-1555) provide strong consistency with reasonable availability

[ https://issues.apache.org/jira/browse/KAFKA-1555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14148407#comment-14148407 ] Sriram Subramanian commented on KAFKA-1555: --- Thank you for summarizing all the t

[jira] [Commented] (KAFKA-1555) provide strong consistency with reasonable availability

[ https://issues.apache.org/jira/browse/KAFKA-1555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14148520#comment-14148520 ] Sriram Subramanian commented on KAFKA-1555: --- 2. I agree. I think what min_isr he

[jira] [Commented] (KAFKA-1555) provide strong consistency with reasonable availability

[ https://issues.apache.org/jira/browse/KAFKA-1555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14167113#comment-14167113 ] Sriram Subramanian commented on KAFKA-1555: --- Awesome. I suggest we document the

[jira] [Commented] (KAFKA-1555) provide strong consistency with reasonable availability

[ https://issues.apache.org/jira/browse/KAFKA-1555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14167464#comment-14167464 ] Sriram Subramanian commented on KAFKA-1555: --- My vote would be to update our docu

[jira] [Commented] (KAFKA-1555) provide strong consistency with reasonable availability

[ https://issues.apache.org/jira/browse/KAFKA-1555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14168996#comment-14168996 ] Sriram Subramanian commented on KAFKA-1555: --- [~gwenshap] +1 on your suggestion.

[jira] [Commented] (KAFKA-739) Handle null values in Message payload

[ https://issues.apache.org/jira/browse/KAFKA-739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13593123#comment-13593123 ] Sriram Subramanian commented on KAFKA-739: -- I am not able to apply this patch usin

[jira] [Closed] (KAFKA-780) Reassign partitions tool produces NPE in shutdown handler

[ https://issues.apache.org/jira/browse/KAFKA-780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriram Subramanian closed KAFKA-780. > Reassign partitions tool produces NPE in shutdown handler > --

[jira] [Resolved] (KAFKA-780) Reassign partitions tool produces NPE in shutdown handler

[ https://issues.apache.org/jira/browse/KAFKA-780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriram Subramanian resolved KAFKA-780. -- Resolution: Fixed Resolved by KAFKA-785 > Reassign partitions tool prod

[jira] [Commented] (KAFKA-795) Improvements to PreferredReplicaLeaderElection tool

[ https://issues.apache.org/jira/browse/KAFKA-795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13596722#comment-13596722 ] Sriram Subramanian commented on KAFKA-795: -- 1. If we are going to run the tool whe

[jira] [Commented] (KAFKA-739) Handle null values in Message payload

[ https://issues.apache.org/jira/browse/KAFKA-739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13597771#comment-13597771 ] Sriram Subramanian commented on KAFKA-739: -- 1. OffsetMap a. The way the probe

[jira] [Created] (KAFKA-800) inSyncReplica in Partition needs some tweaks

Sriram Subramanian created KAFKA-800: Summary: inSyncReplica in Partition needs some tweaks Key: KAFKA-800 URL: https://issues.apache.org/jira/browse/KAFKA-800 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-800) inSyncReplica in Partition needs some tweaks

[ https://issues.apache.org/jira/browse/KAFKA-800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriram Subramanian updated KAFKA-800: - Labels: kafka-0.8 p1 (was: p1) > inSyncReplica in Partition needs some tweaks > -

[jira] [Updated] (KAFKA-800) inSyncReplica in Partition needs some tweaks

[ https://issues.apache.org/jira/browse/KAFKA-800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriram Subramanian updated KAFKA-800: - Attachment: KAFKA-800.patch > inSyncReplica in Partition needs some tweaks > -

[jira] [Updated] (KAFKA-800) inSyncReplica in Partition needs some tweaks

[ https://issues.apache.org/jira/browse/KAFKA-800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriram Subramanian updated KAFKA-800: - Attachment: KAFKA-800-v2.patch You are right. I was being too paranoid there.

[jira] [Commented] (KAFKA-802) Flush message interval is based on compressed message count

[ https://issues.apache.org/jira/browse/KAFKA-802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13601318#comment-13601318 ] Sriram Subramanian commented on KAFKA-802: -- Personally, having different meaning t

[jira] [Created] (KAFKA-814) Controller should not throw exception when a preferred replica is already the leader for a partition

Sriram Subramanian created KAFKA-814: Summary: Controller should not throw exception when a preferred replica is already the leader for a partition Key: KAFKA-814 URL: https://issues.apache.org/jira/browse/KAF

[jira] [Resolved] (KAFKA-814) Controller should not throw exception when a preferred replica is already the leader for a partition

[ https://issues.apache.org/jira/browse/KAFKA-814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriram Subramanian resolved KAFKA-814. -- Resolution: Fixed > Controller should not throw exception when a preferred replica i

[jira] [Closed] (KAFKA-814) Controller should not throw exception when a preferred replica is already the leader for a partition

[ https://issues.apache.org/jira/browse/KAFKA-814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriram Subramanian closed KAFKA-814. > Controller should not throw exception when a preferred replica is already the > leader fo

[jira] [Created] (KAFKA-861) IndexOutOfBoundsException while fetching data from leader

Sriram Subramanian created KAFKA-861: Summary: IndexOutOfBoundsException while fetching data from leader Key: KAFKA-861 URL: https://issues.apache.org/jira/browse/KAFKA-861 Project: Kafka

[jira] [Commented] (KAFKA-861) IndexOutOfBoundsException while fetching data from leader

[ https://issues.apache.org/jira/browse/KAFKA-861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13629410#comment-13629410 ] Sriram Subramanian commented on KAFKA-861: -- This happens when an existing follower

[jira] [Updated] (KAFKA-861) IndexOutOfBoundsException while fetching data from leader

[ https://issues.apache.org/jira/browse/KAFKA-861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriram Subramanian updated KAFKA-861: - Attachment: KAFKA-861.patch Fixes the size = 0 in the iterator.The fetcher thread logs and

[jira] [Updated] (KAFKA-861) IndexOutOfBoundsException while fetching data from leader

[ https://issues.apache.org/jira/browse/KAFKA-861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriram Subramanian updated KAFKA-861: - Attachment: KAFKA-861-v2.patch > IndexOutOfBoundsException while fetching data from le

[jira] [Created] (KAFKA-866) Recover segment does shallow iteration to fix index causing inconsistencies

Sriram Subramanian created KAFKA-866: Summary: Recover segment does shallow iteration to fix index causing inconsistencies Key: KAFKA-866 URL: https://issues.apache.org/jira/browse/KAFKA-866 Proje

[jira] [Updated] (KAFKA-866) Recover segment does shallow iteration to fix index causing inconsistencies

[ https://issues.apache.org/jira/browse/KAFKA-866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriram Subramanian updated KAFKA-866: - Attachment: KAFKA-866.patch 1. Recovery decompresses the message to get the starting offse

[jira] [Assigned] (KAFKA-837) Add 0.7->0.8 migration steps doc

[ https://issues.apache.org/jira/browse/KAFKA-837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriram Subramanian reassigned KAFKA-837: Assignee: Sriram Subramanian > Add 0.7->0.8 migration steps doc > --

[jira] [Updated] (KAFKA-866) Recover segment does shallow iteration to fix index causing inconsistencies

[ https://issues.apache.org/jira/browse/KAFKA-866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriram Subramanian updated KAFKA-866: - Attachment: KAFKA-866-v2.patch On Jun's suggestion reverting the fetcher thread to perform

[jira] [Commented] (KAFKA-837) Add 0.7->0.8 migration steps doc

[ https://issues.apache.org/jira/browse/KAFKA-837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13639989#comment-13639989 ] Sriram Subramanian commented on KAFKA-837: -- Draft is here - https://cwiki.apache.

[jira] [Commented] (KAFKA-837) Add 0.7->0.8 migration steps doc

[ https://issues.apache.org/jira/browse/KAFKA-837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13640653#comment-13640653 ] Sriram Subramanian commented on KAFKA-837: -- I am also planning to explain how the

[jira] [Commented] (KAFKA-876) Produce request: Leader not local for partition [test,0] on broker 0

[ https://issues.apache.org/jira/browse/KAFKA-876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13643322#comment-13643322 ] Sriram Subramanian commented on KAFKA-876: -- 1. Is this the latest kafka checkout?

[jira] [Commented] (KAFKA-876) Produce request: Leader not local for partition [test,0] on broker 0

[ https://issues.apache.org/jira/browse/KAFKA-876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13643425#comment-13643425 ] Sriram Subramanian commented on KAFKA-876: -- is this a valid path in windows ? /kaf

[jira] [Created] (KAFKA-886) Update info on Controlled shutdown and Preferred replica election tool

Sriram Subramanian created KAFKA-886: Summary: Update info on Controlled shutdown and Preferred replica election tool Key: KAFKA-886 URL: https://issues.apache.org/jira/browse/KAFKA-886 Project: K

[jira] [Commented] (KAFKA-886) Update info on Controlled shutdown and Preferred replica election tool

[ https://issues.apache.org/jira/browse/KAFKA-886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13644787#comment-13644787 ] Sriram Subramanian commented on KAFKA-886: -- https://cwiki.apache.org/confluence/di

[jira] [Commented] (KAFKA-886) Update info on Controlled shutdown and Preferred replica election tool

[ https://issues.apache.org/jira/browse/KAFKA-886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13645897#comment-13645897 ] Sriram Subramanian commented on KAFKA-886: -- 1. Updated. 2. That is already there.

[jira] [Created] (KAFKA-905) Logs can have same offsets causing recovery failure

Sriram Subramanian created KAFKA-905: Summary: Logs can have same offsets causing recovery failure Key: KAFKA-905 URL: https://issues.apache.org/jira/browse/KAFKA-905 Project: Kafka Issue

[jira] [Updated] (KAFKA-905) Logs can have same offsets causing recovery failure

[ https://issues.apache.org/jira/browse/KAFKA-905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriram Subramanian updated KAFKA-905: - Description: Consider the following scenario - L

[jira] [Updated] (KAFKA-905) Logs can have same offsets causing recovery failure

[ https://issues.apache.org/jira/browse/KAFKA-905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriram Subramanian updated KAFKA-905: - Description: Consider the following scenario - L F 1 m1,m2

[jira] [Updated] (KAFKA-905) Logs can have same offsets causing recovery failure

[ https://issues.apache.org/jira/browse/KAFKA-905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriram Subramanian updated KAFKA-905: - Attachment: KAFKA-905.rtf Attached a file that has the right formatting. JIRA seems to swa

[jira] [Created] (KAFKA-906) Invoke halt on shutdown and startup failure to ensure the jvm is brought down

Sriram Subramanian created KAFKA-906: Summary: Invoke halt on shutdown and startup failure to ensure the jvm is brought down Key: KAFKA-906 URL: https://issues.apache.org/jira/browse/KAFKA-906 Pro

[jira] [Commented] (KAFKA-903) [0.8.0 - windows] FATAL - [highwatermark-checkpoint-thread1] (Logging.scala:109) - Attempt to swap the new high watermark file with the old one failed

[ https://issues.apache.org/jira/browse/KAFKA-903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13659987#comment-13659987 ] Sriram Subramanian commented on KAFKA-903: -- There are two claims in this JIRA - 1

[jira] [Commented] (KAFKA-911) Bug in controlled shutdown logic in controller leads to controller not sending out some state change request

[ https://issues.apache.org/jira/browse/KAFKA-911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13668466#comment-13668466 ] Sriram Subramanian commented on KAFKA-911: -- I suggest we wait for my patch. My pat

[jira] [Updated] (KAFKA-905) Logs can have same offsets causing recovery failure

[ https://issues.apache.org/jira/browse/KAFKA-905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriram Subramanian updated KAFKA-905: - Attachment: KAFKA-905.patch We have decided to fix this using step 3 above. We just trunca

[jira] [Created] (KAFKA-927) Integrate controlled shutdown into kafka shutdown hook

Sriram Subramanian created KAFKA-927: Summary: Integrate controlled shutdown into kafka shutdown hook Key: KAFKA-927 URL: https://issues.apache.org/jira/browse/KAFKA-927 Project: Kafka Is

[jira] [Updated] (KAFKA-927) Integrate controlled shutdown into kafka shutdown hook

[ https://issues.apache.org/jira/browse/KAFKA-927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriram Subramanian updated KAFKA-927: - Attachment: KAFKA-927.patch > Integrate controlled shutdown into kafka shutdown hook >

[jira] [Resolved] (KAFKA-837) Add 0.7->0.8 migration steps doc

[ https://issues.apache.org/jira/browse/KAFKA-837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriram Subramanian resolved KAFKA-837. -- Resolution: Fixed > Add 0.7->0.8 migration steps doc > -

[jira] [Commented] (KAFKA-927) Integrate controlled shutdown into kafka shutdown hook

[ https://issues.apache.org/jira/browse/KAFKA-927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13671922#comment-13671922 ] Sriram Subramanian commented on KAFKA-927: -- Thank you for the review guys. Jun -

[jira] [Updated] (KAFKA-927) Integrate controlled shutdown into kafka shutdown hook

[ https://issues.apache.org/jira/browse/KAFKA-927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriram Subramanian updated KAFKA-927: - Attachment: KAFKA-927-v2.patch > Integrate controlled shutdown into kafka shutdown hoo

[jira] [Updated] (KAFKA-927) Integrate controlled shutdown into kafka shutdown hook

[ https://issues.apache.org/jira/browse/KAFKA-927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriram Subramanian updated KAFKA-927: - Attachment: KAFKA-927-v2-revised.patch Realized my previous patch did not have my latest c

[jira] [Updated] (KAFKA-927) Integrate controlled shutdown into kafka shutdown hook

[ https://issues.apache.org/jira/browse/KAFKA-927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriram Subramanian updated KAFKA-927: - Attachment: KAFKA-927-v3.patch 1.1 Done 1.2 Done 2. We would need to do some of these to e

[jira] [Commented] (KAFKA-927) Integrate controlled shutdown into kafka shutdown hook

[ https://issues.apache.org/jira/browse/KAFKA-927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13673666#comment-13673666 ] Sriram Subramanian commented on KAFKA-927: -- 30.1 Don't feel strong about this. I t

[jira] [Updated] (KAFKA-927) Integrate controlled shutdown into kafka shutdown hook

[ https://issues.apache.org/jira/browse/KAFKA-927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriram Subramanian updated KAFKA-927: - Attachment: KAFKA-927-v3-removeimports.patch > Integrate controlled shutdown into kafk

[jira] [Updated] (KAFKA-927) Integrate controlled shutdown into kafka shutdown hook

[ https://issues.apache.org/jira/browse/KAFKA-927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriram Subramanian updated KAFKA-927: - Attachment: KAFKA-927-v4.patch >From offline feedback 1. reset startupcomplete flag on shu

[jira] [Created] (KAFKA-930) Integrate preferred replica election logic into kafka

Sriram Subramanian created KAFKA-930: Summary: Integrate preferred replica election logic into kafka Key: KAFKA-930 URL: https://issues.apache.org/jira/browse/KAFKA-930 Project: Kafka Iss

[jira] [Updated] (KAFKA-905) Logs can have same offsets causing recovery failure

[ https://issues.apache.org/jira/browse/KAFKA-905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriram Subramanian updated KAFKA-905: - Attachment: KAFKA-905-v2.patch - made the logging changes - added the missing file

[jira] [Updated] (KAFKA-905) Logs can have same offsets causing recovery failure

[ https://issues.apache.org/jira/browse/KAFKA-905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriram Subramanian updated KAFKA-905: - Attachment: KAFKA-905-trunk.patch changes for trunk > Logs can have same

[jira] [Created] (KAFKA-935) Fix shutdown tool to work with new shutdown api

Sriram Subramanian created KAFKA-935: Summary: Fix shutdown tool to work with new shutdown api Key: KAFKA-935 URL: https://issues.apache.org/jira/browse/KAFKA-935 Project: Kafka Issue Typ

[jira] [Updated] (KAFKA-935) Fix shutdown tool to work with new shutdown api

[ https://issues.apache.org/jira/browse/KAFKA-935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriram Subramanian updated KAFKA-935: - Attachment: shutdowntool.patch > Fix shutdown tool to work with new shutdown api > ---

[jira] [Commented] (KAFKA-905) Logs can have same offsets causing recovery failure

[ https://issues.apache.org/jira/browse/KAFKA-905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13679632#comment-13679632 ] Sriram Subramanian commented on KAFKA-905: -- Ping...Take a look at the patch for tr

[jira] [Assigned] (KAFKA-347) change number of partitions of a topic online

[ https://issues.apache.org/jira/browse/KAFKA-347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriram Subramanian reassigned KAFKA-347: Assignee: Sriram Subramanian > change number of partitions of a topic online > -

[jira] [Commented] (KAFKA-347) change number of partitions of a topic online

[ https://issues.apache.org/jira/browse/KAFKA-347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13687690#comment-13687690 ] Sriram Subramanian commented on KAFKA-347: -- Going to look into this

[jira] [Commented] (KAFKA-950) bytesSinceLastIndexEntry needs to be reset after log segment is truncated

[ https://issues.apache.org/jira/browse/KAFKA-950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13690036#comment-13690036 ] Sriram Subramanian commented on KAFKA-950: -- +1 > bytesSinceLastIn

[jira] [Commented] (KAFKA-717) scala 2.10 build support

[ https://issues.apache.org/jira/browse/KAFKA-717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13697490#comment-13697490 ] Sriram Subramanian commented on KAFKA-717: -- I get the following errors when I try

[jira] [Commented] (KAFKA-911) Bug in controlled shutdown logic in controller leads to controller not sending out some state change request

[ https://issues.apache.org/jira/browse/KAFKA-911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13699500#comment-13699500 ] Sriram Subramanian commented on KAFKA-911: -- This has been fixed.

[jira] [Updated] (KAFKA-911) Bug in controlled shutdown logic in controller leads to controller not sending out some state change request

[ https://issues.apache.org/jira/browse/KAFKA-911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriram Subramanian updated KAFKA-911: - Resolution: Fixed Status: Resolved (was: Patch Available) > Bug in controlled

[jira] [Commented] (KAFKA-316) disallow recursively compressed message

[ https://issues.apache.org/jira/browse/KAFKA-316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13699505#comment-13699505 ] Sriram Subramanian commented on KAFKA-316: -- I don't see any reason to prevent nest

[jira] [Commented] (KAFKA-184) Log retention size and file size should be a long

[ https://issues.apache.org/jira/browse/KAFKA-184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13699510#comment-13699510 ] Sriram Subramanian commented on KAFKA-184: -- We have already fixed all the config n

[jira] [Updated] (KAFKA-184) Log retention size and file size should be a long

[ https://issues.apache.org/jira/browse/KAFKA-184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriram Subramanian updated KAFKA-184: - Resolution: Fixed Status: Resolved (was: Patch Available) > Log retention siz

[jira] [Created] (KAFKA-969) Need to prevent failure of rebalance when there are no brokers available when consumer comes up

Sriram Subramanian created KAFKA-969: Summary: Need to prevent failure of rebalance when there are no brokers available when consumer comes up Key: KAFKA-969 URL: https://issues.apache.org/jira/browse/KAFKA-96

[jira] [Updated] (KAFKA-969) Need to prevent failure of rebalance when there are no brokers available when consumer comes up

[ https://issues.apache.org/jira/browse/KAFKA-969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriram Subramanian updated KAFKA-969: - Attachment: emptybrokeronrebalance-1.patch > Need to prevent failure of rebalance when

[jira] [Updated] (KAFKA-969) Need to prevent failure of rebalance when there are no brokers available when consumer comes up

[ https://issues.apache.org/jira/browse/KAFKA-969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriram Subramanian updated KAFKA-969: - Status: Patch Available (was: Open) > Need to prevent failure of rebalance when there

[jira] [Commented] (KAFKA-969) Need to prevent failure of rebalance when there are no brokers available when consumer comes up

[ https://issues.apache.org/jira/browse/KAFKA-969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13705461#comment-13705461 ] Sriram Subramanian commented on KAFKA-969: -- The other issues you mention are separ

[jira] [Assigned] (KAFKA-838) Update design document to match Kafka 0.8 design

[ https://issues.apache.org/jira/browse/KAFKA-838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriram Subramanian reassigned KAFKA-838: Assignee: Sriram Subramanian > Update design document to match Kafka 0.8 design

[jira] [Resolved] (KAFKA-781) Add option to the controlled shutdown tool to timeout after n secs

[ https://issues.apache.org/jira/browse/KAFKA-781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriram Subramanian resolved KAFKA-781. -- Resolution: Fixed We have moved this logic into the broker. > Add optio

  1   2   3   >