We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 5cdb227 commit faffa30Copy full SHA for faffa30
pulsar/producer_test.go
@@ -657,6 +657,8 @@ func TestMessageRouter(t *testing.T) {
657
assert.Equal(t, string(msg.Payload()), "hello")
658
}
659
func TestMessageSingleRouter(t *testing.T) {
660
+ // TODO: https://github.com/apache/pulsar-client-go/issues/1376
661
+ t.Skip("Skipping TestMessageSingleRouter because it's too flaky")
662
// Create topic with 5 partitions
663
topicAdminURL := "admin/v2/persistent/public/default/my-single-partitioned-topic/partitions"
664
err := httpPut(topicAdminURL, 5)
0 commit comments