Index (Oracle Database Transactional Event Queues Java API Reference)

A B C D E F G H I K L M N O P R S T U V W
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

A

abortTransaction() - Method in class org.oracle.okafka.clients.producer.KafkaProducer: Aborts the ongoing transaction.
abortTransaction(AbortTransactionSpec, AbortTransactionOptions) - Method in class org.oracle.okafka.clients.admin.KafkaAdminClient
ACKS_CONFIG - Static variable in class org.oracle.okafka.clients.producer.ProducerConfig: acks
addDeserializerToConfig(Map<String, Object>, Deserializer<?>, Deserializer<?>) - Static method in class org.oracle.okafka.clients.consumer.ConsumerConfig: Deprecated.
Since 2.7.0. This will be removed in a future major release.
addDeserializerToConfig(Properties, Deserializer<?>, Deserializer<?>) - Static method in class org.oracle.okafka.clients.consumer.ConsumerConfig: Deprecated.
Since 2.7.0. This will be removed in a future major release.
addSerializerToConfig(Map<String, Object>, Serializer<?>, Serializer<?>) - Static method in class org.oracle.okafka.clients.producer.ProducerConfig
addSerializerToConfig(Properties, Serializer<?>, Serializer<?>) - Static method in class org.oracle.okafka.clients.producer.ProducerConfig
Admin - Interface in org.oracle.okafka.clients.admin: The administrative client for Kafka, which supports managing and inspecting topics.
AdminClient - Class in org.oracle.okafka.clients.admin: The administrative client for Transactional Event Queues(TXEQ), which supports managing and inspecting topics.
AdminClient() - Constructor for class org.oracle.okafka.clients.admin.AdminClient
AdminClientConfig - Class in org.oracle.okafka.clients.admin: The AdminClient configuration class, which also contains constants for configuration entry names.
AdminClientConfig(Map<?, ?>) - Constructor for class org.oracle.okafka.clients.admin.AdminClientConfig
AdminClientConfig(Map<?, ?>, boolean) - Constructor for class org.oracle.okafka.clients.admin.AdminClientConfig
all() - Method in class org.oracle.okafka.clients.admin.DeleteTopicsResult: Return a future which succeeds only if all the topic deletions succeed.
ALLOW_AUTO_CREATE_TOPICS_CONFIG - Static variable in class org.oracle.okafka.clients.consumer.ConsumerConfig: allow.auto.create.topics
allPartitionsSorted(Map<String, Integer>, Map<String, ConsumerPartitionAssignor.Subscription>) - Method in class org.oracle.okafka.clients.consumer.TxEQAssignor
alterClientQuotas(Collection<ClientQuotaAlteration>) - Method in interface org.oracle.okafka.clients.admin.Admin: Alters client quota configurations with the specified alterations.
alterClientQuotas(Collection<ClientQuotaAlteration>, AlterClientQuotasOptions) - Method in interface org.oracle.okafka.clients.admin.Admin: Alters client quota configurations with the specified alterations.
alterClientQuotas(Collection<ClientQuotaAlteration>, AlterClientQuotasOptions) - Method in class org.oracle.okafka.clients.admin.KafkaAdminClient
alterConfigs(Map<ConfigResource, Config>) - Method in interface org.oracle.okafka.clients.admin.Admin: Deprecated.
Since 2.3. Use Admin.incrementalAlterConfigs(Map).
alterConfigs(Map<ConfigResource, Config>, AlterConfigsOptions) - Method in interface org.oracle.okafka.clients.admin.Admin: Deprecated.
Since 2.3. Use Admin.incrementalAlterConfigs(Map, AlterConfigsOptions).
alterConfigs(Map<ConfigResource, Config>, AlterConfigsOptions) - Method in class org.oracle.okafka.clients.admin.KafkaAdminClient
alterConsumerGroupOffsets(String, Map<TopicPartition, OffsetAndMetadata>) - Method in interface org.oracle.okafka.clients.admin.Admin: Alters offsets for the specified group.
alterConsumerGroupOffsets(String, Map<TopicPartition, OffsetAndMetadata>, AlterConsumerGroupOffsetsOptions) - Method in interface org.oracle.okafka.clients.admin.Admin: Alters offsets for the specified group.
alterConsumerGroupOffsets(String, Map<TopicPartition, OffsetAndMetadata>, AlterConsumerGroupOffsetsOptions) - Method in class org.oracle.okafka.clients.admin.KafkaAdminClient
alterPartitionReassignments(Map<TopicPartition, Optional<NewPartitionReassignment>>) - Method in interface org.oracle.okafka.clients.admin.Admin: Change the reassignments for one or more partitions.
alterPartitionReassignments(Map<TopicPartition, Optional<NewPartitionReassignment>>, AlterPartitionReassignmentsOptions) - Method in interface org.oracle.okafka.clients.admin.Admin: Change the reassignments for one or more partitions.
alterPartitionReassignments(Map<TopicPartition, Optional<NewPartitionReassignment>>, AlterPartitionReassignmentsOptions) - Method in class org.oracle.okafka.clients.admin.KafkaAdminClient
alterReplicaLogDirs(Map<TopicPartitionReplica, String>) - Method in interface org.oracle.okafka.clients.admin.Admin: Change the log directory for the specified replicas.
alterReplicaLogDirs(Map<TopicPartitionReplica, String>, AlterReplicaLogDirsOptions) - Method in interface org.oracle.okafka.clients.admin.Admin: Change the log directory for the specified replicas.
alterReplicaLogDirs(Map<TopicPartitionReplica, String>, AlterReplicaLogDirsOptions) - Method in class org.oracle.okafka.clients.admin.KafkaAdminClient
alterUserScramCredentials(List<UserScramCredentialAlteration>) - Method in interface org.oracle.okafka.clients.admin.Admin: Alter SASL/SCRAM credentials for the given users.
alterUserScramCredentials(List<UserScramCredentialAlteration>, AlterUserScramCredentialsOptions) - Method in interface org.oracle.okafka.clients.admin.Admin: Alter SASL/SCRAM credentials.
alterUserScramCredentials(List<UserScramCredentialAlteration>, AlterUserScramCredentialsOptions) - Method in class org.oracle.okafka.clients.admin.KafkaAdminClient
assign(Collection<TopicPartition>) - Method in class org.oracle.okafka.clients.consumer.KafkaConsumer: This method is not yet supported.
assign(Map<String, Integer>, Map<String, ConsumerPartitionAssignor.Subscription>) - Method in class org.oracle.okafka.clients.consumer.TxEQAssignor
assign(Map<String, Integer>, Map<String, ConsumerPartitionAssignor.Subscription>, int) - Method in class org.oracle.okafka.clients.consumer.TxEQAssignor
assignment() - Method in class org.oracle.okafka.clients.consumer.KafkaConsumer: Get the set of partitions currently assigned to this consumer using topic subscription.
AUTO_COMMIT_INTERVAL_MS_CONFIG - Static variable in class org.oracle.okafka.clients.consumer.ConsumerConfig: auto.commit.interval.ms
AUTO_OFFSET_RESET_CONFIG - Static variable in class org.oracle.okafka.clients.consumer.ConsumerConfig: auto.offset.reset
AUTO_OFFSET_RESET_DOC - Static variable in class org.oracle.okafka.clients.consumer.ConsumerConfig

B

BATCH_SIZE_CONFIG - Static variable in class org.oracle.okafka.clients.producer.ProducerConfig: batch.size
beginningOffsets(Collection<TopicPartition>) - Method in class org.oracle.okafka.clients.consumer.KafkaConsumer: This method is not yet supported.
beginningOffsets(Collection<TopicPartition>, Duration) - Method in class org.oracle.okafka.clients.consumer.KafkaConsumer: This method is not yet supported.
beginTransaction() - Method in class org.oracle.okafka.clients.producer.KafkaProducer: Should be called before the start of each new transaction.
BOOTSTRAP_SERVERS_CONFIG - Static variable in class org.oracle.okafka.clients.admin.AdminClientConfig: bootstrap.servers
BOOTSTRAP_SERVERS_CONFIG - Static variable in class org.oracle.okafka.clients.consumer.ConsumerConfig: bootstrap.servers
BOOTSTRAP_SERVERS_CONFIG - Static variable in class org.oracle.okafka.clients.producer.ProducerConfig: bootstrap.servers
BUFFER_MEMORY_CONFIG - Static variable in class org.oracle.okafka.clients.producer.ProducerConfig: buffer.memory

