- Sort Score
- Num 10 results
- Language All
Results 11 - 20 of 236 for Producer (0.07 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
internal/config/notify/legacy.go
config.KV{ Key: target.KafkaSASLPassword, Value: cfg.SASL.Password, }, config.KV{ Key: target.KafkaCompressionCodec, Value: cfg.Producer.Compression, }, config.KV{ Key: target.KafkaCompressionLevel, Value: strconv.Itoa(cfg.Producer.CompressionLevel), }, } return nil } // SetNotifyAMQP - helper for config migration from older config.Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Apr 27 04:30:57 GMT 2025 - 13.3K bytes - Click Count (0) -
internal/config/notify/parse.go
compressionCodecEnv := target.EnvKafkaProducerCompressionCodec if k != config.Default { compressionCodecEnv = compressionCodecEnv + config.Default + k } kafkaArgs.Producer.Compression = env.Get(compressionCodecEnv, kv.Get(target.KafkaCompressionCodec)) compressionLevelEnv := target.EnvKafkaProducerCompressionLevel if k != config.Default {Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 47.5K bytes - Click Count (0) -
api/maven-api-core/src/main/java/org/apache/maven/api/Packaging.java
import org.apache.maven.api.model.PluginContainer; /** * Represents the packaging of a Maven project. * * <p>The {@code Packaging} class defines the type of artifact that a Maven project produces during the build process. * The packaging type determines the structure of the project's output and how Maven will treat the resulting artifact.</p> *Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Fri Jun 06 14:28:57 GMT 2025 - 3.2K bytes - Click Count (0) -
android/guava/src/com/google/common/hash/HashFunction.java
* (given by {@link #bits}). For example, {@link Hashing#sha1} produces a 160-bit number, * while {@link Hashing#murmur3_32()} yields only 32 bits. Because a {@code long} value is * clearly insufficient to hold all hash code values, this API represents a hash code as an * instance of {@link HashCode}. * <li><b>pure function:</b> the value produced must depend only on the input bytes, in the orderCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 17 20:26:29 GMT 2025 - 10.9K bytes - Click Count (0) -
doc/go_spec.html
the corresponding iteration value will not be produced. If a map entry is created during iteration, that entry may be produced during the iteration or may be skipped. The choice may vary for each entry created and from one iteration to the next. If the map is <code>nil</code>, the number of iterations is 0. </li> <li> For channels, the iteration values produced are the successive values sent on
Created: Tue Apr 07 11:13:11 GMT 2026 - Last Modified: Wed Apr 01 23:39:18 GMT 2026 - 287.8K bytes - Click Count (1) -
src/test/java/jcifs/smb1/util/HMACT64Test.java
different = true; break; } } assertEquals(true, different, "Different keys should produce different HMAC values"); } @Test void testDifferentDataProducesDifferentResults() { // Test that different data produces different results byte[] data1 = "data1".getBytes(); byte[] data2 = "data2".getBytes();Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 10.1K bytes - Click Count (0) -
android/guava/src/com/google/common/hash/Hashing.java
* * @param minimumBits a positive integer. This can be arbitrarily large. The returned {@link * HashFunction} instance may use memory proportional to this integer. * @return a hash function, described above, that produces hash codes of length {@code * minimumBits} or greater */ public static HashFunction goodFastHash(int minimumBits) { int bits = checkPositiveAndMakeMultipleOf32(minimumBits); if (bits == 32) {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Jul 17 15:26:41 GMT 2025 - 29.8K bytes - Click Count (0) -
docs/es/docs/tutorial/stream-json-lines.md
```mermaid sequenceDiagram participant App participant Client App->>App: Produce Item 1 App->>Client: Send Item 1 App->>App: Produce Item 2 Client->>Client: Process Item 1 App->>Client: Send Item 2 App->>App: Produce Item 3 Client->>Client: Process Item 2 App->>Client: Send Item 3 Client->>Client: Process Item 3Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 19 18:12:26 GMT 2026 - 4.6K bytes - Click Count (0) -
src/test/java/jcifs/util/CryptoTest.java
// When MessageDigest md4 = Crypto.getMD4(); byte[] hash = md4.digest(data); // Then assertNotNull(hash); assertEquals(16, hash.length); // MD4 produces 128-bit hash } @Test @DisplayName("Should calculate MD5 hash correctly") void testMD5Hash() { // Given String input = "Hello World"; byte[] data = input.getBytes();Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 7.4K bytes - Click Count (0) -
src/test/java/jcifs/smb1/smb1/NtlmChallengeTest.java
assertNull(nc.dc); } } @Nested @DisplayName("toString() Tests") class ToStringTests { @Test @DisplayName("toString with valid data produces expected format") void testToStringWithValidData() { byte[] challenge = new byte[] { (byte) 0x01, (byte) 0x02, (byte) 0x03, (byte) 0xFF }; UniAddress dc = mock(UniAddress.class);
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 6K bytes - Click Count (0)