diff options
Diffstat (limited to 'kafka')
| -rw-r--r-- | kafka/producer/kafka.py | 4 | ||||
| -rw-r--r-- | kafka/record/_crc32c.py | 4 | ||||
| -rw-r--r-- | kafka/util.py | 2 |
3 files changed, 5 insertions, 5 deletions
diff --git a/kafka/producer/kafka.py b/kafka/producer/kafka.py index 4fc7bc6..7878c0a 100644 --- a/kafka/producer/kafka.py +++ b/kafka/producer/kafka.py @@ -51,7 +51,7 @@ class KafkaProducer(object): 'retries' is configured to 0. Enabling retries also opens up the possibility of duplicates (see the documentation on message delivery semantics for details: - http://kafka.apache.org/documentation.html#semantics + https://kafka.apache.org/documentation.html#semantics ). The producer maintains buffers of unsent records for each partition. These @@ -522,7 +522,7 @@ class KafkaProducer(object): serializable to bytes via configured value_serializer. If value is None, key is required and message acts as a 'delete'. See kafka compaction documentation for more details: - http://kafka.apache.org/documentation.html#compaction + https://kafka.apache.org/documentation.html#compaction (compaction requires kafka >= 0.8.1) partition (int, optional): optionally specify a partition. If not set, the partition will be selected using the configured diff --git a/kafka/record/_crc32c.py b/kafka/record/_crc32c.py index 5704f82..9db2d89 100644 --- a/kafka/record/_crc32c.py +++ b/kafka/record/_crc32c.py @@ -18,9 +18,9 @@ # limitations under the License. # """Implementation of CRC-32C checksumming as in rfc3720 section B.4. -See http://en.wikipedia.org/wiki/Cyclic_redundancy_check for details on CRC-32C +See https://en.wikipedia.org/wiki/Cyclic_redundancy_check for details on CRC-32C This code is a manual python translation of c code generated by -pycrc 0.7.1 (http://www.tty1.net/pycrc/). Command line used: +pycrc 0.7.1 (https://pycrc.org/). Command line used: './pycrc.py --model=crc-32c --generate c --algorithm=table-driven' """ diff --git a/kafka/util.py b/kafka/util.py index 75538dd..9354bd9 100644 --- a/kafka/util.py +++ b/kafka/util.py @@ -134,7 +134,7 @@ class ReentrantTimer(object): class WeakMethod(object): """ Callable that weakly references a method and the object it is bound to. It - is based on http://stackoverflow.com/a/24287465. + is based on https://stackoverflow.com/a/24287465. Arguments: |