C

CHECK_CRCS_CONFIG - Static variable in class org.oracle.okafka.clients.consumer.ConsumerConfig: check.crcs
CLIENT_DNS_LOOKUP_CONFIG - Static variable in class org.oracle.okafka.clients.consumer.ConsumerConfig: client.dns.lookup
CLIENT_DNS_LOOKUP_CONFIG - Static variable in class org.oracle.okafka.clients.producer.ProducerConfig: client.dns.lookup
CLIENT_ID_CONFIG - Static variable in class org.oracle.okafka.clients.admin.AdminClientConfig
CLIENT_ID_CONFIG - Static variable in class org.oracle.okafka.clients.consumer.ConsumerConfig: client.id
CLIENT_ID_CONFIG - Static variable in class org.oracle.okafka.clients.producer.ProducerConfig: client.id
CLIENT_RACK_CONFIG - Static variable in class org.oracle.okafka.clients.consumer.ConsumerConfig: client.rack
clientInstanceId(Duration) - Method in class org.oracle.okafka.clients.admin.KafkaAdminClient
clientInstanceId(Duration) - Method in class org.oracle.okafka.clients.consumer.KafkaConsumer
clientInstanceId(Duration) - Method in class org.oracle.okafka.clients.producer.KafkaProducer
close() - Method in interface org.oracle.okafka.clients.admin.Admin: Close the Admin and release all associated resources.
close() - Method in class org.oracle.okafka.clients.admin.AdminClient: Close the AdminClient and release all associated resources.
close() - Method in class org.oracle.okafka.clients.consumer.KafkaConsumer: Tries to close the consumer cleanly.
close() - Method in class org.oracle.okafka.clients.producer.KafkaProducer: Close this producer.
close(long, TimeUnit) - Method in interface org.oracle.okafka.clients.admin.Admin: Deprecated.
Since 2.2. Use Admin.close(Duration) or Admin.close().
close(long, TimeUnit) - Method in class org.oracle.okafka.clients.admin.AdminClient: Close the AdminClient and release all associated resources.
close(long, TimeUnit) - Method in class org.oracle.okafka.clients.admin.KafkaAdminClient
close(long, TimeUnit) - Method in class org.oracle.okafka.clients.consumer.KafkaConsumer: Deprecated.
close(Duration) - Method in interface org.oracle.okafka.clients.admin.Admin: Close the Admin client and release all associated resources.
close(Duration) - Method in class org.oracle.okafka.clients.admin.KafkaAdminClient
close(Duration) - Method in class org.oracle.okafka.clients.consumer.KafkaConsumer: Tries to close the consumer cleanly.
close(Duration) - Method in class org.oracle.okafka.clients.producer.KafkaProducer: This method waits up to timeout for the producer to complete the sending of all incomplete requests.
commitAsync() - Method in class org.oracle.okafka.clients.consumer.KafkaConsumer: Commit mesages consumed using KafkaConsumer.poll(Duration) for the subscribed topic and assigned partition in this session since last commit.
commitAsync(Map<TopicPartition, OffsetAndMetadata>, OffsetCommitCallback) - Method in class org.oracle.okafka.clients.consumer.KafkaConsumer: This method is not yet supported.
commitAsync(OffsetCommitCallback) - Method in class org.oracle.okafka.clients.consumer.KafkaConsumer: Commits messages(offsets) consumed using ) since last commit in this session.
commitSync() - Method in class org.oracle.okafka.clients.consumer.KafkaConsumer: Commits messages(offsets) consumed using poll() since last commit in this session.
commitSync(Duration) - Method in class org.oracle.okafka.clients.consumer.KafkaConsumer: Commits messages(offsets) consumed using poll() since last commit in this session.
commitSync(Map<TopicPartition, OffsetAndMetadata>) - Method in class org.oracle.okafka.clients.consumer.KafkaConsumer: This method not yet supported.
commitSync(Map<TopicPartition, OffsetAndMetadata>, Duration) - Method in class org.oracle.okafka.clients.consumer.KafkaConsumer: This method not yet supported.
committed(Set<TopicPartition>) - Method in class org.oracle.okafka.clients.consumer.KafkaConsumer
committed(Set<TopicPartition>, Duration) - Method in class org.oracle.okafka.clients.consumer.KafkaConsumer
committed(TopicPartition) - Method in class org.oracle.okafka.clients.consumer.KafkaConsumer: This method is not yet supported.
committed(TopicPartition, Duration) - Method in class org.oracle.okafka.clients.consumer.KafkaConsumer: This method is not yet supported.
commitTransaction() - Method in class org.oracle.okafka.clients.producer.KafkaProducer: Commits the ongoing transaction.
COMPRESSION_TYPE_CONFIG - Static variable in class org.oracle.okafka.clients.producer.ProducerConfig: compression.type (This property is not yet supported)
configDef() - Static method in class org.oracle.okafka.clients.consumer.ConsumerConfig
configNames() - Static method in class org.oracle.okafka.clients.admin.AdminClientConfig
configNames() - Static method in class org.oracle.okafka.clients.consumer.ConsumerConfig
configNames() - Static method in class org.oracle.okafka.clients.producer.ProducerConfig
ConnectionException - Exception Class in org.oracle.okafka.common.errors
ConnectionException() - Constructor for exception class org.oracle.okafka.common.errors.ConnectionException
ConnectionException(String) - Constructor for exception class org.oracle.okafka.common.errors.ConnectionException
ConnectionException(String, Throwable) - Constructor for exception class org.oracle.okafka.common.errors.ConnectionException
ConnectionException(Throwable) - Constructor for exception class org.oracle.okafka.common.errors.ConnectionException
CONNECTIONS_MAX_IDLE_MS_CONFIG - Static variable in class org.oracle.okafka.clients.admin.AdminClientConfig: connections.max.idle.ms
CONNECTIONS_MAX_IDLE_MS_CONFIG - Static variable in class org.oracle.okafka.clients.consumer.ConsumerConfig: connections.max.idle.ms
CONNECTIONS_MAX_IDLE_MS_CONFIG - Static variable in class org.oracle.okafka.clients.producer.ProducerConfig: connections.max.idle.ms (This property is not yet supported)
ConsumerConfig - Class in org.oracle.okafka.clients.consumer: The consumer configuration keys
ConsumerConfig(Map<?, ?>, boolean) - Constructor for class org.oracle.okafka.clients.consumer.ConsumerConfig
ConsumerConfig(Map<String, Object>) - Constructor for class org.oracle.okafka.clients.consumer.ConsumerConfig
ConsumerConfig(Properties) - Constructor for class org.oracle.okafka.clients.consumer.ConsumerConfig
create(Map<String, Object>) - Static method in interface org.oracle.okafka.clients.admin.Admin: Create a new Admin with the given configuration.
create(Map<String, Object>) - Static method in class org.oracle.okafka.clients.admin.AdminClient: Create a new AdminClient with the given configuration.
create(Properties) - Static method in interface org.oracle.okafka.clients.admin.Admin: Create a new Admin with the given configuration.
create(Properties) - Static method in class org.oracle.okafka.clients.admin.AdminClient
createAcls(Collection<AclBinding>) - Method in interface org.oracle.okafka.clients.admin.Admin: This is a convenience method for Admin.createAcls(Collection, CreateAclsOptions) with default options.
createAcls(Collection<AclBinding>, CreateAclsOptions) - Method in interface org.oracle.okafka.clients.admin.Admin: Creates access control lists (ACLs) which are bound to specific resources.
createAcls(Collection<AclBinding>, CreateAclsOptions) - Method in class org.oracle.okafka.clients.admin.KafkaAdminClient
createDelegationToken() - Method in interface org.oracle.okafka.clients.admin.Admin: Create a Delegation Token.
createDelegationToken(CreateDelegationTokenOptions) - Method in interface org.oracle.okafka.clients.admin.Admin: Create a Delegation Token.
createDelegationToken(CreateDelegationTokenOptions) - Method in class org.oracle.okafka.clients.admin.KafkaAdminClient
createPartitions(Map<String, NewPartitions>) - Method in interface org.oracle.okafka.clients.admin.Admin: Increase the number of partitions of the topics given as the keys of newPartitions according to the corresponding values.
createPartitions(Map<String, NewPartitions>, CreatePartitionsOptions) - Method in interface org.oracle.okafka.clients.admin.Admin: Increase the number of partitions of the topics given as the keys of newPartitions according to the corresponding values.
createPartitions(Map<String, NewPartitions>, CreatePartitionsOptions) - Method in class org.oracle.okafka.clients.admin.KafkaAdminClient
createTopics(Collection<NewTopic>) - Method in interface org.oracle.okafka.clients.admin.Admin: Create a batch of new topics with the default options.
createTopics(Collection<NewTopic>) - Method in class org.oracle.okafka.clients.admin.AdminClient: Create a batch of new topics .This call supports only retention.ms option for topic creation.
createTopics(Collection<NewTopic>, CreateTopicsOptions) - Method in interface org.oracle.okafka.clients.admin.Admin: Create a batch of new topics.
createTopics(Collection<NewTopic>, CreateTopicsOptions) - Method in class org.oracle.okafka.clients.admin.AdminClient: Create a batch of new topics.
createTopics(Collection<NewTopic>, CreateTopicsOptions) - Method in class org.oracle.okafka.clients.admin.KafkaAdminClient
CreateTopicsResult - Class in org.oracle.okafka.clients.admin: The result of Admin.createTopics(Collection).
CreateTopicsResult(Map<String, KafkaFuture<CreateTopicsResult.TopicMetadataAndConfig>>) - Constructor for class org.oracle.okafka.clients.admin.CreateTopicsResult
currentLag(TopicPartition) - Method in class org.oracle.okafka.clients.consumer.KafkaConsumer

