|
@@ -311,22 +311,6 @@ func TestAsyncProducerFailureRetry(t *testing.T) {
|
|
|
closeProducer(t, producer)
|
|
|
}
|
|
|
|
|
|
-type testLogger struct {
|
|
|
- t *testing.T
|
|
|
-}
|
|
|
-
|
|
|
-func (l *testLogger) Print(v ...interface{}) {
|
|
|
- l.t.Log(v...)
|
|
|
-}
|
|
|
-
|
|
|
-func (l *testLogger) Printf(format string, v ...interface{}) {
|
|
|
- l.t.Logf(format, v...)
|
|
|
-}
|
|
|
-
|
|
|
-func (l *testLogger) Println(v ...interface{}) {
|
|
|
- l.t.Log(v...)
|
|
|
-}
|
|
|
-
|
|
|
func TestAsyncProducerRecoveryWithRetriesDisabled(t *testing.T) {
|
|
|
tt := func(t *testing.T, kErr KError) {
|
|
|
seedBroker := NewMockBroker(t, 1)
|