(t *testing.T)
| 814 | } |
| 815 | |
| 816 | func TestFuncAdminDeleteTopic(t *testing.T) { |
| 817 | t.Parallel() |
| 818 | checkKafkaVersion(t, "0.10.0.0") |
| 819 | setupFunctionalTest(t) |
| 820 | defer teardownFunctionalTest(t) |
| 821 | |
| 822 | config := NewFunctionalTestConfig() |
| 823 | adminClient, err := NewClusterAdmin(FunctionalTestEnv.KafkaBrokerAddrs, config) |
| 824 | if err != nil { |
| 825 | t.Fatal(err) |
| 826 | } |
| 827 | defer safeClose(t, adminClient) |
| 828 | |
| 829 | err = adminClient.CreateTopic("delete_topic_test", &TopicDetail{NumPartitions: 1, ReplicationFactor: 1}, false) |
| 830 | if err != nil { |
| 831 | t.Fatal(err) |
| 832 | } |
| 833 | err = adminClient.DeleteTopic("delete_topic_test") |
| 834 | if err != nil { |
| 835 | t.Fatal(err) |
| 836 | } |
| 837 | } |
| 838 | |
| 839 | // TestFuncAdminElectLeadersV1 covers low-version client compatibility against a |
| 840 | // newer broker for the ElectLeaders V1 non-flexible path. See |
nothing calls this directly
no test coverage detected