D

DEFAULT_ALLOW_AUTO_CREATE_TOPICS - Static variable in class org.oracle.okafka.clients.consumer.ConsumerConfig
DEFAULT_API_TIMEOUT_MS_CONFIG - Static variable in class org.oracle.okafka.clients.consumer.ConsumerConfig: default.api.timeout.ms
DEFAULT_API_TIMEOUT_MS_DOC - Static variable in class org.oracle.okafka.clients.consumer.ConsumerConfig
DEFAULT_EXCLUDE_INTERNAL_TOPICS - Static variable in class org.oracle.okafka.clients.consumer.ConsumerConfig
DEFAULT_FETCH_MAX_BYTES - Static variable in class org.oracle.okafka.clients.consumer.ConsumerConfig
DEFAULT_ISOLATION_LEVEL - Static variable in class org.oracle.okafka.clients.consumer.ConsumerConfig
DEFAULT_MAX_PARTITION_FETCH_BYTES - Static variable in class org.oracle.okafka.clients.consumer.ConsumerConfig
DEFAULT_SECURITY_PROTOCOL - Static variable in class org.oracle.okafka.clients.admin.AdminClientConfig
deleteAcls(Collection<AclBindingFilter>) - Method in interface org.oracle.okafka.clients.admin.Admin: This is a convenience method for Admin.deleteAcls(Collection, DeleteAclsOptions) with default options.
deleteAcls(Collection<AclBindingFilter>, DeleteAclsOptions) - Method in interface org.oracle.okafka.clients.admin.Admin: Deletes access control lists (ACLs) according to the supplied filters.
deleteAcls(Collection<AclBindingFilter>, DeleteAclsOptions) - Method in class org.oracle.okafka.clients.admin.KafkaAdminClient
deleteConsumerGroupOffsets(String, Set<TopicPartition>) - Method in interface org.oracle.okafka.clients.admin.Admin: Delete committed offsets for a set of partitions in a consumer group with the default options.
deleteConsumerGroupOffsets(String, Set<TopicPartition>, DeleteConsumerGroupOffsetsOptions) - Method in interface org.oracle.okafka.clients.admin.Admin: Delete committed offsets for a set of partitions in a consumer group.
deleteConsumerGroupOffsets(String, Set<TopicPartition>, DeleteConsumerGroupOffsetsOptions) - Method in class org.oracle.okafka.clients.admin.KafkaAdminClient
deleteConsumerGroups(Collection<String>) - Method in interface org.oracle.okafka.clients.admin.Admin: Delete consumer groups from the cluster with the default options.
deleteConsumerGroups(Collection<String>, DeleteConsumerGroupsOptions) - Method in interface org.oracle.okafka.clients.admin.Admin: Delete consumer groups from the cluster.
deleteConsumerGroups(Collection<String>, DeleteConsumerGroupsOptions) - Method in class org.oracle.okafka.clients.admin.KafkaAdminClient
deleteRecords(Map<TopicPartition, RecordsToDelete>) - Method in interface org.oracle.okafka.clients.admin.Admin: Delete records whose offset is smaller than the given offset of the corresponding partition.
deleteRecords(Map<TopicPartition, RecordsToDelete>, DeleteRecordsOptions) - Method in interface org.oracle.okafka.clients.admin.Admin: Delete records whose offset is smaller than the given offset of the corresponding partition.
deleteRecords(Map<TopicPartition, RecordsToDelete>, DeleteRecordsOptions) - Method in class org.oracle.okafka.clients.admin.KafkaAdminClient
deleteTopics(Collection<String>) - Method in interface org.oracle.okafka.clients.admin.Admin: This is a convenience method for Admin.deleteTopics(Collection, DeleteTopicsOptions) with default options.
deleteTopics(Collection<String>) - Method in class org.oracle.okafka.clients.admin.AdminClient: Delete a batch of topics.
deleteTopics(Collection<String>, DeleteTopicsOptions) - Method in interface org.oracle.okafka.clients.admin.Admin: Delete a batch of topics.
deleteTopics(Collection<String>, DeleteTopicsOptions) - Method in class org.oracle.okafka.clients.admin.AdminClient: Delete a batch of topics.
deleteTopics(Collection<String>, DeleteTopicsOptions) - Method in class org.oracle.okafka.clients.admin.KafkaAdminClient
deleteTopics(Collection<String>, DeleteTopicsOptions) - Method in class org.oracle.okafka.clients.admin.KafkaAdminClient
deleteTopics(TopicCollection, DeleteTopicsOptions) - Method in class org.oracle.okafka.clients.admin.KafkaAdminClient
DeleteTopicsOptions - Class in org.oracle.okafka.clients.admin: Options for Admin.deleteTopics(Collection).
DeleteTopicsOptions() - Constructor for class org.oracle.okafka.clients.admin.DeleteTopicsOptions
DeleteTopicsResult - Class in org.oracle.okafka.clients.admin: The result of the Admin.deleteTopics(Collection) call.
DELIVERY_TIMEOUT_MS_CONFIG - Static variable in class org.oracle.okafka.clients.producer.ProducerConfig: delivery.timeout.ms
describeAcls(AclBindingFilter) - Method in interface org.oracle.okafka.clients.admin.Admin: This is a convenience method for Admin.describeAcls(AclBindingFilter, DescribeAclsOptions) with default options.
describeAcls(AclBindingFilter, DescribeAclsOptions) - Method in interface org.oracle.okafka.clients.admin.Admin: Lists access control lists (ACLs) according to the supplied filter.
describeAcls(AclBindingFilter, DescribeAclsOptions) - Method in class org.oracle.okafka.clients.admin.KafkaAdminClient
describeClientQuotas(ClientQuotaFilter) - Method in interface org.oracle.okafka.clients.admin.Admin: Describes all entities matching the provided filter that have at least one client quota configuration value defined.
describeClientQuotas(ClientQuotaFilter, DescribeClientQuotasOptions) - Method in interface org.oracle.okafka.clients.admin.Admin: Describes all entities matching the provided filter that have at least one client quota configuration value defined.
describeClientQuotas(ClientQuotaFilter, DescribeClientQuotasOptions) - Method in class org.oracle.okafka.clients.admin.KafkaAdminClient
describeCluster() - Method in interface org.oracle.okafka.clients.admin.Admin: Get information about the nodes in the cluster, using the default options.
describeCluster(DescribeClusterOptions) - Method in interface org.oracle.okafka.clients.admin.Admin: Get information about the nodes in the cluster.
describeCluster(DescribeClusterOptions) - Method in class org.oracle.okafka.clients.admin.KafkaAdminClient
describeConfigs(Collection<ConfigResource>) - Method in interface org.oracle.okafka.clients.admin.Admin: Get the configuration for the specified resources with the default options.
describeConfigs(Collection<ConfigResource>, DescribeConfigsOptions) - Method in interface org.oracle.okafka.clients.admin.Admin: Get the configuration for the specified resources.
describeConfigs(Collection<ConfigResource>, DescribeConfigsOptions) - Method in class org.oracle.okafka.clients.admin.KafkaAdminClient
describeConsumerGroups(Collection<String>) - Method in interface org.oracle.okafka.clients.admin.Admin: Describe some group IDs in the cluster, with the default options.
describeConsumerGroups(Collection<String>, DescribeConsumerGroupsOptions) - Method in interface org.oracle.okafka.clients.admin.Admin: Describe some group IDs in the cluster.
describeConsumerGroups(Collection<String>, DescribeConsumerGroupsOptions) - Method in class org.oracle.okafka.clients.admin.KafkaAdminClient
describeDelegationToken() - Method in interface org.oracle.okafka.clients.admin.Admin: Describe the Delegation Tokens.
describeDelegationToken(DescribeDelegationTokenOptions) - Method in interface org.oracle.okafka.clients.admin.Admin: Describe the Delegation Tokens.
describeDelegationToken(DescribeDelegationTokenOptions) - Method in class org.oracle.okafka.clients.admin.KafkaAdminClient
describeFeatures() - Method in interface org.oracle.okafka.clients.admin.Admin: Describes finalized as well as supported features.
describeFeatures(DescribeFeaturesOptions) - Method in interface org.oracle.okafka.clients.admin.Admin: Describes finalized as well as supported features.
describeFeatures(DescribeFeaturesOptions) - Method in class org.oracle.okafka.clients.admin.KafkaAdminClient
describeLogDirs(Collection<Integer>) - Method in interface org.oracle.okafka.clients.admin.Admin: Query the information of all log directories on the given set of brokers
describeLogDirs(Collection<Integer>, DescribeLogDirsOptions) - Method in interface org.oracle.okafka.clients.admin.Admin: Query the information of all log directories on the given set of brokers
describeLogDirs(Collection<Integer>, DescribeLogDirsOptions) - Method in class org.oracle.okafka.clients.admin.KafkaAdminClient
describeMetadataQuorum(DescribeMetadataQuorumOptions) - Method in class org.oracle.okafka.clients.admin.KafkaAdminClient
describeProducers(Collection<TopicPartition>, DescribeProducersOptions) - Method in class org.oracle.okafka.clients.admin.KafkaAdminClient
describeReplicaLogDirs(Collection<TopicPartitionReplica>) - Method in interface org.oracle.okafka.clients.admin.Admin: Query the replica log directory information for the specified replicas.
describeReplicaLogDirs(Collection<TopicPartitionReplica>, DescribeReplicaLogDirsOptions) - Method in interface org.oracle.okafka.clients.admin.Admin: Query the replica log directory information for the specified replicas.
describeReplicaLogDirs(Collection<TopicPartitionReplica>, DescribeReplicaLogDirsOptions) - Method in class org.oracle.okafka.clients.admin.KafkaAdminClient
describeTopics(Collection<String>) - Method in interface org.oracle.okafka.clients.admin.Admin: Describe some topics in the cluster, with the default options.
describeTopics(Collection<String>, DescribeTopicsOptions) - Method in interface org.oracle.okafka.clients.admin.Admin: Describe some topics in the cluster.
describeTopics(Collection<String>, DescribeTopicsOptions) - Method in class org.oracle.okafka.clients.admin.KafkaAdminClient
describeTopics(TopicCollection, DescribeTopicsOptions) - Method in class org.oracle.okafka.clients.admin.KafkaAdminClient
describeTransactions(Collection<String>, DescribeTransactionsOptions) - Method in class org.oracle.okafka.clients.admin.KafkaAdminClient
describeUserScramCredentials() - Method in interface org.oracle.okafka.clients.admin.Admin: Describe all SASL/SCRAM credentials.
describeUserScramCredentials(List<String>) - Method in interface org.oracle.okafka.clients.admin.Admin: Describe SASL/SCRAM credentials for the given users.
describeUserScramCredentials(List<String>, DescribeUserScramCredentialsOptions) - Method in interface org.oracle.okafka.clients.admin.Admin: Describe SASL/SCRAM credentials.
describeUserScramCredentials(List<String>, DescribeUserScramCredentialsOptions) - Method in class org.oracle.okafka.clients.admin.KafkaAdminClient

