diff --git a/config/consumer.properties b/config/consumer.properties index 83847de30d1..01bb12eb089 100644 --- a/config/consumer.properties +++ b/config/consumer.properties @@ -12,18 +12,15 @@ # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. # See the License for the specific language governing permissions and # limitations under the License. -# see kafka.consumer.ConsumerConfig for more details +# see org.apache.kafka.clients.consumer.ConsumerConfig for more details -# Zookeeper connection string -# comma separated host:port pairs, each corresponding to a zk -# server. e.g. "127.0.0.1:3000,127.0.0.1:3001,127.0.0.1:3002" -zookeeper.connect=127.0.0.1:2181 +# list of brokers used for bootstrapping knowledge about the rest of the cluster +# format: host1:port1,host2:port2 ... +bootstrap.servers=localhost:9092 -# timeout in ms for connecting to zookeeper -zookeeper.connection.timeout.ms=6000 - -#consumer group id +# consumer group id group.id=test-consumer-group -#consumer timeout -#consumer.timeout.ms=5000 +# What to do when there is no initial offset in Kafka or if the current +# offset does not exist any more on the server: latest, earliest, none +#auto.offset.reset= diff --git a/config/producer.properties b/config/producer.properties index fcd745c783c..8833ea219d8 100644 --- a/config/producer.properties +++ b/config/producer.properties @@ -12,7 +12,7 @@ # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. # See the License for the specific language governing permissions and # limitations under the License. -# see kafka.producer.ProducerConfig for more details +# see org.apache.kafka.clients.producer for more details ############################# Producer Basics ############################# diff --git a/docs/upgrade.html b/docs/upgrade.html index 862dadb6b47..f5380e87e87 100644 --- a/docs/upgrade.html +++ b/docs/upgrade.html @@ -90,6 +90,7 @@ will return TOPIC_AUTHORIZATION_FAILED errors to requests irrespective of topic existence on broker. If the user have required permissions and the topic doesn't exists, then the UNKNOWN_TOPIC_OR_PARTITION error code will be returned. +
  • config/consumer.properties file updated to use new consumer config properties.
  • New Protocol Versions