Skip to content

Commit

Permalink
KAFKA-3435: Remove Unstable annotation from new Java Consumer
Browse files Browse the repository at this point in the history
Author: Grant Henke <granthenke@gmail.com>

Reviewers: Gwen Shapira

Closes apache#1113 from granthenke/remove-unstable
  • Loading branch information
granthenke authored and gwenshap committed Mar 22, 2016
1 parent 8d8e3aa commit 99cfb99
Show file tree
Hide file tree
Showing 2 changed files with 7 additions and 9 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -3,9 +3,9 @@
* file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file
* to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the
* License. You may obtain a copy of the License at
*
*
* http://www.apache.org/licenses/LICENSE-2.0
*
*
* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on
* an "AS IS" BASIS, 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.
Expand All @@ -29,7 +29,6 @@
* @see KafkaConsumer
* @see MockConsumer
*/
@InterfaceStability.Unstable
public interface Consumer<K, V> extends Closeable {

/**
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -165,11 +165,11 @@
* In this example the client is subscribing to the topics <i>foo</i> and <i>bar</i> as part of a group of consumers
* called <i>test</i> as described above.
* <p>
* The broker will automatically detect failed processes in the <i>test</i> group by using a heartbeat mechanism. The
* consumer will automatically ping the cluster periodically, which lets the cluster know that it is alive. Note that
* the consumer is single-threaded, so periodic heartbeats can only be sent when {@link #poll(long)} is called. As long as
* the consumer is able to do this it is considered alive and retains the right to consume from the partitions assigned
* to it. If it stops heartbeating by failing to call {@link #poll(long)} for a period of time longer than <code>session.timeout.ms</code>
* The broker will automatically detect failed processes in the <i>test</i> group by using a heartbeat mechanism. The
* consumer will automatically ping the cluster periodically, which lets the cluster know that it is alive. Note that
* the consumer is single-threaded, so periodic heartbeats can only be sent when {@link #poll(long)} is called. As long as
* the consumer is able to do this it is considered alive and retains the right to consume from the partitions assigned
* to it. If it stops heartbeating by failing to call {@link #poll(long)} for a period of time longer than <code>session.timeout.ms</code>
* then it will be considered dead and its partitions will be assigned to another process.
* <p>
* The deserializer settings specify how to turn bytes into objects. For example, by specifying string deserializers, we
Expand Down Expand Up @@ -452,7 +452,6 @@
* commit.
*
*/
@InterfaceStability.Unstable
public class KafkaConsumer<K, V> implements Consumer<K, V> {

private static final Logger log = LoggerFactory.getLogger(KafkaConsumer.class);
Expand Down

0 comments on commit 99cfb99

Please sign in to comment.