[jira] [Updated] (KAFKA-1659) Ability to cleanly abort the KafkaProducer

2015-08-19 Thread Gwen Shapira (JIRA) 

 [ 
https://issues.apache.org/jira/browse/KAFKA-1659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Gwen Shapira updated KAFKA-1659:

Fix Version/s: (was: 0.8.3)

 Ability to cleanly abort the KafkaProducer
 --

 Key: KAFKA-1659
 URL: https://issues.apache.org/jira/browse/KAFKA-1659
 Project: Kafka
  Issue Type: Improvement
  Components: clients, producer 
Affects Versions: 0.8.2.0
Reporter: Andrew Stein
Assignee: Jun Rao

 I would like the ability to abort the Java Client's KafkaProducer. This 
 includes the stopping the writing of buffered records.
 The motivation for this is described 
 [here|http://mail-archives.apache.org/mod_mbox/kafka-dev/201409.mbox/%3CCAOk4UxB7BJm6HSgLXrR01sksB2dOC3zdt0NHaKHz1EALR6%3DCTQ%40mail.gmail.com%3E].
 A sketch of this method is:
 {code}
 public void abort() {
 try {
 ioThread.interrupt();
 ioThread.stop(new ThreadDeath());
 } catch (IllegalAccessException e) {
 }
 }
 {code}
 but of course it is preferable to stop the {{ioThread}} by cooperation, 
 rather than use the deprecated {{Thread.stop(new ThreadDeath())}}.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[jira] [Updated] (KAFKA-1659) Ability to cleanly abort the KafkaProducer

2014-10-21 Thread Joe Stein (JIRA) 

 [ 
https://issues.apache.org/jira/browse/KAFKA-1659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Joe Stein updated KAFKA-1659:
-
Fix Version/s: (was: 0.8.2)
   0.8.3

 Ability to cleanly abort the KafkaProducer
 --

 Key: KAFKA-1659
 URL: https://issues.apache.org/jira/browse/KAFKA-1659
 Project: Kafka
  Issue Type: Improvement
  Components: clients, producer 
Affects Versions: 0.8.2
Reporter: Andrew Stein
Assignee: Jun Rao
 Fix For: 0.8.3


 I would like the ability to abort the Java Client's KafkaProducer. This 
 includes the stopping the writing of buffered records.
 The motivation for this is described 
 [here|http://mail-archives.apache.org/mod_mbox/kafka-dev/201409.mbox/%3CCAOk4UxB7BJm6HSgLXrR01sksB2dOC3zdt0NHaKHz1EALR6%3DCTQ%40mail.gmail.com%3E].
 A sketch of this method is:
 {code}
 public void abort() {
 try {
 ioThread.interrupt();
 ioThread.stop(new ThreadDeath());
 } catch (IllegalAccessException e) {
 }
 }
 {code}
 but of course it is preferable to stop the {{ioThread}} by cooperation, 
 rather than use the deprecated {{Thread.stop(new ThreadDeath())}}.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)