- onAssigned(MetadataServiceAssignment, int) - Method in class io.confluent.security.store.kafka.coordinator.MetadataNodeManager
-
- onAssigned(MetadataServiceAssignment, int) - Method in interface io.confluent.security.store.kafka.coordinator.MetadataServiceRebalanceListener
-
Assignment completion notification generated when rebalance completes.
- onConsume(long, boolean) - Method in class io.confluent.security.store.kafka.clients.KafkaReader.PartitionState
-
- onConsumerRecord(ConsumerRecord<AuthKey, AuthValue>, AuthValue) - Method in class io.confluent.security.auth.dataplane.DataplaneBaseAuthStore
-
- onConsumerRecord(ConsumerRecord<AuthKey, AuthValue>, AuthValue) - Method in class io.confluent.security.auth.store.kafka.KafkaAuthStore
-
- onConsumerRecord(ConsumerRecord<AuthKey, AuthValue>, AuthValue) - Method in class io.confluent.security.auth.store.kafka.KafkaAuthWriter
-
- onConsumerRecord(ConsumerRecord<K, V>, V) - Method in interface io.confluent.security.store.kafka.clients.ConsumerListener
-
Notification of new record consumed by local reader
- onJoinComplete(int, String, String, ByteBuffer) - Method in class io.confluent.security.store.kafka.coordinator.MetadataServiceCoordinator
-
- onJoinPrepare(Timer, int, String) - Method in class io.confluent.security.store.kafka.coordinator.MetadataServiceCoordinator
-
- onLeaderElected(String, String, List<JoinGroupResponseData.JoinGroupResponseMember>, boolean) - Method in class io.confluent.security.store.kafka.coordinator.MetadataServiceCoordinator
-
- onProduceFailure(int) - Method in interface io.confluent.security.store.kafka.clients.StatusListener
-
Invoked when a record produce fails.
- onProduceSuccess(int) - Method in interface io.confluent.security.store.kafka.clients.StatusListener
-
Invoked when a record is successfully produced
- onReaderFailure() - Method in interface io.confluent.security.store.kafka.clients.StatusListener
-
Invoked if the consumer throws an exception while polling.
- onReaderSuccess() - Method in interface io.confluent.security.store.kafka.clients.StatusListener
-
Invoked when a record has been processed successfully by the consumer.
- onRecordConsumed(ConsumerRecord<K, V>, V, boolean) - Method in class io.confluent.security.store.kafka.clients.KafkaPartitionWriter
-
Notification of record consumed by the local reader.
- onRemoteFailure(int) - Method in interface io.confluent.security.store.kafka.clients.StatusListener
-
Invoked when FAILED status record is consumed.
- onRemoteSuccess(int) - Method in interface io.confluent.security.store.kafka.clients.StatusListener
-
Invoked when an INITIALIZED status record is consumed.
- onRevoked(int) - Method in class io.confluent.security.store.kafka.coordinator.MetadataNodeManager
-
- onRevoked(int) - Method in interface io.confluent.security.store.kafka.coordinator.MetadataServiceRebalanceListener
-
Assignment revocation notification generated when rebalance commences.
- onStatusConsumed(long, int, MetadataStoreStatus, Integer) - Method in class io.confluent.security.store.kafka.clients.KafkaPartitionWriter
-
Notification of writer status read by the local reader from this partition.
- onUpdate(ClusterResource) - Method in class io.confluent.security.auth.provider.ConfluentProvider
-
- onWriterFailure(int) - Method in class io.confluent.security.store.kafka.clients.KafkaPartitionWriter
-
- onWriterFailure(int) - Method in interface io.confluent.security.store.kafka.clients.StatusListener
-
Invoked if the writer fails due to a critical error and resigns.
- onWriterResigned(int) - Method in class io.confluent.security.store.kafka.coordinator.MetadataNodeManager
-
- onWriterResigned() - Method in class io.confluent.security.store.kafka.coordinator.MetadataNodeManager
-
- onWriterResigned(int) - Method in interface io.confluent.security.store.kafka.coordinator.MetadataServiceRebalanceListener
-
Writer resignation notification generated by the writer when an error
is encountered, cache refresh times out or a generation marker with
newer generation is is received.
- onWriterSuccess(int) - Method in interface io.confluent.security.store.kafka.clients.StatusListener
-
Invoked when the writer is successfully initialized.
- organizationId() - Method in class io.confluent.kafka.multitenant.NonKafkaLogicalClusterMetadata
-