- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 787 for broken1 (0.16 sec)
-
internal/event/target/kafka.go
config.Metadata.Retry.Backoff = (1 * time.Second) config.Metadata.RefreshFrequency = (15 * time.Minute) target.config = config brokers := []string{} for _, broker := range args.Brokers { brokers = append(brokers, broker.String()) } client, err := sarama.NewClient(brokers, config) if err != nil { if !errors.Is(err, sarama.ErrOutOfBrokers) { target.loggerOnce(context.Background(), err, target.ID().String())
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Jun 01 15:02:59 UTC 2024 - 13.1K bytes - Viewed (0) -
internal/logger/target/kafka/kafka.go
sconfig.Metadata.Retry.Backoff = (10 * time.Second) sconfig.Metadata.RefreshFrequency = (15 * time.Minute) h.config = sconfig var brokers []string for _, broker := range h.kconfig.Brokers { brokers = append(brokers, broker.String()) } client, err := sarama.NewClient(brokers, sconfig) if err != nil { return err } producer, err := sarama.NewSyncProducerFromClient(client) if err != nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun Jun 02 03:03:39 UTC 2024 - 10.2K bytes - Viewed (0) -
platforms/ide/tooling-api/src/crossVersionTest/groovy/org/gradle/integtests/tooling/r12rc1/BuildModelCrossVersionSpec.groovy
} def "#description means do not run any tasks even when build logic injects tasks to execute"() { file('build.gradle') << """ gradle.startParameter.taskNames = ["broken2"] gradle.taskGraph.whenReady { throw new RuntimeException() } """ when: withConnection { ProjectConnection connection ->
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 3.1K bytes - Viewed (0) -
internal/config/notify/legacy.go
Key: config.Enable, Value: config.EnableOn, }, config.KV{ Key: target.KafkaBrokers, Value: func() string { var brokers []string for _, broker := range cfg.Brokers { brokers = append(brokers, broker.String()) } return strings.Join(brokers, config.ValueSeparator) }(), }, config.KV{ Key: target.KafkaTopic, Value: cfg.Topic, }, config.KV{
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Mar 19 04:37:54 UTC 2024 - 13.1K bytes - Viewed (0) -
subprojects/core/src/integTest/groovy/org/gradle/api/BuildEventsErrorIntegrationTest.groovy
throw new RuntimeException('broken closure') } task broken { doLast { throw new RuntimeException('broken task') } } """ when: fails("broken") then: failure.assertHasFailures(2) failure.assertHasDescription("Execution failed for task ':broken'.") .assertHasCause("broken task")
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Apr 03 15:21:23 UTC 2024 - 6K bytes - Viewed (0) -
src/internal/poll/fd_mutex_test.go
func TestMutexLock(t *testing.T) { var mu XFDMutex if !mu.Incref() { t.Fatal("broken") } if mu.Decref() { t.Fatal("broken") } if !mu.RWLock(true) { t.Fatal("broken") } if mu.RWUnlock(true) { t.Fatal("broken") } if !mu.RWLock(false) { t.Fatal("broken") } if mu.RWUnlock(false) { t.Fatal("broken") } } func TestMutexClose(t *testing.T) { var mu XFDMutex
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat Oct 08 03:57:40 UTC 2022 - 4K bytes - Viewed (0) -
docs/logging/README.md
comment (sentence) optionally add a comment to this setting ``` Configure MinIO to send audit logs to locally running Kafka brokers ``` mc admin config set myminio/ audit_kafka:target1 brokers=localhost:29092 topic=auditlog mc admin service restart myminio/ ``` On another terminal assuming you have `kafkacat` installed ```
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 09 17:15:03 UTC 2024 - 10.4K bytes - Viewed (0) -
subprojects/core/src/integTest/groovy/org/gradle/api/FinalizerTaskIntegrationTest.groovy
} 2.times { fails "thing", "-Pthing.broken" result.assertTasksExecutedInOrder ":thing", ":finalizerDep", ":finalizer" } 2.times { fails "thing", "-PfinalizerDep.broken" result.assertTasksExecutedInOrder ":thing", ":finalizerDep" } 2.times { fails "thing", "-PfinalizerDep.broken", "--continue"
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri May 17 13:27:33 UTC 2024 - 32.3K bytes - Viewed (0) -
src/cmd/go/testdata/script/dist_list_missing.txt
go tool dist list -v stdout linux/amd64 cp stdout tool-v.txt go tool dist list -broken stdout $GOOS/$GOARCH cp stdout tool-broken.txt go tool dist list -json stdout '"GOOS": "linux",\n\s*"GOARCH": "amd64",\n' cp stdout tool-json.txt go tool dist list -json -broken stdout '"GOOS": "'$GOOS'",\n\s*"GOARCH": "'$GOARCH'",\n' cp stdout tool-json-broken.txt [short] stop
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 22 19:52:13 UTC 2023 - 1.2K bytes - Viewed (0) -
subprojects/core/src/integTest/groovy/org/gradle/execution/ExceptionAttributionIntegrationTest.groovy
} } """ file("buildSrc/src/main/resources/META-INF/gradle-plugins/test.broken.properties") << """ implementation-class=PluginImpl """ buildFile << """ plugins { id("test.broken") } """ expect: 2.times { fails("broken")
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jan 07 06:23:22 UTC 2023 - 3.7K bytes - Viewed (0)