kafka API Manual
Method
- abortTransaction()
- abortTransaction()
- abortTransaction()
- accept(A, B)
- accepts(StateStore)
- add(Header)
- add(String, byte[])
- addClientSaslSupport(ConfigDef)
- addClientSslSupport(ConfigDef)
- addDeserializerToConfig(Map<String, Object>, Deserializer<?>, Deserializer<?>)
- addDeserializerToConfig(Properties, Deserializer<?>, Deserializer<?>)
- addErrorMessage(String)
- addGlobalStore(StateStoreSupplier<KeyValueStore>, String, Deserializer, Deserializer, String, String, ProcessorSupplier)
- addGlobalStore(StateStoreSupplier<KeyValueStore>, String, TimestampExtractor, Deserializer, Deserializer, String, String, ProcessorSupplier)
- addGlobalStore(StateStoreSupplier<KeyValueStore>, String, Deserializer, Deserializer, String, String, ProcessorSupplier)
- addGlobalStore(StateStoreSupplier<KeyValueStore>, String, TimestampExtractor, Deserializer, Deserializer, String, String, ProcessorSupplier)
- addGlobalStore(StateStoreSupplier<KeyValueStore>, String, Deserializer, Deserializer, String, String, ProcessorSupplier)
- addGlobalStore(StateStoreSupplier<KeyValueStore>, String, TimestampExtractor, Deserializer, Deserializer, String, String, ProcessorSupplier)
- addInternalTopic(String)
- addLatencyAndThroughputSensor(String, String, String, Sensor.RecordingLevel, String...)
- addProcessor(String, ProcessorSupplier, String...)
- addProcessor(String, ProcessorSupplier, String...)
- addRecord(ConsumerRecord<K, V>)
- addSensor(String, Sensor.RecordingLevel)
- addSensor(String, Sensor.RecordingLevel, Sensor...)
- addSerializerToConfig(Map<String, Object>, Serializer<?>, Serializer<?>)
- addSerializerToConfig(Properties, Serializer<?>, Serializer<?>)
- addSink(String, String, String...)
- addSink(String, String, StreamPartitioner, String...)
- addSink(String, String, Serializer, Serializer, String...)
- addSink(String, String, Serializer<K>, Serializer<V>, StreamPartitioner<? super K, ? super V>, String...)
- addSink(String, String, String...)
- addSink(String, String, StreamPartitioner, String...)
- addSink(String, String, Serializer, Serializer, String...)
- addSink(String, String, Serializer<K>, Serializer<V>, StreamPartitioner<? super K, ? super V>, String...)
- addSource(String, String...)
- addSource(TopologyBuilder.AutoOffsetReset, String, String...)
- addSource(TimestampExtractor, String, String...)
- addSource(TopologyBuilder.AutoOffsetReset, TimestampExtractor, String, String...)
- addSource(String, Pattern)
- addSource(TopologyBuilder.AutoOffsetReset, String, Pattern)
- addSource(TimestampExtractor, String, Pattern)
- addSource(TopologyBuilder.AutoOffsetReset, TimestampExtractor, String, Pattern)
- addSource(String, Deserializer, Deserializer, String...)
- addSource(TopologyBuilder.AutoOffsetReset, String, TimestampExtractor, Deserializer, Deserializer, String...)
- addSource(String, Deserializer, Deserializer, Pattern)
- addSource(TopologyBuilder.AutoOffsetReset, String, TimestampExtractor, Deserializer, Deserializer, Pattern)
- addSource(TopologyBuilder.AutoOffsetReset, String, Deserializer, Deserializer, Pattern)
- addSource(String, String...)
- addSource(String, Pattern)
- addSource(Topology.AutoOffsetReset, String, String...)
- addSource(Topology.AutoOffsetReset, String, Pattern)
- addSource(TimestampExtractor, String, String...)
- addSource(TimestampExtractor, String, Pattern)
- addSource(Topology.AutoOffsetReset, TimestampExtractor, String, String...)
- addSource(Topology.AutoOffsetReset, TimestampExtractor, String, Pattern)
- addSource(String, Deserializer, Deserializer, String...)
- addSource(String, Deserializer, Deserializer, Pattern)
- addSource(Topology.AutoOffsetReset, String, Deserializer, Deserializer, String...)
- addSource(Topology.AutoOffsetReset, String, Deserializer, Deserializer, Pattern)
- addSource(Topology.AutoOffsetReset, String, TimestampExtractor, Deserializer, Deserializer, String...)
- addSource(Topology.AutoOffsetReset, String, TimestampExtractor, Deserializer, Deserializer, Pattern)
- addStateStore(StateStoreSupplier, String...)
- addStateStore(StateStoreSupplier, String...)
- addStateStore(StateStoreSupplier, String...)
- addThroughputSensor(String, String, String, Sensor.RecordingLevel, String...)
- addWaiter(KafkaFuture.BiConsumer<? super T, ? super Throwable>)
- advanceBy(long)
- after(long)
- aggregate(Initializer<VR>, Aggregator<? super K, ? super V, VR>, Serde<VR>, String)
- aggregate(Initializer<VR>, Aggregator<? super K, ? super V, VR>, Serde<VR>)
- aggregate(Initializer<VR>, Aggregator<? super K, ? super V, VR>, StateStoreSupplier<KeyValueStore>)
- aggregate(Initializer<VR>, Aggregator<? super K, ? super V, VR>, Windows<W>, Serde<VR>, String)
- aggregate(Initializer<VR>, Aggregator<? super K, ? super V, VR>, Windows<W>, Serde<VR>)
- aggregate(Initializer<VR>, Aggregator<? super K, ? super V, VR>, Windows<W>, StateStoreSupplier<WindowStore>)
- aggregate(Initializer<T>, Aggregator<? super K, ? super V, T>, Merger<? super K, T>, SessionWindows, Serde<T>, String)
- aggregate(Initializer<T>, Aggregator<? super K, ? super V, T>, Merger<? super K, T>, SessionWindows, Serde<T>)
- aggregate(Initializer<T>, Aggregator<? super K, ? super V, T>, Merger<? super K, T>, SessionWindows, Serde<T>, StateStoreSupplier<SessionStore>)
- aggregate(Initializer<VR>, Aggregator<? super K, ? super V, VR>, Aggregator<? super K, ? super V, VR>, String)
- aggregate(Initializer<VR>, Aggregator<? super K, ? super V, VR>, Aggregator<? super K, ? super V, VR>)
- aggregate(Initializer<VR>, Aggregator<? super K, ? super V, VR>, Aggregator<? super K, ? super V, VR>, Serde<VR>, String)
- aggregate(Initializer<VR>, Aggregator<? super K, ? super V, VR>, Aggregator<? super K, ? super V, VR>, Serde<VR>)
- aggregate(Initializer<VR>, Aggregator<? super K, ? super V, VR>, Aggregator<? super K, ? super V, VR>, StateStoreSupplier<KeyValueStore>)
- all()
- all()
- all()
- all()
- all()
- all()
- all()
- all()
- allMetadata()
- allMetadataForStore(String)
- allOf(KafkaFuture<?>...)
- allPartitionsSorted(Map<String, Integer>, Map<String, PartitionAssignor.Subscription>)
- alterConfigs(Map<ConfigResource, Config>)
- alterConfigs(Map<ConfigResource, Config>, AlterConfigsOptions)
- alterConfigs(Map<ConfigResource, Config>, AlterConfigsOptions)
- appConfigs()
- appConfigsWithPrefix(String)
- applicationId()
- apply(A)
- apply(R)
- apply(K, V, VA)
- apply(K, V)
- apply()
- apply(K, V)
- apply(K, V, V)
- apply(K, V)
- apply(V, V)
- apply(V1, V2)
- apply(V)
- approximateNumEntries()
- array(Schema)
- assign(Collection<TopicPartition>)
- assign(Collection<TopicPartition>)
- assign(Collection<TopicPartition>)
- assign(Map<String, Integer>, Map<String, PartitionAssignor.Subscription>)
- assign(Map<String, Integer>, Map<String, PartitionAssignor.Subscription>)
- assign(Map<String, Integer>, Map<String, PartitionAssignor.Subscription>)
- assignment()
- assignment()
- assignment()
- assignment()
- atLeast(Number)
- availablePartitionsForTopic(String)
- before(long)
- beginningOffsets(Collection<TopicPartition>)
- beginningOffsets(Collection<TopicPartition>)
- beginningOffsets(Collection<TopicPartition>)
- beginTransaction()
- beginTransaction()
- beginTransaction()
- between(Number, Number)
- binding()
- bool()
- bootstrap(List<InetSocketAddress>)
- branch(Predicate<? super K, ? super V>...)
- build()
- build(Integer)
- build()
- build()
- build()
- builder()
- builder(int)
- builder()
- builder()
- buildGlobalStateTopology()
- ByteArray()
- ByteBuffer()
- Bytes()
- bytes()
- cancel(boolean)
- cancel()
- checksum()
- checksum()
- cleanUp()
- clear()
- close()
- close(long, TimeUnit)
- close(long, TimeUnit)
- close()
- close(long, TimeUnit)
- close()
- close()
- close(long, TimeUnit)
- close()
- close(long, TimeUnit)
- close()
- close(long, TimeUnit)
- close()
- close(long, TimeUnit)
- close()
- close()
- close(long, TimeUnit)
- close()
- close()
- close()
- close()
- close()
- close()
- close()
- close()
- close()
- close()
- close()
- close()
- close()
- close()
- close()
- close()
- close()
- close()
- close()
- close()
- close()
- close()
- close()
- close()
- close()
- close(Collection<TopicPartition>)
- close()
- close()
- close(long, TimeUnit)
- close()
- close()
- close()
- close()
- close()
- close()
- close()
- close()
- closed()
- closed()
- clusterId()
- clusterId()
- clusterResource()
- code()
- code()
- code()
- commit()
- commit()
- commitAsync()
- commitAsync(OffsetCommitCallback)
- commitAsync(Map<TopicPartition, OffsetAndMetadata>, OffsetCommitCallback)
- commitAsync()
- commitAsync(OffsetCommitCallback)
- commitAsync(Map<TopicPartition, OffsetAndMetadata>, OffsetCommitCallback)
- commitAsync(Map<TopicPartition, OffsetAndMetadata>, OffsetCommitCallback)
- commitAsync()
- commitAsync(OffsetCommitCallback)
- commitCount()
- commitRecord(SourceRecord)
- commitSync()
- commitSync(Map<TopicPartition, OffsetAndMetadata>)
- commitSync()
- commitSync(Map<TopicPartition, OffsetAndMetadata>)
- commitSync(Map<TopicPartition, OffsetAndMetadata>)
- commitSync()
- committed(TopicPartition)
- committed(TopicPartition)
- committed(TopicPartition)
- commitTransaction()
- commitTransaction()
- commitTransaction()
- compareTo(TaskId)
- complete(T)
- completedFuture(U)
- completeExceptionally(Throwable)
- completeNext()
- config()
- config()
- configDef()
- configKeys()
- configNames()
- configNames()
- configNames()
- configs(Map<String, String>)
- configs()
- configs()
- configure(Map<String, ?>)
- configure(Map<String, ?>, boolean)
- configure(Map<String, ?>, boolean)
- configure(Map<String, ?>, boolean)
- configure(Map<String, ?>, boolean)
- configure(Map<String, ?>, boolean)
- configure(Map<String, ?>, boolean)
- configure(Map<String, ?>, boolean)
- configure(Map<String, ?>, boolean)
- configure(Map<String, ?>, boolean)
- configure(Map<String, ?>, boolean)
- configure(Map<String, ?>, boolean)
- configure(Map<String, ?>, boolean)
- configure(Map<String, ?>, boolean)
- configure(Map<String, ?>, boolean)
- configure(Map<String, ?>, boolean)
- configure(Map<String, ?>, boolean)
- configure(Map<String, ?>, boolean)
- configure(Map<String, ?>, boolean)
- configure(Map<String, ?>, boolean)
- configure(Map<String, ?>, boolean)
- configure(Map<String, ?>, boolean)
- configure(Map<String, ?>, boolean)
- configure(Map<String, ?>, boolean)
- configure(Map<String, ?>, boolean)
- configure(Map<String, ?>, boolean)
- configure(Map<String, ?>, boolean)
- configure(Map<String, ?>)
- configure(Map<String, ?>)
- configValues()
- connectProcessorAndStateStores(String, String...)
- connectProcessorAndStateStores(String, String...)
- connectProcessors(String...)
- connectSourceStoreAndTopic(String, String)
- consumerGroupOffsetsHistory()
- consumerPrefix(String)
- context()
- controller()
- controller()
- convertToString(Object, ConfigDef.Type)
- copartitionGroups()
- copartitionSources(Collection<String>)
- count()
- count(String)
- count()
- count(StateStoreSupplier<KeyValueStore>)
- count(Windows<W>, String)
- count(Windows<W>)
- count(Windows<W>, StateStoreSupplier<WindowStore>)
- count(SessionWindows, String)
- count(SessionWindows)
- count(SessionWindows, StateStoreSupplier<SessionStore>)
- count(String)
- count()
- count(StateStoreSupplier<KeyValueStore>)
- create(Properties)
- create(Map<String, Object>)
- create(StateStoreProvider, String)
- create(String)
- createAcls(Collection<AclBinding>)
- createAcls(Collection<AclBinding>, CreateAclsOptions)
- createAcls(Collection<AclBinding>, CreateAclsOptions)
- createTopics(Collection<NewTopic>)
- createTopics(Collection<NewTopic>, CreateTopicsOptions)
- createTopics(Collection<NewTopic>, CreateTopicsOptions)
- defaultDeserializationExceptionHandler()
- defaultKeySerde()
- defaultTimestampExtractor()
- defaultValue()
- defaultValue()
- defaultValue()
- defaultValue(Object)
- defaultValueSerde()
- define(ConfigDef.ConfigKey)
- define(String, ConfigDef.Type, Object, ConfigDef.Validator, ConfigDef.Importance, String, String, int, ConfigDef.Width, String, List<String>, ConfigDef.Recommender)
- define(String, ConfigDef.Type, Object, ConfigDef.Validator, ConfigDef.Importance, String, String, int, ConfigDef.Width, String, List<String>)
- define(String, ConfigDef.Type, Object, ConfigDef.Validator, ConfigDef.Importance, String, String, int, ConfigDef.Width, String, ConfigDef.Recommender)
- define(String, ConfigDef.Type, Object, ConfigDef.Validator, ConfigDef.Importance, String, String, int, ConfigDef.Width, String)
- define(String, ConfigDef.Type, Object, ConfigDef.Importance, String, String, int, ConfigDef.Width, String, List<String>, ConfigDef.Recommender)
- define(String, ConfigDef.Type, Object, ConfigDef.Importance, String, String, int, ConfigDef.Width, String, List<String>)
- define(String, ConfigDef.Type, Object, ConfigDef.Importance, String, String, int, ConfigDef.Width, String, ConfigDef.Recommender)
- define(String, ConfigDef.Type, Object, ConfigDef.Importance, String, String, int, ConfigDef.Width, String)
- define(String, ConfigDef.Type, ConfigDef.Importance, String, String, int, ConfigDef.Width, String, List<String>, ConfigDef.Recommender)
- define(String, ConfigDef.Type, ConfigDef.Importance, String, String, int, ConfigDef.Width, String, List<String>)
- define(String, ConfigDef.Type, ConfigDef.Importance, String, String, int, ConfigDef.Width, String, ConfigDef.Recommender)
- define(String, ConfigDef.Type, ConfigDef.Importance, String, String, int, ConfigDef.Width, String)
- define(String, ConfigDef.Type, Object, ConfigDef.Validator, ConfigDef.Importance, String)
- define(String, ConfigDef.Type, Object, ConfigDef.Importance, String)
- define(String, ConfigDef.Type, ConfigDef.Importance, String)
- defineInternal(String, ConfigDef.Type, Object, ConfigDef.Importance)
- delete(K)
- deleteAcls(Collection<AclBindingFilter>)
- deleteAcls(Collection<AclBindingFilter>, DeleteAclsOptions)
- deleteAcls(Collection<AclBindingFilter>, DeleteAclsOptions)
- deleteTopics(Collection<String>)
- deleteTopics(Collection<String>, DeleteTopicsOptions)
- deleteTopics(Collection<String>, DeleteTopicsOptions)
- describe()
- describeAcls(AclBindingFilter)
- describeAcls(AclBindingFilter, DescribeAclsOptions)
- describeAcls(AclBindingFilter, DescribeAclsOptions)
- describeCluster()
- describeCluster(DescribeClusterOptions)
- describeCluster(DescribeClusterOptions)
- describeConfigs(Collection<ConfigResource>)
- describeConfigs(Collection<ConfigResource>, DescribeConfigsOptions)
- describeConfigs(Collection<ConfigResource>, DescribeConfigsOptions)
- describeTopics(Collection<String>)
- describeTopics(Collection<String>, DescribeTopicsOptions)
- describeTopics(Collection<String>, DescribeTopicsOptions)
- description()
- description()
- deserialize(String, byte[])
- deserialize(String, byte[])
- deserialize(String, byte[])
- deserialize(String, byte[])
- deserialize(String, byte[])
- deserialize(String, Headers, byte[])
- deserialize(String, Headers, byte[])
- deserialize(String, byte[])
- deserialize(String, byte[])
- deserialize(String, byte[])
- deserialize(String, byte[])
- deserialize(String, byte[])
- deserialize(String, byte[])
- deserializer()
- deserializer()
- disableLogging()
- disableLogging()
- doc()
- doc()
- doc()
- doc(String)
- Double()
- earliestResetTopicsPattern()
- embed(String, String, int, ConfigDef)
- empty()
- empty()
- enableCaching()
- enableLogging(Map<String, String>)
- enableLogging(Map<String, String>)
- end()
- endOffsets(Collection<TopicPartition>)
- endOffsets(Collection<TopicPartition>)
- endOffsets(Collection<TopicPartition>)
- ensureExtended(Deserializer<T>)
- ensureExtended(Serializer<T>)
- ensureValid(String, Object)
- ensureValid(String, Object)
- ensureValid(String, Object)
- ensureValid(String, Object)
- ensureValid(String, Object)
- entries()
- entry()
- entryFilter()
- equals(Object)
- equals(Object)
- equals(Object)
- equals(Object)
- equals(Object)
- equals(Object)
- equals(Object)
- equals(Object)
- equals(Object)
- equals(Object)
- equals(Object)
- equals(Object)
- equals(Object)
- equals(Object)
- equals(Object)
- equals(Object)
- equals(Object)
- equals(Object)
- equals(Object)
- equals(Object)
- equals(Object)
- equals(Object)
- equals(Object)
- equals(Object)
- equals(Object)
- equals(Object)
- equals(Object)
- equals(Object)
- equals(Object)
- equals(Object)
- equals(Object)
- equals(Object)
- equals(Object)
- errorMessages()
- errorNext(RuntimeException)
- exception()
- extract(ConsumerRecord<Object, Object>, long)
- extract(ConsumerRecord<Object, Object>, long)
- fenceProducer()
- fetch(K)
- fetch(K, K)
- fetch(K, long, long)
- fetch(K, K, long, long)
- field(String)
- field(String)
- field(String, Schema)
- field(String)
- fields()
- fields()
- fields()
- fillInStackTrace()
- fillInStackTrace()
- filter(Predicate<? super K, ? super V>)
- filter(Predicate<? super K, ? super V>)
- filter(Predicate<? super K, ? super V>, String)
- filter(Predicate<? super K, ? super V>, StateStoreSupplier<KeyValueStore>)
- filterNot(Predicate<? super K, ? super V>)
- filterNot(Predicate<? super K, ? super V>)
- filterNot(Predicate<? super K, ? super V>, StateStoreSupplier<KeyValueStore>)
- filterNot(Predicate<? super K, ? super V>, String)
- findIndefiniteField()
- findIndefiniteField()
- findIndefiniteField()
- findSessions(K, long, long)
- findSessions(K, K, long, long)
- flatMap(KeyValueMapper<? super K, ? super V, ? extends Iterable<? extends KeyValue<? extends KR, ? extends VR>>>)
- flatMapValues(ValueMapper<? super V, ? extends Iterable<? extends VR>>)
- Float()
- float32()
- float64()
- flush()
- flush()
- flush()
- flush(Map<TopicPartition, OffsetAndMetadata>)
- flush()
- flushed()
- foreach(ForeachAction<? super K, ? super V>)
- foreach(ForeachAction<? super K, ? super V>)
- forward(K, V)
- forward(K, V, int)
- forward(K, V, String)
- fromCode(byte)
- fromCode(byte)
- fromCode(byte)
- fromConnectData(String, Schema, Object)
- fromConnectData(String, Schema, Object)
- fromLogical(Schema, Date)
- fromLogical(Schema, BigDecimal)
- fromLogical(Schema, Date)
- fromLogical(Schema, Date)
- fromString(String)
- fromString(String)
- fromString(String)
- get(String)
- get(String)
- get()
- get(long, TimeUnit)
- get(String)
- get(Field)
- get()
- get()
- get()
- get()
- get(K)
- getArray(String)
- getBoolean(String)
- getBoolean(String)
- getBytes(String)
- getClass(String)
- getConfiguredInstance(String, Class<T>)
- getConfiguredInstances(String, Class<T>)
- getConfiguredInstances(String, Class<T>, Map<String, Object>)
- getConfigValue(ConfigDef.ConfigKey, String)
- getConsumer(Map<String, Object>)
- getConsumerConfigs(StreamThread, String, String)
- getDouble(String)
- getFloat32(String)
- getFloat64(String)
- getInt(String)
- getInt16(String)
- getInt32(String)
- getInt64(String)
- getInt8(String)
- getList(String)
- getLong(String)
- getMap(String)
- getName()
- getNow(T)
- getPassword(String)
- getProducer(Map<String, Object>)
- getProducerConfigs(String)
- getRestoreConsumer(Map<String, Object>)
- getRestoreConsumerConfigs(String)
- getShort(String)
- getStateStore(String)
- getString(String)
- getString(String)
- getStruct(String)
- getWithoutDefault(String)
- globalStateStores()
- globalStores()
- globalTable(String, String)
- globalTable(String)
- globalTable(Serde<K>, Serde<V>, TimestampExtractor, String, String)
- globalTable(Serde<K>, Serde<V>, String, StateStoreSupplier<KeyValueStore>)
- globalTable(Serde<K>, Serde<V>, String, String)
- globalTable(Serde<K>, Serde<V>, String)
- globalTable(String, String)
- globalTable(String)
- globalTable(Serde<K>, Serde<V>, TimestampExtractor, String, String)
- globalTable(Serde<K>, Serde<V>, String, StateStoreSupplier<KeyValueStore>)
- globalTable(Serde<K>, Serde<V>, String, String)
- globalTable(Serde<K>, Serde<V>, String)
- group()
- group()
- groupBy(KeyValueMapper<? super K, ? super V, KR>)
- groupBy(KeyValueMapper<? super K, ? super V, KR>, Serde<KR>, Serde<V>)
- groupBy(KeyValueMapper<? super K, ? super V, KeyValue<KR, VR>>)
- groupBy(KeyValueMapper<? super K, ? super V, KeyValue<KR, VR>>, Serde<KR>, Serde<VR>)
- groupByKey()
- groupByKey(Serde<K>, Serde<V>)
- groupId()
- groupPartitions(List<T>, int)
- groups()
- handle(ProcessorContext, ConsumerRecord<byte[], byte[]>, Exception)
- handle(ProcessorContext, ConsumerRecord<byte[], byte[]>, Exception)
- handle(ProcessorContext, ConsumerRecord<byte[], byte[]>, Exception)
- hasDefault()
- hashCode()
- hashCode()
- hashCode()
- hashCode()
- hashCode()
- hashCode()
- hashCode()
- hashCode()
- hashCode()
- hashCode()
- hashCode()
- hashCode()
- hashCode()
- hashCode()
- hashCode()
- hashCode()
- hashCode()
- hashCode()
- hashCode()
- hashCode()
- hashCode()
- hashCode()
- hashCode()
- hashCode()
- hashCode()
- hashCode()
- hashCode()
- hashCode()
- hashCode()
- hashCode()
- hashCode()
- hashCode()
- hashCode()
- hasRack()
- headers()
- headers()
- headers()
- headers(String)
- history()
- host()
- host()
- host()
- host()
- host()
- hostInfo()
- id()
- id()
- idString()
- ignore(String)
- in(String...)
- in(String...)
- inactivityGap()
- index()
- init(ProcessorContext)
- init(ProcessorContext)
- init(ProcessorContext)
- init(ProcessorContext)
- init(ProcessorContext, StateStore)
- initialize(ConnectorContext)
- initialize(ConnectorContext, List<Map<String, String>>)
- initialize(SinkTaskContext)
- initialize(SourceTaskContext)
- initTransactions()
- initTransactions()
- initTransactions()
- inMemory()
- inSyncReplicas()
- int16()
- int32()
- int64()
- int8()
- Integer()
- internalTopics()
- isBootstrapConfigured()
- isCancelled()
- isCompletedExceptionally()
- isCreatedOrRunning()
- isDefault()
- isDone()
- isEmpty()
- isEmpty()
- isInternal()
- isInternal()
- isOpen()
- isOptional()
- isOptional()
- isOptional()
- isPrimitive()
- isr()
- isReadOnly()
- isRunning()
- isSensitive()
- isUnknown()
- isUnknown()
- isUnknown()
- isUnknown()
- isUnknown()
- isUnknown()
- isUnknown()
- isUnknown()
- isUnknown()
- isValidTransition(KafkaStreams.State)
- iterator()
- join(KStream<K, VO>, ValueJoiner<? super V, ? super VO, ? extends VR>, JoinWindows)
- join(KStream<K, VO>, ValueJoiner<? super V, ? super VO, ? extends VR>, JoinWindows, Serde<K>, Serde<V>, Serde<VO>)
- join(KTable<K, VT>, ValueJoiner<? super V, ? super VT, ? extends VR>)
- join(KTable<K, VT>, ValueJoiner<? super V, ? super VT, ? extends VR>, Serde<K>, Serde<V>)
- join(GlobalKTable<GK, GV>, KeyValueMapper<? super K, ? super V, ? extends GK>, ValueJoiner<? super V, ? super GV, ? extends RV>)
- join(KTable<K, VO>, ValueJoiner<? super V, ? super VO, ? extends VR>)
- join(KTable<K, VO>, ValueJoiner<? super V, ? super VO, ? extends VR>, Serde<VR>, String)
- join(KTable<K, VO>, ValueJoiner<? super V, ? super VO, ? extends VR>, StateStoreSupplier<KeyValueStore>)
- kafkaOffset()
- kafkaPartition()
- key()
- key()
- key()
- key()
- key()
- keyDeserializer()
- keyFrom(byte[])
- keySchema()
- keySchema()
- keySchema()
- keySchema()
- keySerde()
- keySerde()
- keySerde()
- keySerializer()
- keyValueStore()
- lastHeader(String)
- latestResetTopicsPattern()
- leader()
- leader()
- leaderFor(TopicPartition)
- leftJoin(KStream<K, VO>, ValueJoiner<? super V, ? super VO, ? extends VR>, JoinWindows)
- leftJoin(KStream<K, VO>, ValueJoiner<? super V, ? super VO, ? extends VR>, JoinWindows, Serde<K>, Serde<V>, Serde<VO>)
- leftJoin(KTable<K, VT>, ValueJoiner<? super V, ? super VT, ? extends VR>)
- leftJoin(KTable<K, VT>, ValueJoiner<? super V, ? super VT, ? extends VR>, Serde<K>, Serde<V>)
- leftJoin(GlobalKTable<GK, GV>, KeyValueMapper<? super K, ? super V, ? extends GK>, ValueJoiner<? super V, ? super GV, ? extends RV>)
- leftJoin(KTable<K, VO>, ValueJoiner<? super V, ? super VO, ? extends VR>)
- leftJoin(KTable<K, VO>, ValueJoiner<? super V, ? super VO, ? extends VR>, Serde<VR>, String)
- leftJoin(KTable<K, VO>, ValueJoiner<? super V, ? super VO, ? extends VR>, StateStoreSupplier<KeyValueStore>)
- listings()
- listInternal(boolean)
- listTopics()
- listTopics(ListTopicsOptions)
- listTopics(ListTopicsOptions)
- listTopics()
- listTopics()
- listTopics()
- logConfig()
- loggingEnabled()
- logUnused()
- Long()
- main(String[])
- main(String[])
- main(String[])
- main(String[])
- maintainMs()
- maintainMs()
- maintainMs()
- maintainMs()
- maintainMs()
- map(Schema, Schema)
- map(KeyValueMapper<? super K, ? super V, ? extends KeyValue<? extends KR, ? extends VR>>)
- mapValues(ValueMapper<? super V, ? extends VR>)
- mapValues(ValueMapper<? super V, ? extends VR>)
- mapValues(ValueMapper<? super V, ? extends VR>, Serde<VR>, String)
- mapValues(ValueMapper<? super V, ? extends VR>, Serde<VR>, StateStoreSupplier<KeyValueStore>)
- matches(AccessControlEntry)
- matches(AclBinding)
- matches(Resource)
- matchesAtMostOne()
- matchesAtMostOne()
- matchesAtMostOne()
- maxEntries(int)
- maxNumPartitions(Cluster, Set<String>)
- merge(KStream<K, V>...)
- merge(KStream<K, V>...)
- metadata()
- metadataForKey(String, K, Serializer<K>)
- metadataForKey(String, K, StreamPartitioner<? super K, ?>)
- metricName()
- metrics()
- metrics()
- metrics()
- metrics()
- metrics()
- metrics()
- metrics()
- metrics()
- metrics()
- name()
- name()
- name()
- name()
- name()
- name()
- name()
- name()
- name()
- name()
- name()
- name()
- name()
- name()
- name()
- name()
- name()
- name(String)
- name()
- name()
- name()
- names()
- names()
- namesToListings()
- newName(String)
- newRecord(String, Integer, Schema, Object, Schema, Object, Long)
- newRecord(String, Integer, Schema, Object, Schema, Object, Long)
- newRecord(String, Integer, Schema, Object, Schema, Object, Long)
- newStoreName(String)
- nodeById(int)
- nodeGroups()
- nodes()
- nodes()
- nodes()
- noNode()
- numPartitions()
- numPartitions()
- of(long)
- of(long)
- of()
- offlineReplicas()
- offset()
- offset()
- offset()
- offset()
- offset(Map<TopicPartition, Long>)
- offset(TopicPartition, long)
- offset(Map<String, T>)
- offset()
- offsetOutOfRangePartitions()
- offsets(Collection<Map<String, T>>)
- offsetsForTimes(Map<TopicPartition, Long>)
- offsetsForTimes(Map<TopicPartition, Long>)
- offsetsForTimes(Map<TopicPartition, Long>)
- offsetStorageReader()
- onAcknowledgement(RecordMetadata, Exception)
- onAssignment(PartitionAssignor.Assignment)
- onBatchRestored(TopicPartition, String, long, long)
- onBatchRestored(TopicPartition, String, long, long)
- onBatchRestored(TopicPartition, String, long, long)
- onChange(KafkaStreams.State, KafkaStreams.State)
- onCommit(Map<TopicPartition, OffsetAndMetadata>)
- onComplete(Map<TopicPartition, OffsetAndMetadata>, Exception)
- onCompletion(RecordMetadata, Exception)
- onConsume(ConsumerRecords<K, V>)
- onInvalidTimestamp(ConsumerRecord<Object, Object>, long, long)
- onInvalidTimestamp(ConsumerRecord<Object, Object>, long, long)
- onInvalidTimestamp(ConsumerRecord<Object, Object>, long, long)
- onPartitionsAssigned(Collection<TopicPartition>)
- onPartitionsAssigned(Collection<TopicPartition>)
- onPartitionsRevoked(Collection<TopicPartition>)
- onPartitionsRevoked(Collection<TopicPartition>)
- onRestoreEnd(TopicPartition, String, long)
- onRestoreEnd(TopicPartition, String, long)
- onRestoreEnd(TopicPartition, String, long)
- onRestoreStart(TopicPartition, String, long, long)
- onRestoreStart(TopicPartition, String, long, long)
- onRestoreStart(TopicPartition, String, long, long)
- onSend(ProducerRecord<K, V>)
- onUpdate(ClusterResource)
- open(Collection<TopicPartition>)
- operation()
- operation()
- optional()
- originals()
- originalsStrings()
- originalsWithPrefix(String)
- outerJoin(KStream<K, VO>, ValueJoiner<? super V, ? super VO, ? extends VR>, JoinWindows)
- outerJoin(KStream<K, VO>, ValueJoiner<? super V, ? super VO, ? extends VR>, JoinWindows, Serde<K>, Serde<V>, Serde<VO>)
- outerJoin(KTable<K, VO>, ValueJoiner<? super V, ? super VO, ? extends VR>)
- outerJoin(KTable<K, VO>, ValueJoiner<? super V, ? super VO, ? extends VR>, Serde<VR>, String)
- outerJoin(KTable<K, VO>, ValueJoiner<? super V, ? super VO, ? extends VR>, StateStoreSupplier<KeyValueStore>)
- overlap(Window)
- pair(K, V)
- parameter(String, String)
- parameters()
- parameters()
- parameters()
- parameters(Map<String, String>)
- parse(Map<?, ?>)
- parse(String)
- parseType(String, Object, ConfigDef.Type)
- partition()
- partition()
- partition(String, Object, byte[], Object, byte[], Cluster)
- partition()
- partition()
- partition(TopicPartition)
- partition()
- partition()
- partition()
- partition()
- partition(K, V, int)
- partitionCountForTopic(String)
- partitionGroups(Map<Integer, Set<String>>, Cluster)
- partitionGroups(Map<Integer, Set<String>>, Cluster)
- partitions()
- partitions()
- partitions()
- partitions()
- partitions()
- partitionsFor(String)
- partitionsFor(String)
- partitionsFor(String)
- partitionsFor(String)
- partitionsFor(String)
- partitionsFor(String)
- partitionsForNode(int)
- partitionsForTopic(String)
- pause(Collection<TopicPartition>)
- pause(Collection<TopicPartition>)
- pause(Collection<TopicPartition>)
- pause(TopicPartition...)
- paused()
- paused()
- paused()
- peek(ForeachAction<? super K, ? super V>)
- peekNextKey()
- permissionType()
- permissionType()
- persistent()
- persistent()
- poll(long)
- poll(long)
- poll(long)
- poll()
- port()
- port()
- port()
- position(TopicPartition)
- position(TopicPartition)
- position(TopicPartition)
- postProcessParsedConfig(Map<String, Object>)
- postProcessParsedConfig(Map<String, Object>)
- postProcessParsedConfig(Map<String, Object>)
- postProcessParsedConfig(Map<String, Object>)
- postProcessParsedConfig(Map<String, Object>)
- preCommit(Map<TopicPartition, OffsetAndMetadata>)
- predecessors()
- principal()
- principal()
- print()
- print(String)
- print(Serde<K>, Serde<V>)
- print(Serde<K>, Serde<V>, String)
- print(KeyValueMapper<? super K, ? super V, String>)
- print(KeyValueMapper<? super K, ? super V, String>, String)
- print(KeyValueMapper<? super K, ? super V, String>, Serde<K>, Serde<V>)
- print(KeyValueMapper<? super K, ? super V, String>, Serde<K>, Serde<V>, String)
- print()
- print(String)
- print(Serde<K>, Serde<V>)
- print(Serde<K>, Serde<V>, String)
- process(ProcessorSupplier<? super K, ? super V>, String...)
- process(K, V)
- processor()
- producerPrefix(String)
- project(Schema, Object, Schema)
- punctuate(long)
- punctuate(long)
- punctuate(long)
- punctuate(long)
- punctuate(long)
- put(String, Object)
- put(Field, Object)
- put(Collection<SinkRecord>)
- put(K, V)
- put(Windowed<K>, AGG)
- put(K, V)
- put(K, V, long)
- putAll(List<KeyValue<K, V>>)
- putIfAbsent(K, V)
- queryableStoreName()
- rack()
- raiseError(Exception)
- range(K, K)
- rawKey(K)
- rawValue(V)
- readFrom(DataInputStream)
- readFrom(ByteBuffer)
- rebalance(Collection<TopicPartition>)
- recommendedValues()
- recommendedValues(List<Object>)
- reconfigure(Map<String, String>)
- recordLatency(Sensor, long, long)
- records(TopicPartition)
- records(String)
- recordThroughput(Sensor, long)
- recordTooLargePartitions()
- reduce(Reducer<V>)
- reduce(Reducer<V>, String)
- reduce(Reducer<V>, StateStoreSupplier<KeyValueStore>)
- reduce(Reducer<V>, Windows<W>, String)
- reduce(Reducer<V>, Windows<W>)
- reduce(Reducer<V>, Windows<W>, StateStoreSupplier<WindowStore>)
- reduce(Reducer<V>, SessionWindows, String)
- reduce(Reducer<V>, SessionWindows)
- reduce(Reducer<V>, SessionWindows, StateStoreSupplier<SessionStore>)
- reduce(Reducer<V>, Reducer<V>, String)
- reduce(Reducer<V>, Reducer<V>)
- reduce(Reducer<V>, Reducer<V>, StateStoreSupplier<KeyValueStore>)
- register(StateStore, boolean, StateRestoreCallback)
- remove(String)
- remove(Windowed<K>)
- removeSensor(Sensor)
- replicas()
- replicas()
- replicasAssignments()
- replicasAssignments()
- replicationFactor()
- replicationFactor()
- requestCommit()
- requestTaskReconfiguration()
- required()
- resource()
- resource()
- resourceFilter()
- resourceType()
- resourceType()
- restore(byte[], byte[])
- restore(byte[], byte[])
- restoreAll(Collection<KeyValue<byte[], byte[]>>)
- resume(Collection<TopicPartition>)
- resume(Collection<TopicPartition>)
- resume(Collection<TopicPartition>)
- resume(TopicPartition...)
- schedule(long, PunctuationType, Punctuator)
- schedule(long)
- scheduleNopPollTask()
- schedulePollTask(Runnable)
- schema()
- schema(int)
- schema()
- schema()
- schema()
- schema()
- schema()
- schemaType(Class<?>)
- seek(TopicPartition, long)
- seek(TopicPartition, long)
- seek(TopicPartition, long)
- seekToBeginning(Collection<TopicPartition>)
- seekToBeginning(Collection<TopicPartition>)
- seekToBeginning(Collection<TopicPartition>)
- seekToEnd(Collection<TopicPartition>)
- seekToEnd(Collection<TopicPartition>)
- seekToEnd(Collection<TopicPartition>)
- segments(int)
- selectKey(KeyValueMapper<? super K, ? super V, ? extends KR>)
- send(ProducerRecord<K, V>)
- send(ProducerRecord<K, V>, Callback)
- send(ProducerRecord<K, V>)
- send(ProducerRecord<K, V>, Callback)
- send(ProducerRecord<K, V>)
- send(ProducerRecord<K, V>, Callback)
- sendOffsetsToTransaction(Map<TopicPartition, OffsetAndMetadata>, String)
- sendOffsetsToTransaction(Map<TopicPartition, OffsetAndMetadata>, String)
- sendOffsetsToTransaction(Map<TopicPartition, OffsetAndMetadata>, String)
- sentOffsets()
- serdeFrom(Class<T>)
- serdeFrom(Serializer<T>, Deserializer<T>)
- serialize(String, byte[])
- serialize(String, ByteBuffer)
- serialize(String, Bytes)
- serialize(String, Double)
- serialize(String, Headers, T)
- serialize(String, Headers, T)
- serialize(String, T)
- serialize(String, Float)
- serialize(String, Integer)
- serialize(String, Long)
- serialize(String, T)
- serialize(String, Short)
- serialize(String, String)
- serializedKeySize()
- serializedKeySize()
- serializedValueSize()
- serializedValueSize()
- serializer()
- serializer()
- sessionStore()
- sessionWindowed(long)
- setApplicationId(String)
- setConfig(String, Options, Map<String, Object>)
- setException(KafkaException)
- setGlobalStateRestoreListener(StateRestoreListener)
- setStateListener(KafkaStreams.StateListener)
- setUncaughtExceptionHandler(Thread.UncaughtExceptionHandler)
- Short()
- shouldListInternal()
- shouldValidateOnly()
- shouldValidateOnly()
- size()
- size()
- size()
- size()
- source()
- sourceOffset()
- sourcePartition()
- sourceTopicPattern()
- start(Map<String, String>)
- start(Map<String, String>)
- start(Map<String, String>)
- start(Map<String, String>)
- start()
- start()
- startOn(long)
- state()
- stateDir()
- stateStoreNames()
- stateStoreNameToSourceTopics()
- stop()
- stop()
- stop()
- stop()
- store(String, QueryableStoreType<T>)
- stores()
- stream(String...)
- stream(TopologyBuilder.AutoOffsetReset, String...)
- stream(Pattern)
- stream(TopologyBuilder.AutoOffsetReset, Pattern)
- stream(Serde<K>, Serde<V>, String...)
- stream(TopologyBuilder.AutoOffsetReset, Serde<K>, Serde<V>, String...)
- stream(TimestampExtractor, Serde<K>, Serde<V>, String...)
- stream(TopologyBuilder.AutoOffsetReset, TimestampExtractor, Serde<K>, Serde<V>, String...)
- stream(Serde<K>, Serde<V>, Pattern)
- stream(TopologyBuilder.AutoOffsetReset, Serde<K>, Serde<V>, Pattern)
- stream(TimestampExtractor, Serde<K>, Serde<V>, Pattern)
- stream(TopologyBuilder.AutoOffsetReset, TimestampExtractor, Serde<K>, Serde<V>, Pattern)
- stream(String...)
- stream(Topology.AutoOffsetReset, String...)
- stream(Pattern)
- stream(Topology.AutoOffsetReset, Pattern)
- stream(Serde<K>, Serde<V>, String...)
- stream(Topology.AutoOffsetReset, Serde<K>, Serde<V>, String...)
- stream(TimestampExtractor, Serde<K>, Serde<V>, String...)
- stream(Topology.AutoOffsetReset, TimestampExtractor, Serde<K>, Serde<V>, String...)
- stream(Serde<K>, Serde<V>, Pattern)
- stream(Topology.AutoOffsetReset, Serde<K>, Serde<V>, Pattern)
- stream(TimestampExtractor, Serde<K>, Serde<V>, Pattern)
- stream(Topology.AutoOffsetReset, TimestampExtractor, Serde<K>, Serde<V>, Pattern)
- String()
- string()
- struct()
- subscribe(Collection<String>)
- subscribe(Collection<String>, ConsumerRebalanceListener)
- subscribe(Pattern, ConsumerRebalanceListener)
- subscribe(Collection<String>, ConsumerRebalanceListener)
- subscribe(Collection<String>)
- subscribe(Pattern, ConsumerRebalanceListener)
- subscribe(Collection<String>)
- subscribe(Pattern, ConsumerRebalanceListener)
- subscribe(Collection<String>, ConsumerRebalanceListener)
- subscription()
- subscription()
- subscription()
- subscription(Set<String>)
- subscriptionUpdates()
- subtopologies()
- successors()
- table(String, String)
- table(String, StateStoreSupplier<KeyValueStore>)
- table(String)
- table(TopologyBuilder.AutoOffsetReset, String, String)
- table(TopologyBuilder.AutoOffsetReset, String, StateStoreSupplier<KeyValueStore>)
- table(TopologyBuilder.AutoOffsetReset, String)
- table(TimestampExtractor, String, String)
- table(TopologyBuilder.AutoOffsetReset, TimestampExtractor, String, String)
- table(Serde<K>, Serde<V>, String, String)
- table(Serde<K>, Serde<V>, String, StateStoreSupplier<KeyValueStore>)
- table(Serde<K>, Serde<V>, String)
- table(TopologyBuilder.AutoOffsetReset, Serde<K>, Serde<V>, String, String)
- table(TimestampExtractor, Serde<K>, Serde<V>, String, String)
- table(TopologyBuilder.AutoOffsetReset, TimestampExtractor, Serde<K>, Serde<V>, String, String)
- table(TopologyBuilder.AutoOffsetReset, Serde<K>, Serde<V>, String)
- table(TopologyBuilder.AutoOffsetReset, TimestampExtractor, Serde<K>, Serde<V>, String, StateStoreSupplier<KeyValueStore>)
- table(String, String)
- table(String, StateStoreSupplier<KeyValueStore>)
- table(String)
- table(Topology.AutoOffsetReset, String, String)
- table(Topology.AutoOffsetReset, String, StateStoreSupplier<KeyValueStore>)
- table(Topology.AutoOffsetReset, String)
- table(TimestampExtractor, String, String)
- table(Topology.AutoOffsetReset, TimestampExtractor, String, String)
- table(Serde<K>, Serde<V>, String, String)
- table(Serde<K>, Serde<V>, String, StateStoreSupplier<KeyValueStore>)
- table(Serde<K>, Serde<V>, String)
- table(Topology.AutoOffsetReset, Serde<K>, Serde<V>, String, String)
- table(TimestampExtractor, Serde<K>, Serde<V>, String, String)
- table(Topology.AutoOffsetReset, TimestampExtractor, Serde<K>, Serde<V>, String, String)
- table(Topology.AutoOffsetReset, Serde<K>, Serde<V>, String)
- table(Topology.AutoOffsetReset, TimestampExtractor, Serde<K>, Serde<V>, String, StateStoreSupplier<KeyValueStore>)
- tags()
- tags()
- taskClass()
- taskConfigs(int)
- taskId()
- test(K, V)
- thenApply(KafkaFuture.Function<T, R>)
- through(String)
- through(StreamPartitioner<? super K, ? super V>, String)
- through(Serde<K>, Serde<V>, String)
- through(Serde<K>, Serde<V>, StreamPartitioner<? super K, ? super V>, String)
- through(String, String)
- through(String, StateStoreSupplier<KeyValueStore>)
- through(String)
- through(StreamPartitioner<? super K, ? super V>, String)
- through(StreamPartitioner<? super K, ? super V>, String, String)
- through(StreamPartitioner<? super K, ? super V>, String, StateStoreSupplier<KeyValueStore>)
- through(Serde<K>, Serde<V>, String, String)
- through(Serde<K>, Serde<V>, String, StateStoreSupplier<KeyValueStore>)
- through(Serde<K>, Serde<V>, String)
- through(Serde<K>, Serde<V>, StreamPartitioner<? super K, ? super V>, String, String)
- through(Serde<K>, Serde<V>, StreamPartitioner<? super K, ? super V>, String, StateStoreSupplier<KeyValueStore>)
- through(Serde<K>, Serde<V>, StreamPartitioner<? super K, ? super V>, String)
- timeout(long)
- timeoutMs(Integer)
- timeoutMs()
- timeoutMs(Integer)
- timeoutMs()
- timeoutMs(Integer)
- timeoutMs()
- timeoutMs(Integer)
- timeoutMs()
- timeoutMs(Integer)
- timeoutMs()
- timeoutMs(Integer)
- timeoutMs()
- timeoutMs(Integer)
- timeoutMs()
- timeoutMs(Integer)
- timeoutMs()
- timeoutMs(Integer)
- timeoutMs()
- timeoutMs(Integer)
- timeoutMs()
- timestamp()
- timestamp()
- timestamp()
- timestamp()
- timestamp()
- timestamp()
- timestampType()
- timestampType()
- to(String)
- to(StreamPartitioner<? super K, ? super V>, String)
- to(Serde<K>, Serde<V>, String)
- to(Serde<K>, Serde<V>, StreamPartitioner<? super K, ? super V>, String)
- to(String)
- to(StreamPartitioner<? super K, ? super V>, String)
- to(Serde<K>, Serde<V>, String)
- to(Serde<K>, Serde<V>, StreamPartitioner<? super K, ? super V>, String)
- toArray()
- toConnectData(String, byte[])
- toConnectData(String, byte[])
- toEnrichedRst()
- toFilter()
- toFilter()
- toFilter()
- toHtmlTable()
- toLogical(Schema, int)
- toLogical(Schema, byte[])
- toLogical(Schema, int)
- toLogical(Schema, long)
- topic()
- topic()
- topic()
- topic()
- topic()
- topic()
- topic()
- topic()
- topic()
- topic()
- topicGroups()
- topicPartitions()
- topicPrefix(String)
- topics()
- topics()
- toRst()
- toStream()
- toStream(KeyValueMapper<? super K, ? super V, ? extends KR>)
- toString()
- toString()
- toString()
- toString()
- toString()
- toString()
- toString()
- toString()
- toString()
- toString()
- toString()
- toString()
- toString()
- toString()
- toString()
- toString()
- toString()
- toString()
- toString()
- toString()
- toString()
- toString()
- toString()
- toString()
- toString()
- toString()
- toString()
- toString()
- toString()
- toString()
- toString()
- toString()
- toString()
- toString()
- toString()
- toString()
- toString()
- toString()
- toString(String)
- toString()
- toString()
- toString()
- toString()
- toString()
- toString()
- toString()
- transactionAborted()
- transactionCommitted()
- transactionInFlight()
- transactionInitialized()
- transform(TransformerSupplier<? super K, ? super V, KeyValue<K1, V1>>, String...)
- transform(K, V)
- transform(V)
- transformValues(ValueTransformerSupplier<? super V, ? extends VR>, String...)
- type()
- type()
- type()
- type()
- type(Schema.Type)
- typeOf(String)
- unauthorizedTopics()
- unauthorizedTopics()
- unsubscribe()
- unsubscribe()
- unsubscribe()
- until(long)
- until(long)
- until(long)
- until(long)
- until(long)
- unused()
- updateBeginningOffsets(Map<TopicPartition, Long>)
- updateEndOffsets(Map<TopicPartition, Long>)
- updatePartitions(String, List<PartitionInfo>)
- updateSubscriptions(SubscriptionUpdates, String)
- validate(Map<String, String>)
- validate(Map<String, String>)
- validate()
- validate(AlterConfigPolicy.RequestMetadata)
- validate(CreateTopicPolicy.RequestMetadata)
- validateAll(Map<String, String>)
- validateOnly(boolean)
- validateOnly(boolean)
- validateValue(Schema, Object)
- validateValue(String, Schema, Object)
- validateValue(Object)
- validValues(String, Map<String, Object>)
- value()
- value()
- value()
- value()
- value(Object)
- value()
- value()
- value()
- value()
- valueDeserializer()
- valueFrom(byte[])
- valueOf(String)
- valueOf(String)
- valueOf(String)
- valueOf(String)
- valueOf(String)
- valueOf(String)
- valueOf(String)
- valueOf(String)
- valueOf(String)
- valueOf(String)
- valueOf(String)
- valueOf(String)
- valueOf(String)
- valueOf(String)
- values()
- values()
- values()
- values()
- values()
- values()
- values()
- values()
- values()
- values()
- values()
- values()
- values()
- values()
- values()
- values()
- values()
- values()
- values()
- values()
- values()
- values()
- values()
- values()
- valueSchema()
- valueSchema()
- valueSchema()
- valueSchema()
- valueSerde()
- valueSerde()
- valueSerde()
- valueSerializer()
- valuesWithPrefixOverride(String)
- version()
- version()
- version()
- version()
- version()
- version(Integer)
- visible(String, Map<String, Object>)
- visible()
- visible(boolean)
- wakeup()
- wakeup()
- wakeup()
- window()
- windowed(long, long, int, boolean)
- windowsFor(long)
- windowsFor(long)
- windowsFor(long)
- windowsFor(long)
- windowStore()
- with(long)
- withBuiltinTypes(String, Class<K>, Class<V>)
- withByteArrayKeys()
- withByteArrayValues()
- withByteBufferKeys()
- withByteBufferValues()
- withClientSaslSupport()
- withClientSslSupport()
- withDoubleKeys()
- withDoubleValues()
- withIntegerKeys()
- withIntegerValues()
- withKeys(Class<K>)
- withKeys(Serde<K>)
- withLongKeys()
- withLongValues()
- withPartitions(Map<TopicPartition, PartitionInfo>)
- withStringKeys()
- withStringValues()
- withUnderlyingMessage(String)
- withValues(Class<V>)
- withValues(Serde<V>)
- writeAsText(String)
- writeAsText(String, String)
- writeAsText(String, Serde<K>, Serde<V>)
- writeAsText(String, String, Serde<K>, Serde<V>)
- writeAsText(String, KeyValueMapper<? super K, ? super V, String>)
- writeAsText(String, String, KeyValueMapper<? super K, ? super V, String>)
- writeAsText(String, Serde<K>, Serde<V>, KeyValueMapper<? super K, ? super V, String>)
- writeAsText(String, String, Serde<K>, Serde<V>, KeyValueMapper<? super K, ? super V, String>)
- writeAsText(String)
- writeAsText(String, String)
- writeAsText(String, Serde<K>, Serde<V>)
- writeAsText(String, String, Serde<K>, Serde<V>)
- writeTo(DataOutputStream)
- writeTo(ByteBuffer)
Class
Constructor
- AbstractConfig(ConfigDef, Map<?, ?>, boolean)
- AbstractConfig(ConfigDef, Map<?, ?>)
- AbstractNotifyingBatchingRestoreCallback()
- AbstractNotifyingRestoreCallback()
- AbstractProcessor()
- AccessControlEntry(String, String, AclOperation, AclPermissionType)
- AccessControlEntryFilter(String, String, AclOperation, AclPermissionType)
- AclBinding(Resource, AccessControlEntry)
- AclBindingFilter(ResourceFilter, AccessControlEntryFilter)
- AdminClient()
- AdminClientConfig(Map<?, ?>)
- AlreadyExistsException(String)
- AlreadyExistsException(String, Throwable)
- AlreadyExistsException(Throwable)
- AlterConfigsOptions()
- ApiException(String, Throwable)
- ApiException(String)
- ApiException(Throwable)
- ApiException()
- AuthenticationException(String)
- AuthenticationException(String, Throwable)
- AuthorizationException(String)
- AuthorizationException(String, Throwable)
- BiConsumer()
- BrokerNotAvailableException(String)
- BrokerNotAvailableException(String, Throwable)
- BrokerNotFoundException(String)
- BrokerNotFoundException(String, Throwable)
- BrokerNotFoundException(Throwable)
- BufferExhaustedException(String)
- ByteArrayDeserializer()
- ByteArraySerde()
- ByteArraySerializer()
- ByteBufferDeserializer()
- ByteBufferSerde()
- ByteBufferSerializer()
- BytesDeserializer()
- BytesSerde()
- BytesSerializer()
- Cluster(String, Collection<Node>, Collection<PartitionInfo>, Set<String>, Set<String>)
- Cluster(String, Collection<Node>, Collection<PartitionInfo>, Set<String>, Set<String>, Node)
- ClusterAuthorizationException(String)
- ClusterAuthorizationException(String, Throwable)
- ClusterResource(String)
- CommitFailedException()
- ConcurrentTransactionsException(String)
- Config(Collection<ConfigEntry>)
- Config(List<ConfigValue>)
- ConfigDef()
- ConfigDef(ConfigDef)
- ConfigEntry(String, String)
- ConfigEntry(String, String, boolean, boolean, boolean)
- ConfigException(String)
- ConfigException(String, Object)
- ConfigException(String, Object, String)
- ConfigKey(String, ConfigDef.Type, Object, ConfigDef.Validator, ConfigDef.Importance, String, String, int, ConfigDef.Width, String, List<String>, ConfigDef.Recommender, boolean)
- ConfigResource(ConfigResource.Type, String)
- ConfigValue(String)
- ConfigValue(String, Object, List<Object>, List<String>)
- ConnectException(String)
- ConnectException(String, Throwable)
- ConnectException(Throwable)
- Connector()
- ConnectorUtils()
- ConnectRecord(String, Integer, Schema, Object, Schema, Object, Long)
- ConnectSchema(Schema.Type, boolean, Object, String, Integer, String, Map<String, String>, List<Field>, Schema, Schema)
- ConnectSchema(Schema.Type, boolean, Object, String, Integer, String)
- ConnectSchema(Schema.Type)
- ConsumerRecord(String, int, long, K, V)
- ConsumerRecord(String, int, long, long, TimestampType, long, int, int, K, V)
- ConsumerRecord(String, int, long, long, TimestampType, Long, int, int, K, V, Headers)
- ConsumerRecords(Map<TopicPartition, List<ConsumerRecord<K, V>>>)
- ControllerMovedException(String)
- ControllerMovedException(String, Throwable)
- CoordinatorLoadInProgressException(String)
- CoordinatorLoadInProgressException(String, Throwable)
- CoordinatorNotAvailableException(String)
- CoordinatorNotAvailableException(String, Throwable)
- CorruptRecordException()
- CorruptRecordException(String)
- CorruptRecordException(Throwable)
- CorruptRecordException(String, Throwable)
- CreateAclsOptions()
- CreateTopicsOptions()
- DataException(String)
- DataException(String, Throwable)
- DataException(Throwable)
- Date()
- Decimal()
- DefaultPartitionGrouper()
- DeleteAclsOptions()
- DeleteTopicsOptions()
- DescribeAclsOptions()
- DescribeClusterOptions()
- DescribeConfigsOptions()
- DescribeTopicsOptions()
- DisconnectException()
- DisconnectException(String, Throwable)
- DisconnectException(String)
- DisconnectException(Throwable)
- DoubleDeserializer()
- DoubleSerde()
- DoubleSerializer()
- DuplicateSequenceNumberException(String)
- FailOnInvalidTimestamp()
- Field(String, int, Schema)
- FloatDeserializer()
- FloatSerde()
- FloatSerializer()
- Function()
- GroupAuthorizationException(String)
- GroupCoordinatorNotAvailableException()
- GroupCoordinatorNotAvailableException(String)
- GroupCoordinatorNotAvailableException(String, Throwable)
- GroupCoordinatorNotAvailableException(Throwable)
- GroupLoadInProgressException()
- GroupLoadInProgressException(String)
- GroupLoadInProgressException(String, Throwable)
- GroupLoadInProgressException(Throwable)
- HostInfo(String, int)
- IllegalGenerationException()
- IllegalGenerationException(String, Throwable)
- IllegalGenerationException(String)
- IllegalGenerationException(Throwable)
- IllegalSaslStateException(String)
- IllegalSaslStateException(String, Throwable)
- IllegalWorkerStateException(String)
- IllegalWorkerStateException(String, Throwable)
- IllegalWorkerStateException(Throwable)
- InconsistentGroupProtocolException(String, Throwable)
- InconsistentGroupProtocolException(String)
- IntegerDeserializer()
- IntegerSerde()
- IntegerSerializer()
- InterfaceStability()
- InternalConfig()
- InterruptException(InterruptedException)
- InterruptException(String, InterruptedException)
- InterruptException(String)
- InvalidCommitOffsetSizeException(String, Throwable)
- InvalidCommitOffsetSizeException(String)
- InvalidConfigurationException(String)
- InvalidConfigurationException(String, Throwable)
- InvalidFetchSizeException(String)
- InvalidFetchSizeException(String, Throwable)
- InvalidGroupIdException(String, Throwable)
- InvalidGroupIdException(String)
- InvalidMetadataException()
- InvalidMetadataException(String)
- InvalidMetadataException(String, Throwable)
- InvalidMetadataException(Throwable)
- InvalidOffsetException(String)
- InvalidOffsetException(String)
- InvalidOffsetException(String, Throwable)
- InvalidPartitionsException(String)
- InvalidPartitionsException(String, Throwable)
- InvalidPidMappingException(String)
- InvalidReplicaAssignmentException(String)
- InvalidReplicaAssignmentException(String, Throwable)
- InvalidReplicationFactorException(String)
- InvalidReplicationFactorException(String, Throwable)
- InvalidRequestException(String)
- InvalidRequestException(String, Throwable)
- InvalidRequiredAcksException(String)
- InvalidSessionTimeoutException(String, Throwable)
- InvalidSessionTimeoutException(String)
- InvalidStateStoreException(String)
- InvalidStateStoreException(String, Throwable)
- InvalidStateStoreException(Throwable)
- InvalidTimestampException(String)
- InvalidTimestampException(String, Throwable)
- InvalidTopicException()
- InvalidTopicException(String, Throwable)
- InvalidTopicException(String)
- InvalidTopicException(Throwable)
- InvalidTxnStateException(String)
- InvalidTxnTimeoutException(String, Throwable)
- InvalidTxnTimeoutException(String)
- KafkaConsumer(Map<String, Object>)
- KafkaConsumer(Map<String, Object>, Deserializer<K>, Deserializer<V>)
- KafkaConsumer(Properties)
- KafkaConsumer(Properties, Deserializer<K>, Deserializer<V>)
- KafkaException(String, Throwable)
- KafkaException(String)
- KafkaException(Throwable)
- KafkaException()
- KafkaFuture()
- KafkaProducer(Map<String, Object>)
- KafkaProducer(Map<String, Object>, Serializer<K>, Serializer<V>)
- KafkaProducer(Properties)
- KafkaProducer(Properties, Serializer<K>, Serializer<V>)
- KafkaStorageException()
- KafkaStorageException(String)
- KafkaStorageException(Throwable)
- KafkaStorageException(String, Throwable)
- KafkaStreams(TopologyBuilder, Properties)
- KafkaStreams(TopologyBuilder, StreamsConfig)
- KafkaStreams(TopologyBuilder, StreamsConfig, KafkaClientSupplier)
- KafkaStreams(Topology, Properties)
- KafkaStreams(Topology, StreamsConfig)
- KafkaStreams(Topology, StreamsConfig, KafkaClientSupplier)
- KeyValue(K, V)
- KStreamBuilder()
- LeaderNotAvailableException(String)
- LeaderNotAvailableException(String, Throwable)
- ListTopicsOptions()
- LockException(String)
- LockException(String, Throwable)
- LockException(Throwable)
- LogAndContinueExceptionHandler()
- LogAndFailExceptionHandler()
- LogAndSkipOnInvalidTimestamp()
- LongDeserializer()
- LongSerde()
- LongSerializer()
- MetricName(String, String, String, Map<String, String>)
- MetricNameTemplate(String, String, String, Set<String>)
- MetricNameTemplate(String, String, String, String...)
- MockConsumer(OffsetResetStrategy)
- MockProducer(Cluster, boolean, Partitioner, Serializer<K>, Serializer<V>)
- MockProducer(boolean, Serializer<K>, Serializer<V>)
- MockProducer(boolean, Partitioner, Serializer<K>, Serializer<V>)
- MockProducer()
- NetworkException()
- NetworkException(String, Throwable)
- NetworkException(String)
- NetworkException(Throwable)
- NewTopic(String, int, short)
- NewTopic(String, Map<Integer, List<Integer>>)
- Node(int, String, int)
- Node(int, String, int, String)
- NonEmptyString()
- NoOffsetForPartitionException(TopicPartition)
- NoOffsetForPartitionException(Collection<TopicPartition>)
- NotControllerException(String)
- NotControllerException(String, Throwable)
- NotCoordinatorException(String)
- NotCoordinatorException(String, Throwable)
- NotCoordinatorForGroupException()
- NotCoordinatorForGroupException(String)
- NotCoordinatorForGroupException(String, Throwable)
- NotCoordinatorForGroupException(Throwable)
- NotEnoughReplicasAfterAppendException(String)
- NotEnoughReplicasException()
- NotEnoughReplicasException(String, Throwable)
- NotEnoughReplicasException(String)
- NotEnoughReplicasException(Throwable)
- NotFoundException(String)
- NotFoundException(String, Throwable)
- NotFoundException(Throwable)
- NotLeaderForPartitionException()
- NotLeaderForPartitionException(String)
- NotLeaderForPartitionException(Throwable)
- NotLeaderForPartitionException(String, Throwable)
- OffsetAndMetadata(long, String)
- OffsetAndMetadata(long)
- OffsetAndTimestamp(long, long)
- OffsetMetadataTooLarge()
- OffsetMetadataTooLarge(String)
- OffsetMetadataTooLarge(Throwable)
- OffsetMetadataTooLarge(String, Throwable)
- OffsetOutOfRangeException(Map<TopicPartition, Long>)
- OffsetOutOfRangeException(String)
- OffsetOutOfRangeException(String, Throwable)
- OperationNotAttemptedException(String)
- OutOfOrderSequenceException(String)
- PartitionInfo(String, int, Node, Node[], Node[])
- PartitionInfo(String, int, Node, Node[], Node[], Node[])
- PolicyViolationException(String)
- PolicyViolationException(String, Throwable)
- PrintForeachAction(PrintWriter, KeyValueMapper<? super K, ? super V, String>, String)
- ProcessorStateException(String)
- ProcessorStateException(String, Throwable)
- ProcessorStateException(Throwable)
- ProducerFencedException(String)
- ProducerRecord(String, Integer, Long, K, V, Iterable<Header>)
- ProducerRecord(String, Integer, Long, K, V)
- ProducerRecord(String, Integer, K, V, Iterable<Header>)
- ProducerRecord(String, Integer, K, V)
- ProducerRecord(String, K, V)
- ProducerRecord(String, V)
- QueryableStoreTypes()
- RangeAssignor()
- RebalanceInProgressException()
- RebalanceInProgressException(String, Throwable)
- RebalanceInProgressException(String)
- RebalanceInProgressException(Throwable)
- RecordBatchTooLargeException()
- RecordBatchTooLargeException(String, Throwable)
- RecordBatchTooLargeException(String)
- RecordBatchTooLargeException(Throwable)
- RecordMetadata(TopicPartition, long, long, long, Long, int, int)
- RecordMetadata(TopicPartition, long, long, long, long, int, int)
- RecordTooLargeException()
- RecordTooLargeException(String, Throwable)
- RecordTooLargeException(String)
- RecordTooLargeException(Throwable)
- RecordTooLargeException(String, Map<TopicPartition, Long>)
- ReplicaNotAvailableException(String)
- ReplicaNotAvailableException(String, Throwable)
- ReplicaNotAvailableException(Throwable)
- RequestMetadata(ConfigResource, Map<String, String>)
- RequestMetadata(String, Integer, Short, Map<Integer, List<Integer>>, Map<String, String>)
- Resource(ResourceType, String)
- ResourceFilter(ResourceType, String)
- RetriableCommitFailedException(Throwable)
- RetriableCommitFailedException(String)
- RetriableCommitFailedException(String, Throwable)
- RetriableException(String, Throwable)
- RetriableException(String)
- RetriableException(Throwable)
- RetriableException()
- RetriableException(String)
- RetriableException(String, Throwable)
- RetriableException(Throwable)
- RoundRobinAssignor()
- SaslConfigs()
- SchemaAndValue(Schema, Object)
- SchemaBuilder(Schema.Type)
- SchemaBuilderException(String)
- SchemaBuilderException(String, Throwable)
- SchemaBuilderException(Throwable)
- SchemaProjector()
- SchemaProjectorException(String)
- SchemaProjectorException(String, Throwable)
- SchemaProjectorException(Throwable)
- SecurityDisabledException(String)
- SecurityDisabledException(String, Throwable)
- Serdes()
- SerializationException(String, Throwable)
- SerializationException(String)
- SerializationException(Throwable)
- SerializationException()
- ShortDeserializer()
- ShortSerde()
- ShortSerializer()
- SinkConnector()
- SinkRecord(String, int, Schema, Object, Schema, Object, long)
- SinkRecord(String, int, Schema, Object, Schema, Object, long, Long, TimestampType)
- SinkTask()
- SourceConnector()
- SourceRecord(Map<String, ?>, Map<String, ?>, String, Integer, Schema, Object)
- SourceRecord(Map<String, ?>, Map<String, ?>, String, Schema, Object)
- SourceRecord(Map<String, ?>, Map<String, ?>, String, Schema, Object, Schema, Object)
- SourceRecord(Map<String, ?>, Map<String, ?>, String, Integer, Schema, Object, Schema, Object)
- SourceRecord(Map<String, ?>, Map<String, ?>, String, Integer, Schema, Object, Schema, Object, Long)
- SourceTask()
- SslConfigs()
- StateSerdes(String, Serde<K>, Serde<V>)
- StickyAssignor()
- StoreFactory()
- Stores()
- StreamsBuilder()
- StreamsConfig(Map<?, ?>)
- StreamsException(String)
- StreamsException(String, Throwable)
- StreamsException(Throwable)
- StreamsMetadata(HostInfo, Set<String>, Set<TopicPartition>)
- StringConverter()
- StringDeserializer()
- StringSerde()
- StringSerializer()
- Struct(Schema)
- TaskAssignmentException(String)
- TaskAssignmentException(String, Throwable)
- TaskAssignmentException(Throwable)
- TaskId(int, int)
- TaskIdFormatException(String)
- TaskIdFormatException(String, Throwable)
- TaskIdFormatException(Throwable)
- Time()
- TimeoutException()
- TimeoutException(String, Throwable)
- TimeoutException(String)
- TimeoutException(Throwable)
- Timestamp()
- TopicAuthorizationException(Set<String>)
- TopicAuthorizationException(String)
- TopicConfig()
- TopicDescription(String, boolean, List<TopicPartitionInfo>)
- TopicExistsException(String)
- TopicExistsException(String, Throwable)
- TopicListing(String, boolean)
- TopicPartition(String, int)
- TopicPartitionInfo(int, Node, List<Node>, List<Node>)
- TopicsInfo(Set<String>, Set<String>, Map<String, InternalTopicConfig>, Map<String, InternalTopicConfig>)
- Topology()
- TopologyBuilder()
- TopologyBuilderException(String)
- TopologyBuilderException(String, Throwable)
- TopologyBuilderException(Throwable)
- TopologyException(String)
- TopologyException(String, Throwable)
- TopologyException(Throwable)
- TransactionalIdAuthorizationException(String)
- TransactionCoordinatorFencedException(String)
- TransactionCoordinatorFencedException(String, Throwable)
- UnknownMemberIdException()
- UnknownMemberIdException(String, Throwable)
- UnknownMemberIdException(String)
- UnknownMemberIdException(Throwable)
- UnknownServerException()
- UnknownServerException(String)
- UnknownServerException(Throwable)
- UnknownServerException(String, Throwable)
- UnknownTopicOrPartitionException()
- UnknownTopicOrPartitionException(String)
- UnknownTopicOrPartitionException(Throwable)
- UnknownTopicOrPartitionException(String, Throwable)
- UnsupportedForMessageFormatException(String)
- UnsupportedForMessageFormatException(String, Throwable)
- UnsupportedSaslMechanismException(String)
- UnsupportedSaslMechanismException(String, Throwable)
- UnsupportedVersionException(String, Throwable)
- UnsupportedVersionException(String)
- UsePreviousTimeOnInvalidTimestamp()
- ValueFactory()
- WakeupException()
- WallclockTimestampExtractor()
- Window(long, long)
- Windowed(K, Window)
- Windows()
- Wrapper(Deserializer<T>)
- Wrapper(Serializer<T>)
- WrapperSerde(Serializer<T>, Deserializer<T>)
Field
Enumeration
Interface
Exception
Notation
Package
Method(1477)
Class(164)
Constructor(425)
Field(332)
Enumeration(14)
Interface(85)
Exception(95)
Notation(3)
Package(25)