| LOW | partitioner.go | 21 | // partitions (even ones known to be unavailable), and its choice must be |
| LOW | config.go | 41 | // Net is the namespace for network-level properties used by the Broker, and |
| LOW | config.go | 61 | // original address list. Similar to the `client.dns.lookup` option in |
| LOW | config.go | 81 | Enable bool |
| LOW | config.go | 141 | // cluster is in the middle of a leader election (default 3). |
| LOW | config.go | 161 | |
| LOW | config.go | 181 | } |
| LOW | config.go | 201 | Compression CompressionCodec |
| LOW | config.go | 221 | |
| LOW | config.go | 241 | // this internally. |
| LOW | config.go | 261 | // `MaxMessages` to set a hard upper limit. |
| LOW | config.go | 281 | // more sophisticated backoff strategies. This takes precedence over |
| LOW | config.go | 301 | // message for the first time. Interceptors allows to intercept and |
| LOW | config.go | 321 | Timeout time.Duration |
| LOW | config.go | 341 | // strategy that all group members support will be chosen by the leader. |
| LOW | config.go | 381 | // How long to wait after a failing to read from a partition before |
| LOW | config.go | 401 | // as 0 causes the consumer to spin when no messages are available. |
| LOW | config.go | 421 | // one extra RecordBatch beyond it to guarantee progress when a single |
| LOW | config.go | 441 | // of the expiryTicker then a timeout is detected. |
| LOW | config.go | 461 | // Offsets specifies configuration for how and when to commit consumed |
| LOW | config.go | 481 | // Should be OffsetNewest or OffsetOldest. Defaults to OffsetNewest. |
| LOW | config.go | 501 | // - use `ReadCommitted` to hide messages that are part of an aborted transaction |
| LOW | config.go | 521 | // The number of events to buffer in internal and external channels. This |
| LOW | metadata.go | 241 | for { |
| LOW | sync_producer.go | 21 | type SyncProducer interface { |
| LOW | async_producer.go | 21 | // minFunctionalRetryBufferLength defines the minimum number of messages the retry buffer must support. |
| LOW | async_producer.go | 41 | // drain the results of any messages in flight. |
| LOW | async_producer.go | 341 | |
| LOW | async_producer.go | 361 | // Timestamp can vary in behavior depending on broker configuration, being |
| LOW | CHANGELOG.md | 1301 | #1817 - reverts #1785 - Add private method to Client interface to prevent implementation |
| LOW | CHANGELOG.md | 1321 | ### Improvements |
| LOW | request_test.go | 421 | apiKeyMetadata: 10, // up from 9 |
| LOW | request_test.go | 501 | { |
| LOW | request.go | 221 | return &DescribeClusterRequest{Version: version} |
| LOW | fetch_response.go | 41 | |
| LOW | offset_manager.go | 501 | if om.sessionCanceler != nil { |
| LOW | offset_manager.go | 521 | // metadata string can be used by another consumer to restore that state, so it |
| LOW | offset_manager.go | 541 | // Errors returns a read channel of errors that occur during offset management, if |
| LOW | client.go | 21 | // automatically when it passes out of scope. It is safe to share a client amongst many |
| LOW | client.go | 81 | // available metadata for those topics. If no topics are provided, it will refresh |
| LOW | client.go | 121 | // to call this function before a client object passes out of scope, as it will |
| LOW | client.go | 1081 | if client.Closed() { |
| LOW | interceptors.go | 1 | package sarama |
| LOW | produce_response.go | 1 | package sarama |
| LOW | admin.go | 21 | // It may take several seconds after CreateTopic returns success for all the brokers |
| LOW | admin.go | 41 | // If partitions are increased for a topic that has a key, the partition logic or ordering of |
| LOW | admin.go | 61 | // The returned configuration includes default values and the Default is true |
| LOW | admin.go | 81 | |
| LOW | admin.go | 121 | // |
| LOW | consumer.go | 61 | // This method is the same as Client.Partitions(), and is provided for convenience. |
| LOW | consumer.go | 341 | |
| LOW | consumer.go | 361 | // should continue to service the 'Messages' and 'Errors' channels until they are empty. It is required to call this |
| LOW | consumer.go | 381 | Errors() <-chan *ConsumerError |
| LOW | fetch_request.go | 61 | // is from a consumer. |
| LOW | describe_client_quotas_response.go | 1 | package sarama |
| LOW | config_test.go | 601 | metrics.WriteOnce(appMetricRegistry, os.Stdout) |
| LOW | join_group_request.go | 41 | SessionTimeout int32 |
| LOW | balance_strategy.go | 61 | // BalanceStrategy that lets a strategy inject per-cycle metadata into the |
| LOW | balance_strategy.go | 121 | // Example with topic T with six partitions (0..5) and two members (M1, M2): |
| LOW | consumer_group.go | 21 | var ErrSessionPartitionCountChanged = errors.New("kafka: partition count changed for subscribed topic") |
| 14 more matches not shown… |