Added some tests that will need implementation

test/schema_registry_test.go

@@ -344,6 +344,13 @@ func Test_SchemaRegistry_AutoRegisterSchemas_RequiresSchemaSpecification(t *test
 	require.ErrorContains(t, err, "avro schema is required for schema registry formatter")
 }
 
+func Test_ProtoSchemaRegistry(t *testing.T) {
+	require.Fail(t, "implement")
+}
+
+func Test_JsonSchemaRegistry(t *testing.T) {
+	require.Fail(t, "implement")
+}
 func checkShouldSkipTest(t *testing.T, flags ...string) {
 	t.Helper()
 	for _, flag := range flags {

test/worker_test.go

@@ -2060,6 +2060,24 @@ func TestWork_ShutdownCausesRunExit(t *testing.T) {
 	require.NoError(t, err)
 }
 
+func Test_DeadeletterClientDoesntCollidWithProducer(t *testing.T) {
+	// work with deadletter clientid=123
+	// producer  clientid=123
+	// This is a classic pattern. connecetor style. Shouldn't have issues with writes
+	t.Fail()
+}
+
+func Test_MissingBootstrap_ShouldGiveClearError(t *testing.T) {
+	t.Fail()
+}
+
+func Test_FailedAuthentication(t *testing.T) {
+	// not sure if we can even do this with the local broker
+	// See if can require username/password for dynamically provisioned topic
+	t.Fail()
+
+}
+
 // $ go test -run=XXX -bench=BenchmarkWork_Run_CircuitBreaker_BusyLoopBreaker -cpuprofile profile_cpu.out
 // $ go tool pprof --web profile_cpu.out
 // $ go tool pprof -http=":8000" test.test ./profile_cpu.out