jar

com.amazonaws : amazon-kinesis-client

Maven & Gradle

Jun 08, 2023
79 usages
629 stars

Amazon Kinesis Client Library for Java · The Amazon Kinesis Client Library for Java enables Java developers to easily consume and process data from Amazon Kinesis.

Table Of Contents

Latest Version

Download com.amazonaws : amazon-kinesis-client JAR file - Latest Versions:

All Versions

Download com.amazonaws : amazon-kinesis-client JAR file - All Versions:

Version Vulnerabilities Size Updated
1.15.x
1.14.x
1.13.x
1.12.x
1.11.x
1.10.x
1.9.x
1.8.x
1.7.x
1.6.x
1.5.x
1.4.x
1.3.x
1.2.x
1.1.x
1.0.x

View Java Class Source Code in JAR file

  1. Download JD-GUI to open JAR file and explore Java source code file (.class .java)
  2. Click menu "File → Open File..." or just drag-and-drop the JAR file in the JD-GUI window amazon-kinesis-client-1.15.0.jar file.
    Once you open a JAR file, all the java classes in the JAR file will be displayed.

com.amazonaws.services.kinesis.metrics.impl

├─ com.amazonaws.services.kinesis.metrics.impl.AccumulateByNameMetricsScope.class - [JAR]

├─ com.amazonaws.services.kinesis.metrics.impl.AccumulatingMetricsScope.class - [JAR]

├─ com.amazonaws.services.kinesis.metrics.impl.CWMetricKey.class - [JAR]

├─ com.amazonaws.services.kinesis.metrics.impl.CWMetricsFactory.class - [JAR]

├─ com.amazonaws.services.kinesis.metrics.impl.CWMetricsScope.class - [JAR]

├─ com.amazonaws.services.kinesis.metrics.impl.CWPublisherRunnable.class - [JAR]

├─ com.amazonaws.services.kinesis.metrics.impl.DefaultCWMetricsPublisher.class - [JAR]

├─ com.amazonaws.services.kinesis.metrics.impl.DimensionTrackingMetricsScope.class - [JAR]

├─ com.amazonaws.services.kinesis.metrics.impl.EndingMetricsScope.class - [JAR]

├─ com.amazonaws.services.kinesis.metrics.impl.FilteringMetricsScope.class - [JAR]

├─ com.amazonaws.services.kinesis.metrics.impl.ICWMetricsPublisher.class - [JAR]

├─ com.amazonaws.services.kinesis.metrics.impl.InterceptingMetricsFactory.class - [JAR]

├─ com.amazonaws.services.kinesis.metrics.impl.LogMetricsFactory.class - [JAR]

├─ com.amazonaws.services.kinesis.metrics.impl.LogMetricsScope.class - [JAR]

├─ com.amazonaws.services.kinesis.metrics.impl.MetricAccumulatingQueue.class - [JAR]

├─ com.amazonaws.services.kinesis.metrics.impl.MetricDatumWithKey.class - [JAR]

├─ com.amazonaws.services.kinesis.metrics.impl.MetricsHelper.class - [JAR]

├─ com.amazonaws.services.kinesis.metrics.impl.NullMetricsFactory.class - [JAR]

├─ com.amazonaws.services.kinesis.metrics.impl.NullMetricsScope.class - [JAR]

├─ com.amazonaws.services.kinesis.metrics.impl.ThreadSafeMetricsDelegatingFactory.class - [JAR]

├─ com.amazonaws.services.kinesis.metrics.impl.ThreadSafeMetricsDelegatingScope.class - [JAR]

com.amazonaws.services.kinesis.clientlibrary.proxies

├─ com.amazonaws.services.kinesis.clientlibrary.proxies.IKinesisProxy.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.proxies.IKinesisProxyExtended.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.proxies.IKinesisProxyFactory.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.proxies.KinesisProxy.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.proxies.KinesisProxyFactory.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.proxies.MetricsCollectingKinesisProxyDecorator.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.proxies.ShardClosureVerificationResponse.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.proxies.ShardListWrappingShardClosureVerificationResponse.class - [JAR]

