Rename test topics to be shorter

and easier to remember and more consistent.

functional_client_test.go

@@ -39,20 +39,20 @@ func TestFuncClientMetadata(t *testing.T) {
 		t.Error("Expected ErrUnknownTopicOrPartition, got", err)
 	}
 
-	partitions, err := client.Partitions("multi_partition")
+	partitions, err := client.Partitions("test.4")
 	if err != nil {
 		t.Error(err)
 	}
-	if len(partitions) != 2 {
-		t.Errorf("Expected multi_partition topic to have 2 partitions, found %v", partitions)
+	if len(partitions) != 4 {
+		t.Errorf("Expected test.4 topic to have 4 partitions, found %v", partitions)
 	}
 
-	partitions, err = client.Partitions("single_partition")
+	partitions, err = client.Partitions("test.1")
 	if err != nil {
 		t.Error(err)
 	}
 	if len(partitions) != 1 {
-		t.Errorf("Expected single_partition topic to have 1 partitions, found %v", partitions)
+		t.Errorf("Expected test.1 topic to have 1 partitions, found %v", partitions)
 	}
 
 	safeClose(t, client)

functional_consumer_test.go

@@ -13,11 +13,11 @@ func TestFuncConsumerOffsetOutOfRange(t *testing.T) {
 		t.Fatal(err)
 	}
 
-	if _, err := consumer.ConsumePartition("single_partition", 0, -10); err != ErrOffsetOutOfRange {
+	if _, err := consumer.ConsumePartition("test.1", 0, -10); err != ErrOffsetOutOfRange {
 		t.Error("Expected ErrOffsetOutOfRange, got:", err)
 	}
 
-	if _, err := consumer.ConsumePartition("single_partition", 0, math.MaxInt64); err != ErrOffsetOutOfRange {
+	if _, err := consumer.ConsumePartition("test.1", 0, math.MaxInt64); err != ErrOffsetOutOfRange {
 		t.Error("Expected ErrOffsetOutOfRange, got:", err)
 	}
 

functional_producer_test.go

@@ -58,7 +58,7 @@ func TestFuncMultiPartitionProduce(t *testing.T) {
 	for i := 1; i <= TestBatchSize; i++ {
 		go func(i int) {
 			defer wg.Done()
-			msg := &ProducerMessage{Topic: "multi_partition", Key: nil, Value: StringEncoder(fmt.Sprintf("hur %d", i))}
+			msg := &ProducerMessage{Topic: "test.64", Key: nil, Value: StringEncoder(fmt.Sprintf("hur %d", i))}
 			if _, _, err := producer.SendMessage(msg); err != nil {
 				t.Error(i, err)
 			}
@@ -105,7 +105,7 @@ func testProducingMessages(t *testing.T, config *Config) {
 	if err != nil {
 		t.Fatal(err)
 	}
-	consumer, err := master.ConsumePartition("single_partition", 0, OffsetNewest)
+	consumer, err := master.ConsumePartition("test.1", 0, OffsetNewest)
 	if err != nil {
 		t.Fatal(err)
 	}
@@ -117,7 +117,7 @@ func testProducingMessages(t *testing.T, config *Config) {
 
 	expectedResponses := TestBatchSize
 	for i := 1; i <= TestBatchSize; {
-		msg := &ProducerMessage{Topic: "single_partition", Key: nil, Value: StringEncoder(fmt.Sprintf("testing %d", i))}
+		msg := &ProducerMessage{Topic: "test.1", Key: nil, Value: StringEncoder(fmt.Sprintf("testing %d", i))}
 		select {
 		case producer.Input() <- msg:
 			i++

vagrant/create_topics.sh

@@ -6,6 +6,6 @@ while ! nc -q 1 localhost 21801 </dev/null; do echo "Waiting"; sleep 1; done
 while ! nc -q 1 localhost 29092 </dev/null; do echo "Waiting"; sleep 1; done
 
 cd ${KAFKA_INSTALL_ROOT}/kafka-9092
-bin/kafka-topics.sh --create --partitions 1 --replication-factor 3 --topic single_partition --zookeeper localhost:2181
-bin/kafka-topics.sh --create --partitions 2 --replication-factor 3 --topic multi_partition  --zookeeper localhost:2181
-bin/kafka-topics.sh --create --partitions 32 --replication-factor 3 --topic many_partition  --zookeeper localhost:2181
+bin/kafka-topics.sh --create --partitions 1 --replication-factor 3 --topic test.1 --zookeeper localhost:2181
+bin/kafka-topics.sh --create --partitions 4 --replication-factor 3 --topic test.4 --zookeeper localhost:2181
+bin/kafka-topics.sh --create --partitions 64 --replication-factor 3 --topic test.64  --zookeeper localhost:2181