E

electLeaders(ElectionType, Set<TopicPartition>) - Method in interface org.oracle.okafka.clients.admin.Admin: Elect a replica as leader for topic partitions.
electLeaders(ElectionType, Set<TopicPartition>, ElectLeadersOptions) - Method in interface org.oracle.okafka.clients.admin.Admin: Elect a replica as leader for the given partitions, or for all partitions if the argument to partitions is null.
electLeaders(ElectionType, Set<TopicPartition>, ElectLeadersOptions) - Method in class org.oracle.okafka.clients.admin.KafkaAdminClient
electPreferredLeaders(Collection<TopicPartition>) - Method in interface org.oracle.okafka.clients.admin.Admin: Deprecated.
Since 2.4.0. Use Admin.electLeaders(ElectionType, Set).
electPreferredLeaders(Collection<TopicPartition>, ElectLeadersOptions) - Method in interface org.oracle.okafka.clients.admin.Admin: Deprecated.
Since 2.4.0. Use Admin.electLeaders(ElectionType, Set, ElectLeadersOptions).
ENABLE_AUTO_COMMIT_CONFIG - Static variable in class org.oracle.okafka.clients.consumer.ConsumerConfig: enable.auto.commit
ENABLE_IDEMPOTENCE_CONFIG - Static variable in class org.oracle.okafka.clients.producer.ProducerConfig: enable.idempotence (This property is not yet supported)
ENABLE_IDEMPOTENCE_DOC - Static variable in class org.oracle.okafka.clients.producer.ProducerConfig
endOffsets(Collection<TopicPartition>) - Method in class org.oracle.okafka.clients.consumer.KafkaConsumer: This method is not yet supported.
endOffsets(Collection<TopicPartition>, Duration) - Method in class org.oracle.okafka.clients.consumer.KafkaConsumer: This method is not yet supported.
enforceRebalance() - Method in class org.oracle.okafka.clients.consumer.KafkaConsumer
enforceRebalance(String) - Method in class org.oracle.okafka.clients.consumer.KafkaConsumer
EXCLUDE_INTERNAL_TOPICS_CONFIG - Static variable in class org.oracle.okafka.clients.consumer.ConsumerConfig: exclude.internal.topics
expireDelegationToken(byte[]) - Method in interface org.oracle.okafka.clients.admin.Admin: Expire a Delegation Token.
expireDelegationToken(byte[], ExpireDelegationTokenOptions) - Method in interface org.oracle.okafka.clients.admin.Admin: Expire a Delegation Token.
expireDelegationToken(byte[], ExpireDelegationTokenOptions) - Method in class org.oracle.okafka.clients.admin.KafkaAdminClient

F

