tagSearchIndex = [{"l":"1. One Consumer Per Thread","h":"class org.apache.kafka.clients.consumer.KafkaConsumer","d":"Section","u":"org/apache/kafka/clients/consumer/KafkaConsumer.html#1-one-consumer-per-thread-heading"},{"l":"2. Decouple Consumption and Processing","h":"class org.apache.kafka.clients.consumer.KafkaConsumer","d":"Section","u":"org/apache/kafka/clients/consumer/KafkaConsumer.html#2-decouple-consumption-and-processing-heading"},{"l":"Acknowledging a batch of records (implicit acknowledgement)","h":"class org.apache.kafka.clients.consumer.KafkaShareConsumer","d":"Section","u":"org/apache/kafka/clients/consumer/KafkaShareConsumer.html#acknowledging-a-batch-of-records-implicit-acknowledgement--heading"},{"l":"Automatic Offset Committing","h":"class org.apache.kafka.clients.consumer.KafkaConsumer","d":"Section","u":"org/apache/kafka/clients/consumer/KafkaConsumer.html#automatic-offset-committing-heading"},{"l":"Bootstrap and balancing","h":"interface org.apache.kafka.clients.admin.Admin","d":"Section","u":"org/apache/kafka/clients/admin/Admin.html#bootstrap-and-balancing-heading"},{"l":"Broker","h":"interface org.apache.kafka.common.ClusterResourceListener","d":"Section","u":"org/apache/kafka/common/ClusterResourceListener.html#broker-heading"},{"l":"Broker Compatibility","h":"interface org.apache.kafka.clients.admin.Admin","d":"Section","u":"org/apache/kafka/clients/admin/Admin.html#broker-compatibility-heading"},{"l":"Clients","h":"interface org.apache.kafka.common.ClusterResourceListener","d":"Section","u":"org/apache/kafka/common/ClusterResourceListener.html#clients-heading"},{"l":"Collecting branches in a single scope","h":"interface org.apache.kafka.streams.kstream.BranchedKStream","d":"Section","u":"org/apache/kafka/streams/kstream/BranchedKStream.html#collecting-branches-in-a-single-scope-heading"},{"l":"Constant Field Values","h":"","u":"constant-values.html"},{"l":"Consumer Groups and Topic Subscriptions","h":"class org.apache.kafka.clients.consumer.KafkaConsumer","d":"Section","u":"org/apache/kafka/clients/consumer/KafkaConsumer.html#consumer-groups-and-topic-subscriptions-heading"},{"l":"Consumption Flow Control","h":"class org.apache.kafka.clients.consumer.KafkaConsumer","d":"Section","u":"org/apache/kafka/clients/consumer/KafkaConsumer.html#consumption-flow-control-heading"},{"l":"Controlling The Consumer's Position","h":"class org.apache.kafka.clients.consumer.KafkaConsumer","d":"Section","u":"org/apache/kafka/clients/consumer/KafkaConsumer.html#controlling-the-consumer-s-position-heading"},{"l":"Cross-Version Compatibility","h":"class org.apache.kafka.clients.consumer.KafkaConsumer","d":"Section","u":"org/apache/kafka/clients/consumer/KafkaConsumer.html#cross-version-compatibility-heading"},{"l":"Cross-Version Compatibility","h":"class org.apache.kafka.clients.consumer.KafkaShareConsumer","d":"Section","u":"org/apache/kafka/clients/consumer/KafkaShareConsumer.html#cross-version-compatibility-heading"},{"l":"Detecting Consumer Failures","h":"class org.apache.kafka.clients.consumer.KafkaConsumer","d":"Section","u":"org/apache/kafka/clients/consumer/KafkaConsumer.html#detecting-consumer-failures-heading"},{"l":"Detecting Consumer Failures","h":"class org.apache.kafka.clients.consumer.KafkaShareConsumer","d":"Section","u":"org/apache/kafka/clients/consumer/KafkaShareConsumer.html#detecting-consumer-failures-heading"},{"l":"Direct Branch Consuming","h":"interface org.apache.kafka.streams.kstream.BranchedKStream","d":"Section","u":"org/apache/kafka/streams/kstream/BranchedKStream.html#direct-branch-consuming-heading"},{"l":"Driver setup","h":"class org.apache.kafka.streams.TopologyTestDriver","d":"Section","u":"org/apache/kafka/streams/TopologyTestDriver.html#driver-setup-heading"},{"l":"Dynamic branching","h":"interface org.apache.kafka.streams.kstream.BranchedKStream","d":"Section","u":"org/apache/kafka/streams/kstream/BranchedKStream.html#dynamic-branching-heading"},{"l":"Impact on ConsumerRebalanceListener","h":"class org.apache.kafka.clients.consumer.StickyAssignor","d":"Section","u":"org/apache/kafka/clients/consumer/StickyAssignor.html#impact-on-consumerrebalancelistener-heading"},{"l":"Manual Offset Control","h":"class org.apache.kafka.clients.consumer.KafkaConsumer","d":"Section","u":"org/apache/kafka/clients/consumer/KafkaConsumer.html#manual-offset-control-heading"},{"l":"Manual Partition Assignment","h":"class org.apache.kafka.clients.consumer.KafkaConsumer","d":"Section","u":"org/apache/kafka/clients/consumer/KafkaConsumer.html#manual-partition-assignment-heading"},{"l":"Multithreaded Processing","h":"class org.apache.kafka.clients.consumer.KafkaShareConsumer","d":"Section","u":"org/apache/kafka/clients/consumer/KafkaShareConsumer.html#multithreaded-processing-heading"},{"l":"Multi-threaded Processing","h":"class org.apache.kafka.clients.consumer.KafkaConsumer","d":"Section","u":"org/apache/kafka/clients/consumer/KafkaConsumer.html#multi-threaded-processing-heading"},{"l":"Offsets and Consumer Position","h":"class org.apache.kafka.clients.consumer.KafkaConsumer","d":"Section","u":"org/apache/kafka/clients/consumer/KafkaConsumer.html#offsets-and-consumer-position-heading"},{"l":"Per-record acknowledgement (explicit acknowledgement)","h":"class org.apache.kafka.clients.consumer.KafkaShareConsumer","d":"Section","u":"org/apache/kafka/clients/consumer/KafkaShareConsumer.html#per-record-acknowledgement-explicit-acknowledgement--heading"},{"l":"Per-record acknowledgement, ending processing of the batch on an error (explicit acknowledgement)","h":"class org.apache.kafka.clients.consumer.KafkaShareConsumer","d":"Section","u":"org/apache/kafka/clients/consumer/KafkaShareConsumer.html#per-record-acknowledgement-ending-processing-of-the-batch-on-an-error-explicit-acknowledgement--heading"},{"l":"Processing messages","h":"class org.apache.kafka.streams.TestInputTopic","d":"Section","u":"org/apache/kafka/streams/TestInputTopic.html#processing-messages-heading"},{"l":"Processing messages","h":"class org.apache.kafka.streams.TopologyTestDriver","d":"Section","u":"org/apache/kafka/streams/TopologyTestDriver.html#processing-messages-heading"},{"l":"Processing records","h":"class org.apache.kafka.streams.TestOutputTopic","d":"Section","u":"org/apache/kafka/streams/TestOutputTopic.html#processing-records-heading"},{"l":"Processor state","h":"class org.apache.kafka.streams.TopologyTestDriver","d":"Section","u":"org/apache/kafka/streams/TopologyTestDriver.html#processor-state-heading"},{"l":"Reading Transactional Messages","h":"class org.apache.kafka.clients.consumer.KafkaConsumer","d":"Section","u":"org/apache/kafka/clients/consumer/KafkaConsumer.html#reading-transactional-messages-heading"},{"l":"Reading Transactional Records","h":"class org.apache.kafka.clients.consumer.KafkaShareConsumer","d":"Section","u":"org/apache/kafka/clients/consumer/KafkaShareConsumer.html#reading-transactional-records-heading"},{"l":"Record Delivery and Acknowledgement","h":"class org.apache.kafka.clients.consumer.KafkaShareConsumer","d":"Section","u":"org/apache/kafka/clients/consumer/KafkaShareConsumer.html#record-delivery-and-acknowledgement-heading"},{"l":"Relation to CompletionStage","h":"class org.apache.kafka.common.KafkaFuture","d":"Section","u":"org/apache/kafka/common/KafkaFuture.html#relation-to-completionstage-heading"},{"l":"Rules of forming the resulting map","h":"interface org.apache.kafka.streams.kstream.BranchedKStream","d":"Section","u":"org/apache/kafka/streams/kstream/BranchedKStream.html#rules-of-forming-the-resulting-map-heading"},{"l":"Serialized Form","h":"","u":"serialized-form.html"},{"l":"Share Groups and Topic Subscriptions","h":"class org.apache.kafka.clients.consumer.KafkaShareConsumer","d":"Section","u":"org/apache/kafka/clients/consumer/KafkaShareConsumer.html#share-groups-and-topic-subscriptions-heading"},{"l":"Storing Offsets Outside Kafka","h":"class org.apache.kafka.clients.consumer.KafkaConsumer","d":"Section","u":"org/apache/kafka/clients/consumer/KafkaConsumer.html#storing-offsets-outside-kafka-heading"},{"l":"Usage examples","h":"interface org.apache.kafka.streams.kstream.BranchedKStream","d":"Section","u":"org/apache/kafka/streams/kstream/BranchedKStream.html#usage-examples-heading"},{"l":"Usage Examples","h":"class org.apache.kafka.clients.consumer.KafkaConsumer","d":"Section","u":"org/apache/kafka/clients/consumer/KafkaConsumer.html#usage-examples-heading"},{"l":"Usage Examples","h":"class org.apache.kafka.clients.consumer.KafkaShareConsumer","d":"Section","u":"org/apache/kafka/clients/consumer/KafkaShareConsumer.html#usage-examples-heading"}];updateSearchResults();