Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 11 - 20 of 236 for Producer (0.07 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. 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)
  2. 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)
  3. 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)
  4. 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 order
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 17 20:26:29 GMT 2025
    - 10.9K bytes
    - Click Count (0)
  5. 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)
  6. 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)
  7. 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)
  8. 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 3
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:12:26 GMT 2026
    - 4.6K bytes
    - Click Count (0)
  9. 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)
  10. 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)
Back to Top