FeatureNotSupportedException - Exception Class in org.oracle.okafka.common.errors: If a method/api is not supported then this exception is thrown.
FeatureNotSupportedException() - Constructor for exception class org.oracle.okafka.common.errors.FeatureNotSupportedException
FeatureNotSupportedException(String) - Constructor for exception class org.oracle.okafka.common.errors.FeatureNotSupportedException
FeatureNotSupportedException(String, Throwable) - Constructor for exception class org.oracle.okafka.common.errors.FeatureNotSupportedException
FeatureNotSupportedException(Throwable) - Constructor for exception class org.oracle.okafka.common.errors.FeatureNotSupportedException
fenceProducers(Collection<String>, FenceProducersOptions) - Method in class org.oracle.okafka.clients.admin.KafkaAdminClient
FETCH_MAX_BYTES_CONFIG - Static variable in class org.oracle.okafka.clients.consumer.ConsumerConfig: fetch.max.bytes
FETCH_MAX_WAIT_MS_CONFIG - Static variable in class org.oracle.okafka.clients.consumer.ConsumerConfig: fetch.max.wait.ms
FETCH_MIN_BYTES_CONFIG - Static variable in class org.oracle.okafka.clients.consumer.ConsumerConfig: fetch.min.bytes
flush() - Method in class org.oracle.okafka.clients.producer.KafkaProducer: Invoking this method makes all buffered records immediately available to send (even if linger.ms is greater than 0) and blocks on the completion of the requests associated with these records.

G

getDBConnection() - Method in class org.oracle.okafka.clients.consumer.KafkaConsumer: Get the Oracle database connection used to consume records from Oracle Transactional Event Queue.
getDBConnection() - Method in class org.oracle.okafka.clients.producer.KafkaProducer: This method returns the database connection used by this KafkaProducer.
GROUP_ID_CONFIG - Static variable in class org.oracle.okafka.clients.consumer.ConsumerConfig: group.id
GROUP_INSTANCE_ID_CONFIG - Static variable in class org.oracle.okafka.clients.consumer.ConsumerConfig: group.instance.id
groupMetadata() - Method in class org.oracle.okafka.clients.consumer.KafkaConsumer

H

HEARTBEAT_INTERVAL_MS_CONFIG - Static variable in class org.oracle.okafka.clients.consumer.ConsumerConfig: heartbeat.interval.ms

I

incrementalAlterConfigs(Map<ConfigResource, Collection<AlterConfigOp>>) - Method in interface org.oracle.okafka.clients.admin.Admin: Incrementally updates the configuration for the specified resources with default options.
incrementalAlterConfigs(Map<ConfigResource, Collection<AlterConfigOp>>, AlterConfigsOptions) - Method in interface org.oracle.okafka.clients.admin.Admin: Incrementally update the configuration for the specified resources.
incrementalAlterConfigs(Map<ConfigResource, Collection<AlterConfigOp>>, AlterConfigsOptions) - Method in class org.oracle.okafka.clients.admin.KafkaAdminClient
initTransactions() - Method in class org.oracle.okafka.clients.producer.KafkaProducer: Needs to be called before any other methods when the transactional.id is set in the configuration.
INTERCEPTOR_CLASSES_CONFIG - Static variable in class org.oracle.okafka.clients.consumer.ConsumerConfig: interceptor.classes
INTERCEPTOR_CLASSES_CONFIG - Static variable in class org.oracle.okafka.clients.producer.ProducerConfig: interceptor.classes
INTERCEPTOR_CLASSES_DOC - Static variable in class org.oracle.okafka.clients.consumer.ConsumerConfig
INTERCEPTOR_CLASSES_DOC - Static variable in class org.oracle.okafka.clients.producer.ProducerConfig
InvalidLoginCredentialsException - Exception Class in org.oracle.okafka.common.errors: This exception indicates that user provided invalid login details.
InvalidLoginCredentialsException() - Constructor for exception class org.oracle.okafka.common.errors.InvalidLoginCredentialsException
InvalidLoginCredentialsException(String) - Constructor for exception class org.oracle.okafka.common.errors.InvalidLoginCredentialsException
InvalidLoginCredentialsException(String, Throwable) - Constructor for exception class org.oracle.okafka.common.errors.InvalidLoginCredentialsException
InvalidLoginCredentialsException(Throwable) - Constructor for exception class org.oracle.okafka.common.errors.InvalidLoginCredentialsException
InvalidMessageIdException - Exception Class in org.oracle.okafka.common.errors: This exception indicates that client has received invalid message id from server.
InvalidMessageIdException() - Constructor for exception class org.oracle.okafka.common.errors.InvalidMessageIdException
InvalidMessageIdException(String) - Constructor for exception class org.oracle.okafka.common.errors.InvalidMessageIdException
InvalidMessageIdException(String, Throwable) - Constructor for exception class org.oracle.okafka.common.errors.InvalidMessageIdException
InvalidMessageIdException(Throwable) - Constructor for exception class org.oracle.okafka.common.errors.InvalidMessageIdException
ISOLATION_LEVEL_CONFIG - Static variable in class org.oracle.okafka.clients.consumer.ConsumerConfig: isolation.level
ISOLATION_LEVEL_DOC - Static variable in class org.oracle.okafka.clients.consumer.ConsumerConfig

K

KafkaAdminClient - Class in org.oracle.okafka.clients.admin: The default implementation of AdminClient.
KafkaConsumer<K,V> - Class in org.oracle.okafka.clients.consumer: A Java client that consumes records from a Transactional event queues(TxEventQ).
KafkaConsumer(Map<String, Object>) - Constructor for class org.oracle.okafka.clients.consumer.KafkaConsumer: A consumer is instantiated by providing a set of key-value pairs as configuration.
KafkaConsumer(Map<String, Object>, Deserializer<K>, Deserializer<V>) - Constructor for class org.oracle.okafka.clients.consumer.KafkaConsumer: A consumer is instantiated by providing a set of key-value pairs as configuration, and a key and a value Deserializer.
KafkaConsumer(Properties) - Constructor for class org.oracle.okafka.clients.consumer.KafkaConsumer: A consumer is instantiated by providing a Properties object as configuration.
KafkaConsumer(Properties, Deserializer<K>, Deserializer<V>) - Constructor for class org.oracle.okafka.clients.consumer.KafkaConsumer: A consumer is instantiated by providing a Properties object as configuration, and a key and a value Deserializer.
KafkaConsumer.FetchManagerMetrics - Class in org.oracle.okafka.clients.consumer
KafkaProducer<K,V> - Class in org.oracle.okafka.clients.producer: An OKafka client that publishes records to the Oracle's Transactional Event Queue (TxEQ) messaging broker.
KafkaProducer(Map<String, Object>) - Constructor for class org.oracle.okafka.clients.producer.KafkaProducer: A producer is instantiated by providing a set of key-value pairs as configuration.
KafkaProducer(Map<String, Object>, Connection) - Constructor for class org.oracle.okafka.clients.producer.KafkaProducer: A producer is instantiated by providing a set of key-value pairs as configuration.
KafkaProducer(Map<String, Object>, Serializer<K>, Serializer<V>) - Constructor for class org.oracle.okafka.clients.producer.KafkaProducer: A producer is instantiated by providing a set of key-value pairs as configuration, a key and a value Serializer.
KafkaProducer(Map<String, Object>, Serializer<K>, Serializer<V>, Connection) - Constructor for class org.oracle.okafka.clients.producer.KafkaProducer: A producer is instantiated by providing a set of key-value pairs as configuration, a key and a value Serializer and Connection to Oracle Database, versioned 23c and above.
KafkaProducer(Properties) - Constructor for class org.oracle.okafka.clients.producer.KafkaProducer: A producer is instantiated by providing a set of key-value pairs as configuration.
KafkaProducer(Properties, Connection) - Constructor for class org.oracle.okafka.clients.producer.KafkaProducer: A producer is instantiated by providing a set of key-value pairs as configuration.
KafkaProducer(Properties, Serializer<K>, Serializer<V>) - Constructor for class org.oracle.okafka.clients.producer.KafkaProducer: A producer is instantiated by providing a set of key-value pairs as configuration, a key and a value Serializer.
KafkaProducer(Properties, Serializer<K>, Serializer<V>, Connection) - Constructor for class org.oracle.okafka.clients.producer.KafkaProducer: A producer is instantiated by providing a set of key-value pairs as configuration, a key and a value Serializer and Connection to Oracle Database.
KEY_DESERIALIZER_CLASS_CONFIG - Static variable in class org.oracle.okafka.clients.consumer.ConsumerConfig: key.deserializer
KEY_DESERIALIZER_CLASS_DOC - Static variable in class org.oracle.okafka.clients.consumer.ConsumerConfig
KEY_SERIALIZER_CLASS_CONFIG - Static variable in class org.oracle.okafka.clients.producer.ProducerConfig: key.serializer
KEY_SERIALIZER_CLASS_DOC - Static variable in class org.oracle.okafka.clients.producer.ProducerConfig

