Re: Review Request 23568: Patch for KAFKA-1523

> On Aug. 6, 2014, 5:32 a.m., Timothy Chen wrote: > > core/src/main/scala/kafka/server/TransactionManager.scala, line 300 > > > > > > I'm just trying to think if there is a chance to have overlapping tx > > ids especi

Re: Review Request 23568: Patch for KAFKA-1523

> On Aug. 6, 2014, 5:32 a.m., Timothy Chen wrote: > > core/src/main/scala/kafka/server/TransactionManager.scala, line 300 > > > > > > I'm just trying to think if there is a chance to have overlapping tx > > ids especi

Re: Review Request 23568: Patch for KAFKA-1523

> On Aug. 6, 2014, 5:32 a.m., Timothy Chen wrote: > > core/src/main/scala/kafka/server/TransactionManager.scala, line 300 > > > > > > I'm just trying to think if there is a chance to have overlapping tx > > ids especi

[jira] [Assigned] (KAFKA-1059) Improve the patch review tool to use OAuth for JIRA access

[ https://issues.apache.org/jira/browse/KAFKA-1059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede reassigned KAFKA-1059: Assignee: Neha Narkhede (was: Manikumar Reddy) > Improve the patch review tool to use OAut

[jira] [Updated] (KAFKA-1374) LogCleaner (compaction) does not support compressed topics

[ https://issues.apache.org/jira/browse/KAFKA-1374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1374: - Assignee: Joel Koshy (was: Manikumar Reddy) > LogCleaner (compaction) does not support compresse

[jira] [Commented] (KAFKA-1374) LogCleaner (compaction) does not support compressed topics

[ https://issues.apache.org/jira/browse/KAFKA-1374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14087675#comment-14087675 ] Neha Narkhede commented on KAFKA-1374: -- Assigning to [~jjkoshy] for review > LogClea

[jira] [Commented] (KAFKA-1282) Disconnect idle socket connection in Selector

[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14087676#comment-14087676 ] Neha Narkhede commented on KAFKA-1282: -- Hey [~nmarasoiu], are you actively working on

Re: Review Request 23440: Patch for KAFKA-1536

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23440/ --- (Updated Aug. 6, 2014, 2:17 p.m.) Review request for kafka. Summary (updated)

[jira] [Updated] (KAFKA-1536) Change the status of the JIRA to "Patch Available" in the kafka-review-tool

[ https://issues.apache.org/jira/browse/KAFKA-1536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-1536: --- Attachment: KAFKA-1536_2014-08-06_19:44:49.patch > Change the status of the JIRA to "Patch Av

[jira] [Commented] (KAFKA-1536) Change the status of the JIRA to "Patch Available" in the kafka-review-tool

[ https://issues.apache.org/jira/browse/KAFKA-1536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14087704#comment-14087704 ] Manikumar Reddy commented on KAFKA-1536: Updated reviewboard https://reviews.apach

[jira] [Updated] (KAFKA-1536) Change the status of the JIRA to "Patch Available" in the kafka-review-tool

[ https://issues.apache.org/jira/browse/KAFKA-1536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-1536: --- Attachment: (was: KAFKA-1536_2014-07-18_20:41:40.patch) > Change the status of the JIRA t

[jira] [Commented] (KAFKA-1536) Change the status of the JIRA to "Patch Available" in the kafka-review-tool

[ https://issues.apache.org/jira/browse/KAFKA-1536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14087708#comment-14087708 ] Manikumar Reddy commented on KAFKA-1536: [~nehanarkhede] can we check-in this patc

Issue in using kafka SimpleConsumer code

Hi Team, I have a requirement of reading real time data using kafka and write to cassandra. For this I am using SimpleConsumer to read data from Kafka topics and writing into Cassandra. I am maintaining offsets of topics in my log files. The issue is that after few days like 3-4 days my cosumer co

[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=14087795#comment-14087795 ] Gwen Shapira commented on KAFKA-1555: - We are talking about topic level, and I complet

[jira] [Created] (KAFKA-1574) unit tests can hand on socketserver shutdown

Jun Rao created KAFKA-1574: -- Summary: unit tests can hand on socketserver shutdown Key: KAFKA-1574 URL: https://issues.apache.org/jira/browse/KAFKA-1574 Project: Kafka Issue Type: Bug Comp

[jira] [Commented] (KAFKA-1574) unit tests can hand on socketserver shutdown

[ https://issues.apache.org/jira/browse/KAFKA-1574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14087882#comment-14087882 ] Jun Rao commented on KAFKA-1574: This issue seems to be a race condition in AbstractServer

[jira] [Created] (KAFKA-1575) Topic Hierarchy

Gwen Shapira created KAFKA-1575: --- Summary: Topic Hierarchy Key: KAFKA-1575 URL: https://issues.apache.org/jira/browse/KAFKA-1575 Project: Kafka Issue Type: Improvement Reporter: Gwe

Review Request 24411: Patch for KAFKA-1524

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/24411/ --- Review request for kafka. Bugs: KAFKA-1524 https://issues.apache.org/jira/b

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

[ https://issues.apache.org/jira/browse/KAFKA-1524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raul Castro Fernandez updated KAFKA-1524: - Attachment: (was: KAFKA-1524.patch) > Implement transactional producer >

Review Request 24417: Patch for KAFKA-1541

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/24417/ --- Review request for kafka. Bugs: KAFKA-1541 https://issues.apache.org/jira/b

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

[ https://issues.apache.org/jira/browse/KAFKA-1524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raul Castro Fernandez updated KAFKA-1524: - Attachment: KAFKA-1524.patch > Implement transactional producer > ---

[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=14088133#comment-14088133 ] Raul Castro Fernandez commented on KAFKA-1524: -- Created reviewboard https://r

[jira] [Commented] (KAFKA-1541) Add transactional request definitions to clients package

[ https://issues.apache.org/jira/browse/KAFKA-1541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14088142#comment-14088142 ] Raul Castro Fernandez commented on KAFKA-1541: -- Created reviewboard https://r

[jira] [Updated] (KAFKA-1541) Add transactional request definitions to clients package

[ https://issues.apache.org/jira/browse/KAFKA-1541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raul Castro Fernandez updated KAFKA-1541: - Attachment: KAFKA-1541.patch > Add transactional request definitions to clients

[jira] [Commented] (KAFKA-1387) Kafka getting stuck creating ephemeral node it has already created when two zookeeper sessions are established in a very short period of time

[ https://issues.apache.org/jira/browse/KAFKA-1387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14088474#comment-14088474 ] Gwen Shapira commented on KAFKA-1387: - Attempted to reproduce with trunk as well. I'm