- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 105 for Producers (0.2 sec)
-
internal/event/target/kafka.go
config.Producer.Retry.Max = 2 config.Producer.Retry.Backoff = (1 * time.Second) config.Producer.Return.Successes = true config.Producer.Return.Errors = true config.Producer.RequiredAcks = 1 config.Producer.Timeout = (5 * time.Second) // Set Producer Compression cc, ok := codecs[strings.ToLower(args.Producer.Compression)] if ok { config.Producer.Compression = cc
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 20 08:16:35 GMT 2024 - 13K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/QueuesTest.java
assertEquals(0, Queues.drain(q, ImmutableList.of(), 1, 10, MILLISECONDS)); Producer producer = new Producer(q, 1); // producing one, will ask for two Future<?> producerThread = threadPool.submit(producer); producer.beganProducing.await(); // make sure we time out Stopwatch timer = Stopwatch.createStarted();
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 12K bytes - Viewed (0) -
internal/logger/target/kafka/kafka.go
// refer https://github.com/IBM/sarama/issues/765#issuecomment-254333355 sconfig.Producer.Retry.Max = 2 sconfig.Producer.Retry.Backoff = (10 * time.Second) sconfig.Producer.Return.Successes = true sconfig.Producer.Return.Errors = true sconfig.Producer.RequiredAcks = 1 sconfig.Producer.Timeout = (10 * time.Second) sconfig.Net.ReadTimeout = (10 * time.Second) sconfig.Net.DialTimeout = (10 * time.Second)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 10.1K bytes - Viewed (1) -
.github/ISSUE_TEMPLATE/tflite-converter-issue.md
``` ### 3. Failure after conversion If the conversion is successful, but the generated model is wrong, then state what is wrong: - Model produces wrong results and/or has lesser accuracy. - Model produces correct results, but it is slower than expected. ### 4. (optional) RNN conversion support If converting TF RNN to TFLite fused RNN ops, please prefix [RNN] in the title.
Plain Text - Registered: Tue May 07 12:40:20 GMT 2024 - Last Modified: Wed Jun 15 03:35:58 GMT 2022 - 2.1K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/testing/NullPointerTester.java
*/ public void testAllPublicInstanceMethods(Object instance) { testInstanceMethods(instance, Visibility.PUBLIC); } /** * Verifies that {@code method} produces a {@link NullPointerException} or {@link * UnsupportedOperationException} whenever <i>any</i> of its non-nullable parameters are null. *
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Nov 16 15:12:31 GMT 2023 - 22.8K bytes - Viewed (0) -
build-logic/binary-compatibility/src/test/kotlin/gradlebuild/binarycompatibility/AbstractBinaryCompatibilityTest.kt
* Runs the binary compatibility check against two source trees. * * The fixture build supports both Java and Kotlin sources. * * @param v1 sources producer for V1, receiver is the `src/main` directory * @param v2 sources producer for V2, receiver is the `src/main` directory * @param block convenience block invoked on the result * @return the check result */ private
Plain Text - Registered: Wed May 01 11:36:15 GMT 2024 - Last Modified: Mon Sep 25 13:49:37 GMT 2023 - 16.4K bytes - Viewed (0) -
guava-testlib/src/com/google/common/testing/NullPointerTester.java
*/ public void testAllPublicInstanceMethods(Object instance) { testInstanceMethods(instance, Visibility.PUBLIC); } /** * Verifies that {@code method} produces a {@link NullPointerException} or {@link * UnsupportedOperationException} whenever <i>any</i> of its non-nullable parameters are null. *
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Thu Nov 16 15:12:31 GMT 2023 - 23.3K bytes - Viewed (0) -
.gitattributes
# Treat all files in the Go repo as binary, with no git magic updating # line endings. This produces predictable results in different environments. # # Windows users contributing to Go will need to use a modern version # of git and editors capable of LF line endings. # # Windows .bat files are known to have multiple bugs when run with LF # endings, and so they are checked in with CRLF endings, with a test
Plain Text - Registered: Tue May 07 11:14:38 GMT 2024 - Last Modified: Mon Jun 08 15:31:43 GMT 2020 - 639 bytes - Viewed (0) -
doc/next/6-stdlib/2-unique.md
The new [unique](/pkg/unique) package provides facilities for canonicalizing values (like "interning" or "hash-consing"). Any value of comparable type may be canonicalized with the new `Make[T]` function, which produces a reference to a canonical copy of the value in the form of a `Handle[T]`. Two `Handle[T]` are equal if and only if the values used to produce the handles are equal, allowing programs to deduplicate values and reduce
Plain Text - Registered: Tue May 07 11:14:38 GMT 2024 - Last Modified: Wed Apr 24 13:37:36 GMT 2024 - 579 bytes - Viewed (0) -
android/guava/src/com/google/common/collect/FluentIterable.java
* in this fluent iterable to that value * @throws IllegalArgumentException if {@code keyFunction} produces the same key for more than one * value in this fluent iterable * @throws NullPointerException if any element of this iterable is {@code null}, or if {@code * keyFunction} produces {@code null} for any key * @since 14.0 */
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Jan 30 00:14:39 GMT 2024 - 35.7K bytes - Viewed (0)