L

LINGER_MS_CONFIG - Static variable in class org.oracle.okafka.clients.producer.ProducerConfig: linger.ms
listClientMetricsResources(ListClientMetricsResourcesOptions) - Method in class org.oracle.okafka.clients.admin.KafkaAdminClient
listConsumerGroupOffsets(String) - Method in interface org.oracle.okafka.clients.admin.Admin: List the consumer group offsets available in the cluster with the default options.
listConsumerGroupOffsets(String, ListConsumerGroupOffsetsOptions) - Method in interface org.oracle.okafka.clients.admin.Admin: List the consumer group offsets available in the cluster.
listConsumerGroupOffsets(String, ListConsumerGroupOffsetsOptions) - Method in class org.oracle.okafka.clients.admin.KafkaAdminClient
listConsumerGroupOffsets(Map<String, ListConsumerGroupOffsetsSpec>, ListConsumerGroupOffsetsOptions) - Method in class org.oracle.okafka.clients.admin.KafkaAdminClient
listConsumerGroups() - Method in interface org.oracle.okafka.clients.admin.Admin: List the consumer groups available in the cluster with the default options.
listConsumerGroups(ListConsumerGroupsOptions) - Method in interface org.oracle.okafka.clients.admin.Admin: List the consumer groups available in the cluster.
listConsumerGroups(ListConsumerGroupsOptions) - Method in class org.oracle.okafka.clients.admin.KafkaAdminClient
listOffsets(Map<TopicPartition, OffsetSpec>) - Method in interface org.oracle.okafka.clients.admin.Admin: List offset for the specified partitions and OffsetSpec.
listOffsets(Map<TopicPartition, OffsetSpec>, ListOffsetsOptions) - Method in interface org.oracle.okafka.clients.admin.Admin: List offset for the specified partitions.
listOffsets(Map<TopicPartition, OffsetSpec>, ListOffsetsOptions) - Method in class org.oracle.okafka.clients.admin.KafkaAdminClient
listPartitionReassignments() - Method in interface org.oracle.okafka.clients.admin.Admin: List all of the current partition reassignments This is a convenience method for Admin.listPartitionReassignments(ListPartitionReassignmentsOptions) with default options.
listPartitionReassignments(Optional<Set<TopicPartition>>, ListPartitionReassignmentsOptions) - Method in interface org.oracle.okafka.clients.admin.Admin
listPartitionReassignments(Optional<Set<TopicPartition>>, ListPartitionReassignmentsOptions) - Method in class org.oracle.okafka.clients.admin.KafkaAdminClient
listPartitionReassignments(Set<TopicPartition>) - Method in interface org.oracle.okafka.clients.admin.Admin: List the current reassignments for the given partitions This is a convenience method for Admin.listPartitionReassignments(Set, ListPartitionReassignmentsOptions) with default options.
listPartitionReassignments(Set<TopicPartition>, ListPartitionReassignmentsOptions) - Method in interface org.oracle.okafka.clients.admin.Admin: List the current reassignments for the given partitions
listPartitionReassignments(ListPartitionReassignmentsOptions) - Method in interface org.oracle.okafka.clients.admin.Admin: List all of the current partition reassignments
listTopics() - Method in interface org.oracle.okafka.clients.admin.Admin: List the topics available in the cluster with the default options.
listTopics() - Method in class org.oracle.okafka.clients.consumer.KafkaConsumer: This method is not yet supported.
listTopics(Duration) - Method in class org.oracle.okafka.clients.consumer.KafkaConsumer: This method is not yet supported.
listTopics(ListTopicsOptions) - Method in interface org.oracle.okafka.clients.admin.Admin: List the topics available in the cluster.
listTopics(ListTopicsOptions) - Method in class org.oracle.okafka.clients.admin.KafkaAdminClient
listTransactions(ListTransactionsOptions) - Method in class org.oracle.okafka.clients.admin.KafkaAdminClient

M

main(String[]) - Static method in class org.oracle.okafka.clients.admin.AdminClientConfig
main(String[]) - Static method in class org.oracle.okafka.clients.consumer.ConsumerConfig
main(String[]) - Static method in class org.oracle.okafka.clients.producer.ProducerConfig
MAX_BLOCK_MS_CONFIG - Static variable in class org.oracle.okafka.clients.producer.ProducerConfig: max.block.ms
MAX_IN_FLIGHT_REQUESTS_PER_CONNECTION - Static variable in class org.oracle.okafka.clients.producer.ProducerConfig: max.in.flight.requests.per.connection (This property is not yet supported)
MAX_PARTITION_FETCH_BYTES_CONFIG - Static variable in class org.oracle.okafka.clients.consumer.ConsumerConfig: max.partition.fetch.bytes
MAX_POLL_INTERVAL_MS_CONFIG - Static variable in class org.oracle.okafka.clients.consumer.ConsumerConfig: max.poll.interval.ms
MAX_POLL_RECORDS_CONFIG - Static variable in class org.oracle.okafka.clients.consumer.ConsumerConfig: max.poll.records
MAX_REQUEST_SIZE_CONFIG - Static variable in class org.oracle.okafka.clients.producer.ProducerConfig: max.request.size
METADATA_MAX_AGE_CONFIG - Static variable in class org.oracle.okafka.clients.admin.AdminClientConfig
METADATA_MAX_AGE_CONFIG - Static variable in class org.oracle.okafka.clients.consumer.ConsumerConfig: metadata.max.age.ms
METADATA_MAX_AGE_CONFIG - Static variable in class org.oracle.okafka.clients.producer.ProducerConfig: metadata.max.age.ms
METADATA_MAX_IDLE_CONFIG - Static variable in class org.oracle.okafka.clients.producer.ProducerConfig: metadata.max.idle.ms
METRIC_REPORTER_CLASSES_CONFIG - Static variable in class org.oracle.okafka.clients.admin.AdminClientConfig
METRIC_REPORTER_CLASSES_CONFIG - Static variable in class org.oracle.okafka.clients.consumer.ConsumerConfig: metric.reporters
METRIC_REPORTER_CLASSES_CONFIG - Static variable in class org.oracle.okafka.clients.producer.ProducerConfig: metric.reporters (This property is not yet supported)
metrics() - Method in interface org.oracle.okafka.clients.admin.Admin: Get the metrics kept by the adminClient
metrics() - Method in class org.oracle.okafka.clients.admin.KafkaAdminClient
metrics() - Method in class org.oracle.okafka.clients.consumer.KafkaConsumer: This method is not yet supported.
metrics() - Method in class org.oracle.okafka.clients.producer.KafkaProducer: Get the full set of internal metrics maintained by the producer.
METRICS_NUM_SAMPLES_CONFIG - Static variable in class org.oracle.okafka.clients.admin.AdminClientConfig
METRICS_NUM_SAMPLES_CONFIG - Static variable in class org.oracle.okafka.clients.consumer.ConsumerConfig: metrics.num.samples
METRICS_NUM_SAMPLES_CONFIG - Static variable in class org.oracle.okafka.clients.producer.ProducerConfig: metrics.num.samples (This property is not yet supported)
METRICS_RECORDING_LEVEL_CONFIG - Static variable in class org.oracle.okafka.clients.admin.AdminClientConfig
METRICS_RECORDING_LEVEL_CONFIG - Static variable in class org.oracle.okafka.clients.consumer.ConsumerConfig: metrics.log.level
METRICS_RECORDING_LEVEL_CONFIG - Static variable in class org.oracle.okafka.clients.producer.ProducerConfig: metrics.log.level (This property is not yet supported)
METRICS_SAMPLE_WINDOW_MS_CONFIG - Static variable in class org.oracle.okafka.clients.admin.AdminClientConfig
METRICS_SAMPLE_WINDOW_MS_CONFIG - Static variable in class org.oracle.okafka.clients.consumer.ConsumerConfig: metrics.sample.window.ms
METRICS_SAMPLE_WINDOW_MS_CONFIG - Static variable in class org.oracle.okafka.clients.producer.ProducerConfig: metrics.sample.window.ms (This property is not yet supported)

