| LOW | partitioner.go | 21 | // partitions (even ones known to be unavailable), and its choice must be | COMMENT |
| LOW | config.go | 41 | // Net is the namespace for network-level properties used by the Broker, and | COMMENT |
| LOW | config.go | 61 | // original address list. Similar to the `client.dns.lookup` option in | COMMENT |
| LOW | config.go | 81 | Enable bool | COMMENT |
| LOW | config.go | 141 | // cluster is in the middle of a leader election (default 3). | COMMENT |
| LOW | config.go | 161 | | COMMENT |
| LOW | config.go | 181 | } | COMMENT |
| LOW | config.go | 201 | // RequiredAcks (defaults to 10 seconds). This is only relevant when | COMMENT |
| LOW | config.go | 221 | // Transaction specify | COMMENT |
| LOW | config.go | 241 | } | COMMENT |
| LOW | config.go | 261 | // across all its accumulated topic and partition batches. Producer.MaxMessageBytes | COMMENT |
| LOW | config.go | 281 | // Similar to the `message.send.max.retries` setting of the JVM producer. | COMMENT |
| LOW | config.go | 301 | // Defaults to 0 for unlimited. | COMMENT |
| LOW | config.go | 321 | Session struct { | COMMENT |
| LOW | config.go | 341 | // | COMMENT |
| LOW | config.go | 381 | // under-replication where a replica does not have all the data yet. It can be | COMMENT |
| LOW | config.go | 401 | } | COMMENT |
| LOW | config.go | 421 | // (no limit). Similar to the JVM's `fetch.message.max.bytes`. The | COMMENT |
| LOW | config.go | 441 | // The maximum amount of time the consumer expects a message takes to | COMMENT |
| LOW | config.go | 461 | // you must read from them to prevent deadlock. | COMMENT |
| LOW | config.go | 481 | // When disabled, marked offsets are only sent by | COMMENT |
| LOW | config.go | 501 | // (default is 0: disabled). | COMMENT |
| LOW | config.go | 521 | // interceptor chain. | COMMENT |
| LOW | config.go | 541 | // and most 3rdparty ones. | COMMENT |
| LOW | metadata.go | 241 | ch, queued := m.refreshOrQueue(topics) | COMMENT |
| LOW | sync_producer.go | 21 | type SyncProducer interface { | COMMENT |
| LOW | async_producer.go | 21 | | COMMENT |
| LOW | async_producer.go | 41 | // when both the Errors and Successes channels have been closed. When calling | COMMENT |
| LOW | async_producer.go | 361 | // Sarama completely ignores this field and is only to be used for | COMMENT |
| LOW | list_transactions_request.go | 21 | // one of the filtered states are returned | COMMENT |
| LOW | CHANGELOG.md | 1321 | ### Improvements | COMMENT |
| LOW | CHANGELOG.md | 1341 | ## Fixes | COMMENT |
| LOW | sarama.go | 101 | | COMMENT |
| LOW | describe_groups_response.go | 221 | | COMMENT |
| LOW | request_test.go | 421 | // TODO: FindCoordinatorRequest v5 is not supported, but expected for KafkaVersion 3.8.0 | COMMENT |
| LOW | request_test.go | 441 | // apiKeyListOffsets: 9, // up from 8 | COMMENT |
| LOW | request_test.go | 461 | // apiKeyEndTxn: 5, // up from 4 | COMMENT |
| LOW | request.go | 221 | return &UpdateFeaturesRequest{Version: version} | COMMENT |
| LOW | offset_manager.go | 621 | } | COMMENT |
| LOW | offset_manager.go | 641 | // To follow upstream conventions, you are expected to mark the offset of the | COMMENT |
| LOW | offset_manager.go | 661 | // Consumer.Return.Errors setting to true, and read from this channel. | COMMENT |
| LOW | client.go | 21 | // automatically when it passes out of scope. It is safe to share a client amongst many | COMMENT |
| LOW | client.go | 81 | // available metadata for those topics. If no topics are provided, it will refresh | COMMENT |
| LOW | client.go | 121 | // to call this function before a client object passes out of scope, as it will | COMMENT |
| LOW | client.go | 1081 | // Close may have run since the check above, leaving nil maps | COMMENT |
| LOW | interceptors.go | 1 | package sarama | COMMENT |
| LOW | produce_response.go | 1 | package sarama | COMMENT |
| LOW | admin.go | 21 | // It may take several seconds after CreateTopic returns success for all the brokers | COMMENT |
| LOW | admin.go | 41 | // If partitions are increased for a topic that has a key, the partition logic or ordering of | COMMENT |
| LOW | admin.go | 61 | // The returned configuration includes default values and the Default is true | COMMENT |
| LOW | admin.go | 81 | // This operation is supported by brokers with version 0.11.0.0 or higher. | COMMENT |
| LOW | admin.go | 101 | // | COMMENT |
| LOW | admin.go | 121 | // ElectLeaders allows to trigger the election of preferred leaders for a set of partitions. | COMMENT |
| LOW | admin.go | 141 | // is re-batched. Non-retriable per-group errors are returned in the per-group Err. | COMMENT |
| LOW | consumer.go | 61 | // This method is the same as Client.Partitions(), and is provided for convenience. | COMMENT |
| LOW | consumer.go | 361 | for _, partitions := range c.children { | COMMENT |
| LOW | consumer.go | 381 | // | COMMENT |
| LOW | consumer.go | 401 | // Messages returns the read channel for the messages that are returned by | COMMENT |
| LOW | fetch_request.go | 61 | return err | COMMENT |
| LOW | fetch_request.go | 81 | // transactional records. Using READ_UNCOMMITTED (isolation_level = 0) | COMMENT |
| 20 more matches not shown… |
Adjusted legacy signal; badge bands: 25 / 50 / 75 (different from dashboard bands).