com.amazonaws.services.kinesis.clientlibrary.exceptions

├─ com.amazonaws.services.kinesis.clientlibrary.exceptions.InvalidStateException.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.exceptions.KinesisClientLibDependencyException.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.exceptions.KinesisClientLibException.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.exceptions.KinesisClientLibNonRetryableException.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.exceptions.KinesisClientLibRetryableException.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.exceptions.ShutdownException.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.exceptions.ThrottlingException.class - [JAR]

com.amazonaws.services.kinesis.clientlibrary.utils

├─ com.amazonaws.services.kinesis.clientlibrary.utils.NamedThreadFactory.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.utils.RequestUtil.class - [JAR]

com.amazonaws.services.kinesis.multilang

├─ com.amazonaws.services.kinesis.multilang.DrainChildSTDERRTask.class - [JAR]

├─ com.amazonaws.services.kinesis.multilang.DrainChildSTDOUTTask.class - [JAR]

├─ com.amazonaws.services.kinesis.multilang.GetNextMessageTask.class - [JAR]

├─ com.amazonaws.services.kinesis.multilang.LineReaderTask.class - [JAR]

├─ com.amazonaws.services.kinesis.multilang.MessageReader.class - [JAR]

├─ com.amazonaws.services.kinesis.multilang.MessageWriter.class - [JAR]

├─ com.amazonaws.services.kinesis.multilang.MultiLangDaemon.class - [JAR]

├─ com.amazonaws.services.kinesis.multilang.MultiLangDaemonConfig.class - [JAR]

├─ com.amazonaws.services.kinesis.multilang.MultiLangProtocol.class - [JAR]

├─ com.amazonaws.services.kinesis.multilang.MultiLangRecordProcessor.class - [JAR]

├─ com.amazonaws.services.kinesis.multilang.MultiLangRecordProcessorFactory.class - [JAR]

├─ com.amazonaws.services.kinesis.multilang.package-info.class - [JAR]

com.amazonaws.services.kinesis.leases

├─ com.amazonaws.services.kinesis.leases.LeasePendingDeletion.class - [JAR]

com.amazonaws.services.kinesis.clientlibrary.config

├─ com.amazonaws.services.kinesis.clientlibrary.config.AWSCredentialsProviderPropertyValueDecoder.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.config.BooleanPropertyValueDecoder.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.config.ClientConfigurationPropertyValueDecoder.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.config.DatePropertyValueDecoder.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.config.IPropertyValueDecoder.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.config.InitialPositionInStreamPropertyValueDecoder.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.config.IntegerPropertyValueDecoder.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.config.KinesisClientLibConfigurator.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.config.LongPropertyValueDecoder.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.config.SetPropertyValueDecoder.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.config.StringPropertyValueDecoder.class - [JAR]

com.amazonaws.services.kinesis.clientlibrary.types

├─ com.amazonaws.services.kinesis.clientlibrary.types.ExtendedSequenceNumber.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.types.InitializationInput.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.types.Messages.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.types.ProcessRecordsInput.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.types.ShutdownInput.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.types.UserRecord.class - [JAR]

com.amazonaws.services.kinesis.clientlibrary.interfaces

├─ com.amazonaws.services.kinesis.clientlibrary.interfaces.ICheckpoint.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.interfaces.IPreparedCheckpointer.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.interfaces.IRecordProcessor.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.interfaces.IRecordProcessorCheckpointer.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.interfaces.IRecordProcessorFactory.class - [JAR]

com.amazonaws.services.kinesis.multilang.messages

├─ com.amazonaws.services.kinesis.multilang.messages.CheckpointMessage.class - [JAR]

├─ com.amazonaws.services.kinesis.multilang.messages.InitializeMessage.class - [JAR]

├─ com.amazonaws.services.kinesis.multilang.messages.JsonFriendlyRecord.class - [JAR]

