http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/common/errors/AuthorizationException.html ---------------------------------------------------------------------- diff --git a/090/javadoc/org/apache/kafka/common/errors/AuthorizationException.html b/090/javadoc/org/apache/kafka/common/errors/AuthorizationException.html index 6a89cf0..29173a3 100644 --- a/090/javadoc/org/apache/kafka/common/errors/AuthorizationException.html +++ b/090/javadoc/org/apache/kafka/common/errors/AuthorizationException.html @@ -2,15 +2,15 @@ - -AuthorizationException (clients 0.9.0.0 API) - + +AuthorizationException (clients 0.9.0.1 API) + http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/common/errors/BrokerNotAvailableException.html ---------------------------------------------------------------------- diff --git a/090/javadoc/org/apache/kafka/common/errors/BrokerNotAvailableException.html b/090/javadoc/org/apache/kafka/common/errors/BrokerNotAvailableException.html index 220d260..a74fe71 100644 --- a/090/javadoc/org/apache/kafka/common/errors/BrokerNotAvailableException.html +++ b/090/javadoc/org/apache/kafka/common/errors/BrokerNotAvailableException.html @@ -2,15 +2,15 @@ - -BrokerNotAvailableException (clients 0.9.0.0 API) - + +BrokerNotAvailableException (clients 0.9.0.1 API) + http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/common/errors/ControllerMovedException.html ---------------------------------------------------------------------- diff --git a/090/javadoc/org/apache/kafka/common/errors/ControllerMovedException.html b/090/javadoc/org/apache/kafka/common/errors/ControllerMovedException.html index e07526e..8138436 100644 --- a/090/javadoc/org/apache/kafka/common/errors/ControllerMovedException.html +++ b/090/javadoc/org/apache/kafka/common/errors/ControllerMovedException.html @@ -2,15 +2,15 @@ - -ControllerMovedException (clients 0.9.0.0 API) - + +ControllerMovedException (clients 0.9.0.1 API) + http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/common/errors/CorruptRecordException.html ---------------------------------------------------------------------- diff --git a/090/javadoc/org/apache/kafka/common/errors/CorruptRecordException.html b/090/javadoc/org/apache/kafka/common/errors/CorruptRecordException.html index dd13ad7..4f2e17c 100644 --- a/090/javadoc/org/apache/kafka/common/errors/CorruptRecordException.html +++ b/090/javadoc/org/apache/kafka/common/errors/CorruptRecordException.html @@ -2,15 +2,15 @@ - -CorruptRecordException (clients 0.9.0.0 API) - + +CorruptRecordException (clients 0.9.0.1 API) + http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/common/errors/DisconnectException.html ---------------------------------------------------------------------- diff --git a/090/javadoc/org/apache/kafka/common/errors/DisconnectException.html b/090/javadoc/org/apache/kafka/common/errors/DisconnectException.html index 32d11a6..0b0b95e 100644 --- a/090/javadoc/org/apache/kafka/common/errors/DisconnectException.html +++ b/090/javadoc/org/apache/kafka/common/errors/DisconnectException.html @@ -2,15 +2,15 @@ - -DisconnectException (clients 0.9.0.0 API) - + +DisconnectException (clients 0.9.0.1 API) + @@ -61,13 +61,13 @@ @@ -139,6 +139,25 @@ extends http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/common/serialization/ByteArrayDeserializer.html ---------------------------------------------------------------------- diff --git a/090/javadoc/org/apache/kafka/common/serialization/ByteArrayDeserializer.html b/090/javadoc/org/apache/kafka/common/serialization/ByteArrayDeserializer.html index faa5ea3..82f7f2a 100644 --- a/090/javadoc/org/apache/kafka/common/serialization/ByteArrayDeserializer.html +++ b/090/javadoc/org/apache/kafka/common/serialization/ByteArrayDeserializer.html @@ -2,15 +2,15 @@ - -ByteArrayDeserializer (clients 0.9.0.0 API) - + +ByteArrayDeserializer (clients 0.9.0.1 API) + http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/common/serialization/ByteArraySerializer.html ---------------------------------------------------------------------- diff --git a/090/javadoc/org/apache/kafka/common/serialization/ByteArraySerializer.html b/090/javadoc/org/apache/kafka/common/serialization/ByteArraySerializer.html index 71681fa..4301d46 100644 --- a/090/javadoc/org/apache/kafka/common/serialization/ByteArraySerializer.html +++ b/090/javadoc/org/apache/kafka/common/serialization/ByteArraySerializer.html @@ -2,15 +2,15 @@ - -ByteArraySerializer (clients 0.9.0.0 API) - + +ByteArraySerializer (clients 0.9.0.1 API) + http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/common/serialization/Deserializer.html ---------------------------------------------------------------------- diff --git a/090/javadoc/org/apache/kafka/common/serialization/Deserializer.html b/090/javadoc/org/apache/kafka/common/serialization/Deserializer.html index e3358ac..2d1a71c 100644 --- a/090/javadoc/org/apache/kafka/common/serialization/Deserializer.html +++ b/090/javadoc/org/apache/kafka/common/serialization/Deserializer.html @@ -2,15 +2,15 @@ - -Deserializer (clients 0.9.0.0 API) - + +Deserializer (clients 0.9.0.1 API) + http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/common/serialization/IntegerDeserializer.html ---------------------------------------------------------------------- diff --git a/090/javadoc/org/apache/kafka/common/serialization/IntegerDeserializer.html b/090/javadoc/org/apache/kafka/common/serialization/IntegerDeserializer.html index d6768cb..5a8c0bc 100644 --- a/090/javadoc/org/apache/kafka/common/serialization/IntegerDeserializer.html +++ b/090/javadoc/org/apache/kafka/common/serialization/IntegerDeserializer.html @@ -2,15 +2,15 @@ - -IntegerDeserializer (clients 0.9.0.0 API) - + +IntegerDeserializer (clients 0.9.0.1 API) + http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/common/serialization/IntegerSerializer.html ---------------------------------------------------------------------- diff --git a/090/javadoc/org/apache/kafka/common/serialization/IntegerSerializer.html b/090/javadoc/org/apache/kafka/common/serialization/IntegerSerializer.html index e1dd089..66983fe 100644 --- a/090/javadoc/org/apache/kafka/common/serialization/IntegerSerializer.html +++ b/090/javadoc/org/apache/kafka/common/serialization/IntegerSerializer.html @@ -2,15 +2,15 @@ - -IntegerSerializer (clients 0.9.0.0 API) - + +IntegerSerializer (clients 0.9.0.1 API) + http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/common/serialization/LongDeserializer.html ---------------------------------------------------------------------- diff --git a/090/javadoc/org/apache/kafka/common/serialization/LongDeserializer.html b/090/javadoc/org/apache/kafka/common/serialization/LongDeserializer.html index 0b58719..9cf8110 100644 --- a/090/javadoc/org/apache/kafka/common/serialization/LongDeserializer.html +++ b/090/javadoc/org/apache/kafka/common/serialization/LongDeserializer.html @@ -2,15 +2,15 @@ - -LongDeserializer (clients 0.9.0.0 API) - + +LongDeserializer (clients 0.9.0.1 API) + http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/common/serialization/LongSerializer.html ---------------------------------------------------------------------- diff --git a/090/javadoc/org/apache/kafka/common/serialization/LongSerializer.html b/090/javadoc/org/apache/kafka/common/serialization/LongSerializer.html index 49d52e0..cc2db34 100644 --- a/090/javadoc/org/apache/kafka/common/serialization/LongSerializer.html +++ b/090/javadoc/org/apache/kafka/common/serialization/LongSerializer.html @@ -2,15 +2,15 @@ - -LongSerializer (clients 0.9.0.0 API) - + +LongSerializer (clients 0.9.0.1 API) + http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/common/serialization/Serializer.html ---------------------------------------------------------------------- diff --git a/090/javadoc/org/apache/kafka/common/serialization/Serializer.html b/090/javadoc/org/apache/kafka/common/serialization/Serializer.html index 69ca220..f65cfde 100644 --- a/090/javadoc/org/apache/kafka/common/serialization/Serializer.html +++ b/090/javadoc/org/apache/kafka/common/serialization/Serializer.html @@ -2,15 +2,15 @@ - -Serializer (clients 0.9.0.0 API) - + +Serializer (clients 0.9.0.1 API) + http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/common/serialization/StringDeserializer.html ---------------------------------------------------------------------- diff --git a/090/javadoc/org/apache/kafka/common/serialization/StringDeserializer.html b/090/javadoc/org/apache/kafka/common/serialization/StringDeserializer.html index fed4830..24c7780 100644 --- a/090/javadoc/org/apache/kafka/common/serialization/StringDeserializer.html +++ b/090/javadoc/org/apache/kafka/common/serialization/StringDeserializer.html @@ -2,15 +2,15 @@ - -StringDeserializer (clients 0.9.0.0 API) - + +StringDeserializer (clients 0.9.0.1 API) + http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/common/serialization/StringSerializer.html ---------------------------------------------------------------------- diff --git a/090/javadoc/org/apache/kafka/common/serialization/StringSerializer.html b/090/javadoc/org/apache/kafka/common/serialization/StringSerializer.html index eaa4a04..a58c9be 100644 --- a/090/javadoc/org/apache/kafka/common/serialization/StringSerializer.html +++ b/090/javadoc/org/apache/kafka/common/serialization/StringSerializer.html @@ -2,15 +2,15 @@ - -StringSerializer (clients 0.9.0.0 API) - + +StringSerializer (clients 0.9.0.1 API) + http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/common/serialization/package-frame.html ---------------------------------------------------------------------- diff --git a/090/javadoc/org/apache/kafka/common/serialization/package-frame.html b/090/javadoc/org/apache/kafka/common/serialization/package-frame.html index 5e66acc..b188beb 100644 --- a/090/javadoc/org/apache/kafka/common/serialization/package-frame.html +++ b/090/javadoc/org/apache/kafka/common/serialization/package-frame.html @@ -2,9 +2,9 @@ - -org.apache.kafka.common.serialization (clients 0.9.0.0 API) - + +org.apache.kafka.common.serialization (clients 0.9.0.1 API) + http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/common/serialization/package-summary.html ---------------------------------------------------------------------- diff --git a/090/javadoc/org/apache/kafka/common/serialization/package-summary.html b/090/javadoc/org/apache/kafka/common/serialization/package-summary.html index 364ac89..d008d3f 100644 --- a/090/javadoc/org/apache/kafka/common/serialization/package-summary.html +++ b/090/javadoc/org/apache/kafka/common/serialization/package-summary.html @@ -2,15 +2,15 @@ - -org.apache.kafka.common.serialization (clients 0.9.0.0 API) - + +org.apache.kafka.common.serialization (clients 0.9.0.1 API) + http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/common/serialization/package-tree.html ---------------------------------------------------------------------- diff --git a/090/javadoc/org/apache/kafka/common/serialization/package-tree.html b/090/javadoc/org/apache/kafka/common/serialization/package-tree.html index 5c005b6..d08f197 100644 --- a/090/javadoc/org/apache/kafka/common/serialization/package-tree.html +++ b/090/javadoc/org/apache/kafka/common/serialization/package-tree.html @@ -2,15 +2,15 @@ - -org.apache.kafka.common.serialization Class Hierarchy (clients 0.9.0.0 API) - + +org.apache.kafka.common.serialization Class Hierarchy (clients 0.9.0.1 API) + http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/overview-frame.html ---------------------------------------------------------------------- diff --git a/090/javadoc/overview-frame.html b/090/javadoc/overview-frame.html index 989bbbe..8b7e1c9 100644 --- a/090/javadoc/overview-frame.html +++ b/090/javadoc/overview-frame.html @@ -2,9 +2,9 @@ - -Overview List (clients 0.9.0.0 API) - + +Overview List (clients 0.9.0.1 API) + http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/overview-summary.html ---------------------------------------------------------------------- diff --git a/090/javadoc/overview-summary.html b/090/javadoc/overview-summary.html index 5fcda96..2dd9557 100644 --- a/090/javadoc/overview-summary.html +++ b/090/javadoc/overview-summary.html @@ -2,15 +2,15 @@ - -Overview (clients 0.9.0.0 API) - + +Overview (clients 0.9.0.1 API) + @@ -62,7 +62,7 @@
-