N

name() - Method in class org.oracle.okafka.clients.consumer.TxEQAssignor
NETWORK_THREAD_PREFIX - Static variable in class org.oracle.okafka.clients.producer.KafkaProducer

O

offsetsForTimes(Map<TopicPartition, Long>) - Method in class org.oracle.okafka.clients.consumer.KafkaConsumer: This method is not yet supported.
offsetsForTimes(Map<TopicPartition, Long>, Duration) - Method in class org.oracle.okafka.clients.consumer.KafkaConsumer: This method is not yet supported.
ORACLE_INSTANCE_NAME - Static variable in class org.oracle.okafka.clients.admin.AdminClientConfig
ORACLE_INSTANCE_NAME - Static variable in class org.oracle.okafka.clients.consumer.ConsumerConfig
ORACLE_INSTANCE_NAME - Static variable in class org.oracle.okafka.clients.producer.ProducerConfig: oracle.instance.name
ORACLE_NET_TNS_ADMIN - Static variable in class org.oracle.okafka.clients.admin.AdminClientConfig: oracle.net.tns_admin
ORACLE_NET_TNS_ADMIN - Static variable in class org.oracle.okafka.clients.consumer.ConsumerConfig: oracle.net.tns_admin
ORACLE_NET_TNS_ADMIN - Static variable in class org.oracle.okafka.clients.producer.ProducerConfig: oracle.net.tns_admin
ORACLE_SERVICE_NAME - Static variable in class org.oracle.okafka.clients.admin.AdminClientConfig
ORACLE_SERVICE_NAME - Static variable in class org.oracle.okafka.clients.consumer.ConsumerConfig
ORACLE_SERVICE_NAME - Static variable in class org.oracle.okafka.clients.producer.ProducerConfig: oracle.service.name
ORACLE_TRANSACTIONAL_PRODUCER - Static variable in class org.oracle.okafka.clients.producer.ProducerConfig
ORACLE_TRANSACTIONAL_PRODUCER_DOC - Static variable in class org.oracle.okafka.clients.producer.ProducerConfig
org.oracle.okafka.clients.admin - package org.oracle.okafka.clients.admin
org.oracle.okafka.clients.consumer - package org.oracle.okafka.clients.consumer
org.oracle.okafka.clients.producer - package org.oracle.okafka.clients.producer
org.oracle.okafka.common.errors - package org.oracle.okafka.common.errors

P

PARTITION_ASSIGNMENT_STRATEGY_CONFIG - Static variable in class org.oracle.okafka.clients.consumer.ConsumerConfig: partition.assignment.strategy
PARTITIONER_CLASS_CONFIG - Static variable in class org.oracle.okafka.clients.producer.ProducerConfig: partitioner.class
partitionsFor(String) - Method in class org.oracle.okafka.clients.consumer.KafkaConsumer: This method is not yet supported.
partitionsFor(String) - Method in class org.oracle.okafka.clients.producer.KafkaProducer: Get the partition metadata for the given topic.
partitionsFor(String, Duration) - Method in class org.oracle.okafka.clients.consumer.KafkaConsumer: This method is not yet supported.
pause(Collection<TopicPartition>) - Method in class org.oracle.okafka.clients.consumer.KafkaConsumer: This method is not yet supported.
paused() - Method in class org.oracle.okafka.clients.consumer.KafkaConsumer: This method is not yet supported.
poll(long) - Method in class org.oracle.okafka.clients.consumer.KafkaConsumer: Deprecated.
poll(Duration) - Method in class org.oracle.okafka.clients.consumer.KafkaConsumer: Fetch data for the topic specified using KafkaConsumer.subscribe(Collection) APIs.
position(TopicPartition) - Method in class org.oracle.okafka.clients.consumer.KafkaConsumer: This method is not yet supported.
position(TopicPartition, Duration) - Method in class org.oracle.okafka.clients.consumer.KafkaConsumer: This method is not yet supported.
postProcessParsedConfig(Map<String, Object>) - Method in class org.oracle.okafka.clients.admin.AdminClientConfig
postProcessParsedConfig(Map<String, Object>) - Method in class org.oracle.okafka.clients.consumer.ConsumerConfig
PRODUCER_METRIC_GROUP_NAME - Static variable in class org.oracle.okafka.clients.producer.KafkaProducer
ProducerConfig - Class in org.oracle.okafka.clients.producer
ProducerConfig(Map<String, Object>) - Constructor for class org.oracle.okafka.clients.producer.ProducerConfig
ProducerConfig(Properties) - Constructor for class org.oracle.okafka.clients.producer.ProducerConfig

R

RECEIVE_BUFFER_CONFIG - Static variable in class org.oracle.okafka.clients.admin.AdminClientConfig
RECEIVE_BUFFER_CONFIG - Static variable in class org.oracle.okafka.clients.consumer.ConsumerConfig: receive.buffer.bytes
RECEIVE_BUFFER_CONFIG - Static variable in class org.oracle.okafka.clients.producer.ProducerConfig: receive.buffer.bytes (This property is not yet supported)
RECONNECT_BACKOFF_MAX_MS_CONFIG - Static variable in class org.oracle.okafka.clients.admin.AdminClientConfig: reconnect.backoff.max.ms
RECONNECT_BACKOFF_MAX_MS_CONFIG - Static variable in class org.oracle.okafka.clients.consumer.ConsumerConfig: reconnect.backoff.max.ms
RECONNECT_BACKOFF_MAX_MS_CONFIG - Static variable in class org.oracle.okafka.clients.producer.ProducerConfig: reconnect.backoff.max.ms
RECONNECT_BACKOFF_MS_CONFIG - Static variable in class org.oracle.okafka.clients.admin.AdminClientConfig: reconnect.backoff.ms
RECONNECT_BACKOFF_MS_CONFIG - Static variable in class org.oracle.okafka.clients.consumer.ConsumerConfig: reconnect.backoff.ms
RECONNECT_BACKOFF_MS_CONFIG - Static variable in class org.oracle.okafka.clients.producer.ProducerConfig: reconnect.backoff.ms
recordFetchLatency(double) - Method in class org.oracle.okafka.clients.consumer.KafkaConsumer.FetchManagerMetrics
removeMembersFromConsumerGroup(String, RemoveMembersFromConsumerGroupOptions) - Method in interface org.oracle.okafka.clients.admin.Admin: Remove members from the consumer group by given member identities.
removeMembersFromConsumerGroup(String, RemoveMembersFromConsumerGroupOptions) - Method in class org.oracle.okafka.clients.admin.KafkaAdminClient
renewDelegationToken(byte[]) - Method in interface org.oracle.okafka.clients.admin.Admin: Renew a Delegation Token.
renewDelegationToken(byte[], RenewDelegationTokenOptions) - Method in interface org.oracle.okafka.clients.admin.Admin: Renew a Delegation Token.
renewDelegationToken(byte[], RenewDelegationTokenOptions) - Method in class org.oracle.okafka.clients.admin.KafkaAdminClient
REQUEST_TIMEOUT_MS_CONFIG - Static variable in class org.oracle.okafka.clients.admin.AdminClientConfig: request.timeout.ms
REQUEST_TIMEOUT_MS_CONFIG - Static variable in class org.oracle.okafka.clients.consumer.ConsumerConfig: request.timeout.ms
REQUEST_TIMEOUT_MS_CONFIG - Static variable in class org.oracle.okafka.clients.producer.ProducerConfig: request.timeout.ms (This property is not yet supported)
resume(Collection<TopicPartition>) - Method in class org.oracle.okafka.clients.consumer.KafkaConsumer: This method is not yet supported.
RETRIES_CONFIG - Static variable in class org.oracle.okafka.clients.admin.AdminClientConfig
RETRIES_CONFIG - Static variable in class org.oracle.okafka.clients.producer.ProducerConfig: retries
RETRY_BACKOFF_MS_CONFIG - Static variable in class org.oracle.okafka.clients.admin.AdminClientConfig: retry.backoff.ms
RETRY_BACKOFF_MS_CONFIG - Static variable in class org.oracle.okafka.clients.consumer.ConsumerConfig: retry.backoff.ms
RETRY_BACKOFF_MS_CONFIG - Static variable in class org.oracle.okafka.clients.producer.ProducerConfig: retry.backoff.ms