├─ com.amazonaws.services.kinesis.multilang.messages.Message.class - [JAR]

├─ com.amazonaws.services.kinesis.multilang.messages.ProcessRecordsMessage.class - [JAR]

├─ com.amazonaws.services.kinesis.multilang.messages.ShutdownMessage.class - [JAR]

├─ com.amazonaws.services.kinesis.multilang.messages.ShutdownRequestedMessage.class - [JAR]

├─ com.amazonaws.services.kinesis.multilang.messages.StatusMessage.class - [JAR]

com.amazonaws.services.kinesis.leases.impl

├─ com.amazonaws.services.kinesis.leases.impl.GenericLeaseSelector.class - [JAR]

├─ com.amazonaws.services.kinesis.leases.impl.HashKeyRangeForLease.class - [JAR]

├─ com.amazonaws.services.kinesis.leases.impl.KinesisClientLease.class - [JAR]

├─ com.amazonaws.services.kinesis.leases.impl.KinesisClientLeaseManager.class - [JAR]

├─ com.amazonaws.services.kinesis.leases.impl.KinesisClientLeaseSerializer.class - [JAR]

├─ com.amazonaws.services.kinesis.leases.impl.Lease.class - [JAR]

├─ com.amazonaws.services.kinesis.leases.impl.LeaseCleanupManager.class - [JAR]

├─ com.amazonaws.services.kinesis.leases.impl.LeaseCoordinator.class - [JAR]

├─ com.amazonaws.services.kinesis.leases.impl.LeaseManager.class - [JAR]

├─ com.amazonaws.services.kinesis.leases.impl.LeaseRenewer.class - [JAR]

├─ com.amazonaws.services.kinesis.leases.impl.LeaseSerializer.class - [JAR]

├─ com.amazonaws.services.kinesis.leases.impl.LeaseTaker.class - [JAR]

├─ com.amazonaws.services.kinesis.leases.impl.UpdateField.class - [JAR]

com.amazonaws.services.kinesis.clientlibrary.lib.worker

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.AsynchronousGetRecordsRetrievalStrategy.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.BlockOnParentShardTask.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.BlockingGetRecordsCache.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.CheckpointValueComparator.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.DataFetcherResult.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.DataFetchingStrategy.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.DeterministicShuffleShardSyncLeaderDecider.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.DoesNothingPreparedCheckpointer.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.EmptyLeaseTableSynchronizer.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.GetRecordsCache.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.GetRecordsRetrievalStrategy.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.GetRecordsRetriever.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.GracefulShutdownContext.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.GracefulShutdownCoordinator.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.IDataFetcher.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.IPeriodicShardSyncManager.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.IShardConsumer.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.IShardConsumerFactory.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.ITask.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.InitialPositionInStream.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.InitialPositionInStreamExtended.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.InitializeTask.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibLeaseCoordinator.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisConsumerStates.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisDataFetcher.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisLeaseCleanupValidator.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisPeriodicShardSyncManager.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisShardConsumer.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisShardConsumerFactory.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisShardSyncer.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisShutdownTask.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.LeaderDecider.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.LeaseCleanupValidator.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.LeaseSynchronizer.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.MetricsCollectingTaskDecorator.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.NoOpShardPrioritization.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.NoOpWorkerStateChangeListener.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.NonEmptyLeaseTableSynchronizer.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.ParentsFirstShardPrioritization.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.PeriodicShardSyncManager.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.PeriodicShardSyncStrategy.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.PrefetchGetRecordsCache.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.PreparedCheckpointer.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.ProcessTask.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.RecordProcessorCheckpointer.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.RecordsFetcherFactory.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.SequenceNumberValidator.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.ShardConsumerShutdownNotification.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.ShardEndShardSyncStrategy.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.ShardInfo.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.ShardPrioritization.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.ShardSyncStrategy.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.ShardSyncStrategyType.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.ShardSyncTask.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.ShardSyncTaskManager.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.ShardSyncer.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.ShutdownNotification.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.ShutdownNotificationTask.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.ShutdownReason.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.SimpleRecordsFetcherFactory.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.StreamConfig.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.SynchronousGetRecordsRetrievalStrategy.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.TaskResult.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.TaskType.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.ThrottlingReporter.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.V1ToV2RecordProcessorAdapter.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.V1ToV2RecordProcessorFactoryAdapter.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.Worker.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.worker.WorkerStateChangeListener.class - [JAR]

