Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 61 - 70 of 230 for _producer (0.29 seconds)

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

  1. okhttp-testing-support/src/main/kotlin/okhttp3/JsseDebugLogging.kt

              message.startsWith("Reload ") -> Type.Setup
              message == "No session to resume." -> Type.Handshake
              message.startsWith("Consuming ") -> Type.Handshake
              message.startsWith("Produced ") -> Type.Handshake
              message.startsWith("Negotiated ") -> Type.Handshake
              message.startsWith("Found resumable session") -> Type.Handshake
              message.startsWith("Resuming session") -> Type.Handshake
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 2.8K bytes
    - Click Count (0)
  2. 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)
  3. android/guava/src/com/google/common/collect/EmptyImmutableListMultimap.java

      private EmptyImmutableListMultimap() {
        super(ImmutableMap.of(), 0);
      }
    
      /*
       * TODO(b/242884182): Figure out why this helps produce the same class file when we compile most
       * of common.collect a second time with the results of the first compilation on the classpath. Or
       * just back this out once we stop doing that (which we'll do after our internal GWT setup
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Sep 22 21:07:18 GMT 2025
    - 1.8K bytes
    - Click Count (0)
  4. guava/src/com/google/common/collect/EmptyImmutableListMultimap.java

      private EmptyImmutableListMultimap() {
        super(ImmutableMap.of(), 0);
      }
    
      /*
       * TODO(b/242884182): Figure out why this helps produce the same class file when we compile most
       * of common.collect a second time with the results of the first compilation on the classpath. Or
       * just back this out once we stop doing that (which we'll do after our internal GWT setup
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Sep 22 21:07:18 GMT 2025
    - 1.8K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/collect/EmptyImmutableSetMultimap.java

      private EmptyImmutableSetMultimap() {
        super(ImmutableMap.of(), 0, null);
      }
    
      /*
       * TODO(b/242884182): Figure out why this helps produce the same class file when we compile most
       * of common.collect a second time with the results of the first compilation on the classpath. Or
       * just back this out once we stop doing that (which we'll do after our internal GWT setup
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Sep 22 21:07:18 GMT 2025
    - 1.8K bytes
    - Click Count (0)
  6. .gitignore

    /www/master/shared/config/development.json
    
    # Karma output
    /www/test_out
    
    # precommit temporary directories created by ./hack/verify-generated-docs.sh and ./hack/lib/util.sh
    /_tmp/
    /doc_tmp/
    
    # Test artifacts produced by Prow/kubetest2 jobs
    /_artifacts/
    /_rundir/
    
    # Go dependencies installed on Jenkins
    /_gopath/
    
    # Config directories created by gcloud and gsutil on Jenkins
    /.config/gcloud*/
    /.gsutil/
    
    Created: Fri Apr 03 09:05:14 GMT 2026
    - Last Modified: Tue Mar 17 02:28:41 GMT 2026
    - 2.2K bytes
    - Click Count (0)
  7. compat/maven-model-builder/src/main/java/org/apache/maven/model/building/ModelBuilder.java

         */
        ModelBuildingResult build(ModelBuildingRequest request) throws ModelBuildingException;
    
        /**
         * Builds the effective model by completing the specified interim result which was produced by a previous call to
         * {@link #build(ModelBuildingRequest)} with {@link ModelBuildingRequest#isTwoPhaseBuilding()} being {@code true}.
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Tue Feb 25 08:27:34 GMT 2025
    - 2.6K bytes
    - Click Count (0)
  8. src/test/java/org/codelibs/fess/suggest/entity/SuggestItemBoundaryTest.java

            SuggestItem item2 = new SuggestItem(text2, readings2, null, 0L, 0L, 1.0f, null, null, null, SuggestItem.Kind.QUERY);
    
            // Different word order should produce different IDs (since text is "word1 word2" vs "word2 word1")
            assertFalse("Different word order should produce different IDs", item1.getId().equals(item2.getId()));
        }
    Created: Fri Apr 17 09:08:13 GMT 2026
    - Last Modified: Sat Jan 17 05:10:37 GMT 2026
    - 22.2K bytes
    - Click Count (0)
  9. cycle_suppress_list.txt

    FIELD com.google.common.util.concurrent.AbstractFuture.Listener.executor com.google.common.util.concurrent.ExecutionSequencer.TaskNonReentrantExecutor
    
    # ***** FALSE POSITIVES *****
    
    # The Runnable type is so generic that it produces too many false positives.
    TYPE java.lang.Runnable
    
    FIELD com.google.common.base.Converter.reverse
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Jul 24 01:59:49 GMT 2025
    - 3.2K bytes
    - Click Count (0)
  10. android/guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedArrayBlockingQueue.java

     * inserted by producers and extracted by consumers. Once created, the capacity cannot be increased.
     * Attempts to {@code put} an element into a full queue will result in the operation blocking;
     * attempts to {@code take} an element from an empty queue will similarly block.
     *
     * <p>This class supports an optional fairness policy for ordering waiting producer and consumer
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 23 21:06:42 GMT 2026
    - 22.4K bytes
    - Click Count (0)
Back to Top