clients 0.9.0.0 API

+

clients 0.9.0.1 API

http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/overview-tree.html ---------------------------------------------------------------------- diff --git a/090/javadoc/overview-tree.html b/090/javadoc/overview-tree.html index 714c997..3d2242d 100644 --- a/090/javadoc/overview-tree.html +++ b/090/javadoc/overview-tree.html @@ -2,15 +2,15 @@ - -Class Hierarchy (clients 0.9.0.0 API) - + +Class Hierarchy (clients 0.9.0.1 API) + @@ -104,7 +104,7 @@
  • org.apache.kafka.clients.consumer.MockConsumer<K,V> (implements org.apache.kafka.clients.consumer.Consumer<K,V>)
  • org.apache.kafka.clients.producer.MockProducer<K,V> (implements org.apache.kafka.clients.producer.Producer<K,V>)
  • org.apache.kafka.common.Node
  • -
  • org.apache.kafka.clients.consumer.OffsetAndMetadata
  • +
  • org.apache.kafka.clients.consumer.OffsetAndMetadata (implements java.io.Serializable)
  • org.apache.kafka.common.PartitionInfo
  • org.apache.kafka.clients.producer.ProducerRecord<K,V>
  • org.apache.kafka.clients.producer.RecordMetadata
  • @@ -178,7 +178,7 @@ -
  • org.apache.kafka.common.TopicPartition
  • +
  • org.apache.kafka.common.TopicPartition (implements java.io.Serializable)
  • http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/serialized-form.html ---------------------------------------------------------------------- diff --git a/090/javadoc/serialized-form.html b/090/javadoc/serialized-form.html index 1d4f8d3..7e4b725 100644 --- a/090/javadoc/serialized-form.html +++ b/090/javadoc/serialized-form.html @@ -2,15 +2,15 @@ - -Serialized Form (clients 0.9.0.0 API) - + +Serialized Form (clients 0.9.0.1 API) + @@ -105,6 +105,28 @@ +
  • + + +

    Class org.apache.kafka.clients.consumer.OffsetAndMetadata extends java.lang.Object implements Serializable

    + +
  • @@ -155,6 +177,32 @@
    1L
  • +
  • + + +

    Class org.apache.kafka.common.TopicPartition extends java.lang.Object implements Serializable

    + +
  • http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/kafka_config.html ---------------------------------------------------------------------- diff --git a/090/kafka_config.html b/090/kafka_config.html index f851160..efefeb9 100644 --- a/090/kafka_config.html +++ b/090/kafka_config.html @@ -144,6 +144,8 @@
  • + + @@ -168,11 +170,11 @@ - + - + @@ -212,7 +214,7 @@ - + http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/ops.html ---------------------------------------------------------------------- diff --git a/090/ops.html b/090/ops.html index 04d4e7a..e6356ba 100644 --- a/090/ops.html +++ b/090/ops.html @@ -62,7 +62,9 @@ And finally deleting a topic: Topic deletion option is disabled by default. To enable it set the server config
    delete.topic.enable=true

    -Kafka does not currently support reducing the number of partitions for a topic or changing the replication factor. +Kafka does not currently support reducing the number of partitions for a topic. +

    +Instructions for changing the replication factor of a topic can be found here.

    Graceful shutdown

    http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/quickstart.html ---------------------------------------------------------------------- diff --git a/090/quickstart.html b/090/quickstart.html index 14f7518..c8933c3 100644 --- a/090/quickstart.html +++ b/090/quickstart.html @@ -200,7 +200,7 @@ Kafka Connect is a tool included with Kafka that imports and exports data to Kaf how to run Kafka Connect with simple connectors that import data from a file to a Kafka topic and export data from a Kafka topic to a file. -First, we’ll start by creating some seed data to test with: +First, we'll start by creating some seed data to test with:
     > echo -e "foo\nbar" > test.txt
    
    
    
    zookeeper.set.aclSet client to use secure ACLsbooleanfalsehigh
    broker.id.generation.enableEnable automatic broker id generation on the server? When enabled the value configured for reserved.broker.max.id should be reviewed.booleantruemedium
    connections.max.idle.msIdle connections timeout: the server socket processor threads close the connections that idle more than thislong600000medium
    controlled.shutdown.enableEnable controlled shutdown of the serverbooleantruemedium
    log.cleaner.backoff.msThe amount of time to sleep when there are no logs to cleanlong15000[0,...]medium
    log.cleaner.dedupe.buffer.sizeThe total memory used for log deduplication across all cleaner threadslong524288000medium
    log.cleaner.dedupe.buffer.sizeThe total memory used for log deduplication across all cleaner threadslong134217728medium
    log.cleaner.delete.retention.msHow long are delete records retained?long86400000medium
    log.cleaner.enableShould we enable log cleaning?booleanfalsemedium
    log.cleaner.enableEnable the log cleaner process to run on the server? Should be enabled if using any topics with a cleanup.policy=compact including the internal offsets topic. If disabled those topics will not be compacted and continually grow in size.booleantruemedium
    log.cleaner.io.buffer.load.factorLog cleaner dedupe buffer load factor. The percentage full the dedupe buffer can become. A higher value will allow more log to be cleaned at once but will lead to more hash collisionsdouble0.9medium
    sasl.kerberos.min.time.before.reloginLogin thread sleep time between refresh attempts.long60000medium
    sasl.kerberos.principal.to.local.rulesA list of rules for mapping from principal names to short names (typically operating system usernames). The rules are evaluated in order and the first rule that matches a principal name is used to map it to a short name. Any later rules in the list are ignored. By default, principal names of the form {username}/{hostname}@{REALM} are mapped to {username}.list[DEFAULT]medium
    sasl.kerberos.principal.to.local.rulesA list of rules for mapping from principal names to short names (typically operating system usernames). The rules are evaluated in order and the first rule that matches a principal name is used to map it to a short name. Any later rules in the list are ignored. By default, principal names of the form {username}/{hostname}@{REALM} are mapped to {username}. For more details on the format please see security authorization and acls.list[DEFAULT]medium
    sasl.kerberos.service.nameThe Kerberos principal name that Kafka runs as. This can be defined either in Kafka's JAAS config or in Kafka's config.stringnullmedium