com.amazonaws.services.kinesis.leases.exceptions

├─ com.amazonaws.services.kinesis.leases.exceptions.CustomerApplicationException.class - [JAR]

├─ com.amazonaws.services.kinesis.leases.exceptions.DependencyException.class - [JAR]

├─ com.amazonaws.services.kinesis.leases.exceptions.InvalidStateException.class - [JAR]

├─ com.amazonaws.services.kinesis.leases.exceptions.LeasingException.class - [JAR]

├─ com.amazonaws.services.kinesis.leases.exceptions.ProvisionedThroughputException.class - [JAR]

com.amazonaws.services.kinesis.clientlibrary.interfaces.v2

├─ com.amazonaws.services.kinesis.clientlibrary.interfaces.v2.IRecordProcessor.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.interfaces.v2.IRecordProcessorFactory.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.interfaces.v2.IShutdownNotificationAware.class - [JAR]

com.amazonaws.services.kinesis.leases.util

├─ com.amazonaws.services.kinesis.leases.util.DynamoUtils.class - [JAR]

com.amazonaws.services.kinesis.metrics.interfaces

├─ com.amazonaws.services.kinesis.metrics.interfaces.IMetricsFactory.class - [JAR]

├─ com.amazonaws.services.kinesis.metrics.interfaces.IMetricsScope.class - [JAR]

├─ com.amazonaws.services.kinesis.metrics.interfaces.MetricsLevel.class - [JAR]

com.amazonaws.services.kinesis.clientlibrary.exceptions.internal

├─ com.amazonaws.services.kinesis.clientlibrary.exceptions.internal.BlockedOnParentShardException.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.exceptions.internal.KinesisClientLibIOException.class - [JAR]

com.amazonaws.services.kinesis.clientlibrary.lib.checkpoint

├─ com.amazonaws.services.kinesis.clientlibrary.lib.checkpoint.Checkpoint.class - [JAR]

├─ com.amazonaws.services.kinesis.clientlibrary.lib.checkpoint.SentinelCheckpoint.class - [JAR]

com.amazonaws.services.kinesis.leases.interfaces

├─ com.amazonaws.services.kinesis.leases.interfaces.IKinesisClientLeaseManager.class - [JAR]

├─ com.amazonaws.services.kinesis.leases.interfaces.ILeaseManager.class - [JAR]

├─ com.amazonaws.services.kinesis.leases.interfaces.ILeaseRenewer.class - [JAR]

├─ com.amazonaws.services.kinesis.leases.interfaces.ILeaseSerializer.class - [JAR]

├─ com.amazonaws.services.kinesis.leases.interfaces.ILeaseTaker.class - [JAR]

├─ com.amazonaws.services.kinesis.leases.interfaces.LeaseSelector.class - [JAR]

Advertisement

Dependencies from Group

Aug 25, 2023
1.1k usages
3.9k stars
Aug 25, 2023
906 usages
3.9k stars
Aug 25, 2023
681 usages
3.9k stars
Aug 25, 2023
432 usages
3.9k stars
Aug 25, 2023
349 usages
4k stars

Discover Dependencies

Aug 24, 2023
1.9k usages
73k stars
May 15, 2023
1 usages
7.3k stars
May 19, 2023
127 usages
506 stars
May 19, 2023
21.5k stars
Apr 08, 2021
52 usages
161 stars
Jan 05, 2016
1 usages
3.6k stars
Aug 10, 2023
49 usages
290 stars
Apr 24, 2023
523 usages
6.1k stars
Jun 22, 2022
42 usages