Calling application must ignore or handle SIGPIPE to avoid terminatio…

…n if connection drops. (issue #2)
confluentinc · Jan 7, 2013 · c15c314 · c15c314
1 parent c818ae5
commit c15c314
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 0 deletions.
diff --git a/examples/rdkafka_example.c b/examples/rdkafka_example.c
@@ -130,6 +130,11 @@ int main (int argc, char **argv) {
 
 	signal(SIGINT, stop);
 
+	/* Socket hangups are gracefully handled in librdkafka on socket error
+	 * without the use of signals, so SIGPIPE should be ignored by the calling
+	 * program. */
+	signal(SIGPIPE, SIG_IGN);
+
 	if (mode == 'P') {
 		/*
 		 * Producer

diff --git a/rdkafka.h b/rdkafka.h
@@ -259,6 +259,8 @@ void        rd_kafka_destroy (rd_kafka_t *rk);
  * 'conf' is an optional struct that will be copied to replace rdkafka's
  * default configuration. See the 'rd_kafka_conf_t' type for more information.
  *
+ * NOTE: Make sure SIGPIPE is either ignored or handled by the calling application.
+ *
  *
  * Returns the Kafka handle.
  *