Merge remote-tracking branch 'origin/fix-hang-on-close' into fix-hang-on-close

# Conflicts:
#	writer_test.go

Author: iamgoroot

writer_test.go

@@ -193,7 +193,7 @@ func TestWriter(t *testing.T) {
 		},
 		{
 			scenario: "test no new partition writers after close",
-			function: TestWriterNoNewPartitionWritersAfterClose,
+			function: testWriterNoNewPartitionWritersAfterClose,
 		},
 	}
 
@@ -1034,7 +1034,7 @@ func testWriterOverrideConfigStats(t *testing.T) {
 	}
 }
 
-func TestWriterNoNewPartitionWritersAfterClose(t *testing.T) {
+func testWriterNoNewPartitionWritersAfterClose(t *testing.T) {
 	ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
 	defer cancel()
 	topic1 := makeTopic()