S

SECURITY_PROTOCOL_CONFIG - Static variable in class org.oracle.okafka.clients.admin.AdminClientConfig
SECURITY_PROVIDERS_CONFIG - Static variable in class org.oracle.okafka.clients.consumer.ConsumerConfig: security.providers
seek(TopicPartition, long) - Method in class org.oracle.okafka.clients.consumer.KafkaConsumer: Overrides the fetch offset that the consumer will use on the next poll(timeout).
seek(TopicPartition, OffsetAndMetadata) - Method in class org.oracle.okafka.clients.consumer.KafkaConsumer
seekToBeginning(Collection<TopicPartition>) - Method in class org.oracle.okafka.clients.consumer.KafkaConsumer: Seek to the first available offset for each of the given partitions.
seekToEnd(Collection<TopicPartition>) - Method in class org.oracle.okafka.clients.consumer.KafkaConsumer: Seek to the last offset for each of the given partitions.
send(ProducerRecord<K, V>) - Method in class org.oracle.okafka.clients.producer.KafkaProducer: Asynchronously send a record to a topic.
send(ProducerRecord<K, V>, Callback) - Method in class org.oracle.okafka.clients.producer.KafkaProducer: Asynchronously send a record to a topic and invoke the provided callback when the send has been acknowledged.
SEND_BUFFER_CONFIG - Static variable in class org.oracle.okafka.clients.admin.AdminClientConfig
SEND_BUFFER_CONFIG - Static variable in class org.oracle.okafka.clients.consumer.ConsumerConfig: send.buffer.bytes
SEND_BUFFER_CONFIG - Static variable in class org.oracle.okafka.clients.producer.ProducerConfig: send.buffer.bytes (This property is not yet supported)
sendOffsetsToTransaction(Map<TopicPartition, OffsetAndMetadata>, String) - Method in class org.oracle.okafka.clients.producer.KafkaProducer: This method is not supported for this release of OKafka.
sendOffsetsToTransaction(Map<TopicPartition, OffsetAndMetadata>, ConsumerGroupMetadata) - Method in class org.oracle.okafka.clients.producer.KafkaProducer: This method is not supported for this release of OKafka.
SESSION_TIMEOUT_MS_CONFIG - Static variable in class org.oracle.okafka.clients.consumer.ConsumerConfig: session.timeout.ms
setInstPListMap(Map<Integer, ArrayList<Integer>>) - Method in class org.oracle.okafka.clients.consumer.TxEQAssignor
setPartitionMemberMap(Map<String, ArrayList<SessionData>>) - Method in class org.oracle.okafka.clients.consumer.TxEQAssignor
SOCKET_CONNECTION_SETUP_TIMEOUT_MAX_MS_CONFIG - Static variable in class org.oracle.okafka.clients.consumer.ConsumerConfig: socket.connection.setup.timeout.max.ms
SOCKET_CONNECTION_SETUP_TIMEOUT_MAX_MS_CONFIG - Static variable in class org.oracle.okafka.clients.producer.ProducerConfig: socket.connection.setup.timeout.max.ms
SOCKET_CONNECTION_SETUP_TIMEOUT_MS_CONFIG - Static variable in class org.oracle.okafka.clients.consumer.ConsumerConfig: socket.connection.setup.timeout.ms
SOCKET_CONNECTION_SETUP_TIMEOUT_MS_CONFIG - Static variable in class org.oracle.okafka.clients.producer.ProducerConfig: socket.connection.setup.timeout.ms
subscribe(Collection<String>) - Method in class org.oracle.okafka.clients.consumer.KafkaConsumer: Subscribe to the given list of topics to get partitions assigned dynamically.
subscribe(Collection<String>, ConsumerRebalanceListener) - Method in class org.oracle.okafka.clients.consumer.KafkaConsumer: Subscribe to the given list of topics to get partitions assigned dynamically.
subscribe(Pattern) - Method in class org.oracle.okafka.clients.consumer.KafkaConsumer: This method is not yet supported.
subscribe(Pattern, ConsumerRebalanceListener) - Method in class org.oracle.okafka.clients.consumer.KafkaConsumer: This method is not yet supported.
subscription() - Method in class org.oracle.okafka.clients.consumer.KafkaConsumer: Get the current subscription.

T

TRANSACTION_TIMEOUT_CONFIG - Static variable in class org.oracle.okafka.clients.producer.ProducerConfig: transaction.timeout.ms (This property is not yet supported)
TRANSACTION_TIMEOUT_DOC - Static variable in class org.oracle.okafka.clients.producer.ProducerConfig
TRANSACTIONAL_ID_CONFIG - Static variable in class org.oracle.okafka.clients.producer.ProducerConfig: transactional.id (This property is not yet supported)
TRANSACTIONAL_ID_DOC - Static variable in class org.oracle.okafka.clients.producer.ProducerConfig
TxEQAssignor - Class in org.oracle.okafka.clients.consumer: With Oracle Transactional Event Queue (TxEQ) and in Oracle RAC environment, different partitions of a Topic can be owned by different RAC instances.
TxEQAssignor() - Constructor for class org.oracle.okafka.clients.consumer.TxEQAssignor

U

unregisterBroker(int) - Method in interface org.oracle.okafka.clients.admin.Admin: Unregister a broker.
unregisterBroker(int, UnregisterBrokerOptions) - Method in interface org.oracle.okafka.clients.admin.Admin: Unregister a broker.
unregisterBroker(int, UnregisterBrokerOptions) - Method in class org.oracle.okafka.clients.admin.KafkaAdminClient
unsubscribe() - Method in class org.oracle.okafka.clients.consumer.KafkaConsumer: Unsubscribe from topic currently subscribed with KafkaConsumer.subscribe(Collection).
updateFeatures(Map<String, FeatureUpdate>, UpdateFeaturesOptions) - Method in interface org.oracle.okafka.clients.admin.Admin: Applies specified updates to finalized features.
updateFeatures(Map<String, FeatureUpdate>, UpdateFeaturesOptions) - Method in class org.oracle.okafka.clients.admin.KafkaAdminClient

V

VALUE_DESERIALIZER_CLASS_CONFIG - Static variable in class org.oracle.okafka.clients.consumer.ConsumerConfig: value.deserializer
VALUE_DESERIALIZER_CLASS_DOC - Static variable in class org.oracle.okafka.clients.consumer.ConsumerConfig
VALUE_SERIALIZER_CLASS_CONFIG - Static variable in class org.oracle.okafka.clients.producer.ProducerConfig: value.serializer
VALUE_SERIALIZER_CLASS_DOC - Static variable in class org.oracle.okafka.clients.producer.ProducerConfig
values() - Method in class org.oracle.okafka.clients.admin.DeleteTopicsResult: Return a map from topic names to futures which can be used to check the status of individual deletions.

W

wakeup() - Method in class org.oracle.okafka.clients.consumer.KafkaConsumer: This method is not yet supported.

A B C D E F G H I K L M N O P R S T U V W
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form