Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Update groupId to software.amazon.kinesis #615

Merged
merged 1 commit into from
Dec 13, 2024
Merged

Update groupId to software.amazon.kinesis #615

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion aws/kinesis/protobuf/config.proto
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
syntax = "proto2";
package aws.kinesis.protobuf;

option java_package = "com.amazonaws.services.kinesis.producer.protobuf";
option java_package = "software.amazon.kinesis.producer.protobuf";

message AdditionalDimension {
required string key = 1;
Expand Down
2 changes: 1 addition & 1 deletion aws/kinesis/protobuf/messages.proto
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@ syntax = "proto2";
import "config.proto";

package aws.kinesis.protobuf;
option java_package = "com.amazonaws.services.kinesis.producer.protobuf";
option java_package = "software.amazon.kinesis.producer.protobuf";

message Tag {
required string key = 1;
Expand Down
4 changes: 2 additions & 2 deletions java/amazon-kinesis-producer-sample/README.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -41,11 +41,11 @@ mvn clean package
Then run the producer to put some data into a stream called ``kpltest`` in ``us-west-2`` for ``100 seconds``:

```
mvn exec:java -Dexec.mainClass="com.amazonaws.services.kinesis.producer.sample.SampleProducer" -Dexec.args="kpltest us-west-2 100"
mvn exec:java -Dexec.mainClass="software.amazon.kinesis.producer.sample.SampleProducer" -Dexec.args="kpltest us-west-2 100"
```

Finally run the consumer to retrieve the data from a stream called ``kpltest`` in ``us-west-2``:

```
mvn exec:java -Dexec.mainClass="com.amazonaws.services.kinesis.producer.sample.SampleConsumer" -Dexec.args="kpltest us-west-2"
mvn exec:java -Dexec.mainClass="software.amazon.kinesis.producer.sample.SampleConsumer" -Dexec.args="kpltest us-west-2"
```
6 changes: 3 additions & 3 deletions java/amazon-kinesis-producer-sample/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>com.amazonaws</groupId>
<groupId>software.amazon.kinesis</groupId>
<artifactId>amazon-kinesis-producer-sample</artifactId>
<version>1.0.0</version>
<build>
Expand All @@ -28,7 +28,7 @@
<configuration>
<transformers>
<transformer implementation="org.apache.maven.plugins.shade.resource.ManifestResourceTransformer">
<mainClass>com.amazonaws.services.kinesis.producer.sample.SampleProducer</mainClass>
<mainClass>software.amazon.kinesis.producer.sample.SampleProducer</mainClass>
</transformer>
</transformers>
</configuration>
Expand All @@ -52,7 +52,7 @@
</exclusions>
</dependency>
<dependency>
<groupId>com.amazonaws</groupId>
<groupId>software.amazon.kinesis</groupId>
<artifactId>amazon-kinesis-producer</artifactId>
<version>1.0.0</version>
</dependency>
Expand Down
14 changes: 7 additions & 7 deletions ...er/sample/MetricsAwareSampleProducer.java → ...er/sample/MetricsAwareSampleProducer.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@
* limitations under the License.
*/

package com.amazonaws.services.kinesis.producer.sample;
package software.amazon.kinesis.producer.sample;

import java.nio.ByteBuffer;
import java.util.concurrent.ExecutionException;
Expand All @@ -24,12 +24,12 @@
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.amazonaws.services.kinesis.producer.Attempt;
import com.amazonaws.services.kinesis.producer.KinesisProducerConfiguration;
import com.amazonaws.services.kinesis.producer.KinesisProducer;
import com.amazonaws.services.kinesis.producer.Metric;
import com.amazonaws.services.kinesis.producer.UserRecordFailedException;
import com.amazonaws.services.kinesis.producer.UserRecordResult;
import software.amazon.kinesis.producer.Attempt;
import software.amazon.kinesis.producer.KinesisProducerConfiguration;
import software.amazon.kinesis.producer.KinesisProducer;
import software.amazon.kinesis.producer.Metric;
import software.amazon.kinesis.producer.UserRecordFailedException;
import software.amazon.kinesis.producer.UserRecordResult;
import com.google.common.collect.Iterables;
import com.google.common.util.concurrent.FutureCallback;
import com.google.common.util.concurrent.Futures;
Expand Down
2 changes: 1 addition & 1 deletion ...nesis/producer/sample/SampleConsumer.java → ...nesis/producer/sample/SampleConsumer.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@
* limitations under the License.
*/

package com.amazonaws.services.kinesis.producer.sample;
package software.amazon.kinesis.producer.sample;

import java.util.ArrayList;
import java.util.Collections;
Expand Down
14 changes: 7 additions & 7 deletions ...nesis/producer/sample/SampleProducer.java → ...nesis/producer/sample/SampleProducer.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@
* limitations under the License.
*/

package com.amazonaws.services.kinesis.producer.sample;
package software.amazon.kinesis.producer.sample;

import java.nio.ByteBuffer;
import java.util.concurrent.Executors;
Expand All @@ -22,14 +22,14 @@
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicLong;

import com.amazonaws.services.kinesis.producer.UnexpectedMessageException;
import software.amazon.kinesis.producer.UnexpectedMessageException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.amazonaws.services.kinesis.producer.Attempt;
import com.amazonaws.services.kinesis.producer.KinesisProducer;
import com.amazonaws.services.kinesis.producer.UserRecordFailedException;
import com.amazonaws.services.kinesis.producer.UserRecordResult;
import software.amazon.kinesis.producer.Attempt;
import software.amazon.kinesis.producer.KinesisProducer;
import software.amazon.kinesis.producer.UserRecordFailedException;
import software.amazon.kinesis.producer.UserRecordResult;
import com.google.common.util.concurrent.FutureCallback;
import com.google.common.util.concurrent.Futures;
import com.google.common.util.concurrent.ListenableFuture;
Expand Down Expand Up @@ -73,7 +73,7 @@ public class SampleProducer {

/** The main method.
* @param args The command line args for the Sample Producer.
* @see com.amazonaws.services.kinesis.producer.sample.SampleProducerConfig for positional arg ordering.
* @see software.amazon.kinesis.producer.sample.SampleProducerConfig for positional arg ordering.
*/
public static void main(String[] args) throws Exception {
final SampleProducerConfig config = new SampleProducerConfig(args);
Expand Down
4 changes: 2 additions & 2 deletions ...producer/sample/SampleProducerConfig.java → ...producer/sample/SampleProducerConfig.java
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
package com.amazonaws.services.kinesis.producer.sample;
package software.amazon.kinesis.producer.sample;

import com.amazonaws.services.kinesis.producer.KinesisProducerConfiguration;
import software.amazon.kinesis.producer.KinesisProducerConfiguration;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import software.amazon.awssdk.auth.credentials.DefaultCredentialsProvider;
Expand Down
2 changes: 1 addition & 1 deletion ...rvices/kinesis/producer/sample/Utils.java → ...amazon/kinesis/producer/sample/Utils.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@
* limitations under the License.
*/

package com.amazonaws.services.kinesis.producer.sample;
package software.amazon.kinesis.producer.sample;

import java.io.UnsupportedEncodingException;
import java.math.BigInteger;
Expand Down
4 changes: 2 additions & 2 deletions java/amazon-kinesis-producer/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>com.amazonaws</groupId>
<groupId>software.amazon.kinesis</groupId>
<artifactId>amazon-kinesis-producer</artifactId>
<version>1.0.0</version>
<name>Amazon Kinesis Producer Library</name>
Expand Down Expand Up @@ -36,7 +36,7 @@
<artifactId>maven-javadoc-plugin</artifactId>
<version>3.4.1</version>
<configuration>
<excludePackageNames>com.amazonaws.services.kinesis.producer.protobuf</excludePackageNames>
<excludePackageNames>software.amazon.kinesis.producer.protobuf</excludePackageNames>
</configuration>
<executions>
<execution>
Expand Down
4 changes: 2 additions & 2 deletions ...ws/services/kinesis/producer/Attempt.java → ...ware/amazon/kinesis/producer/Attempt.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -13,9 +13,9 @@
* limitations under the License.
*/

package com.amazonaws.services.kinesis.producer;
package software.amazon.kinesis.producer;

import com.amazonaws.services.kinesis.producer.protobuf.Messages;
import software.amazon.kinesis.producer.protobuf.Messages;

/**
* Represents one attempt at writing a record to the backend. The attempt may or
Expand Down
2 changes: 1 addition & 1 deletion ...inesis/producer/BinaryToHexConverter.java → ...inesis/producer/BinaryToHexConverter.java
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package com.amazonaws.services.kinesis.producer;
package software.amazon.kinesis.producer;

public class BinaryToHexConverter {

Expand Down
2 changes: 1 addition & 1 deletion ...inesis/producer/CertificateExtractor.java → ...inesis/producer/CertificateExtractor.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package com.amazonaws.services.kinesis.producer;
package software.amazon.kinesis.producer;

import java.io.File;
import java.io.IOException;
Expand Down
6 changes: 3 additions & 3 deletions ...aws/services/kinesis/producer/Daemon.java → ...tware/amazon/kinesis/producer/Daemon.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -13,10 +13,10 @@
* limitations under the License.
*/

package com.amazonaws.services.kinesis.producer;
package software.amazon.kinesis.producer;

import com.amazonaws.services.kinesis.producer.protobuf.Messages;
import com.amazonaws.services.kinesis.producer.protobuf.Messages.Message;
import software.amazon.kinesis.producer.protobuf.Messages;
import software.amazon.kinesis.producer.protobuf.Messages.Message;
import com.google.common.util.concurrent.ThreadFactoryBuilder;
import com.google.protobuf.ByteString;
import org.apache.commons.lang3.StringUtils;
Expand Down
2 changes: 1 addition & 1 deletion ...ces/kinesis/producer/DaemonException.java → ...zon/kinesis/producer/DaemonException.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@
* limitations under the License.
*/

package com.amazonaws.services.kinesis.producer;
package software.amazon.kinesis.producer;

public class DaemonException extends RuntimeException {
private static final long serialVersionUID = -1161618354800585162L;
Expand Down
2 changes: 1 addition & 1 deletion ...ices/kinesis/producer/FileAgeManager.java → ...azon/kinesis/producer/FileAgeManager.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package com.amazonaws.services.kinesis.producer;
package software.amazon.kinesis.producer;

import com.google.common.util.concurrent.ThreadFactoryBuilder;
import org.slf4j.Logger;
Expand Down
2 changes: 1 addition & 1 deletion ...sis/producer/FutureTimedOutException.java → ...sis/producer/FutureTimedOutException.java
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package com.amazonaws.services.kinesis.producer;
package software.amazon.kinesis.producer;

/*
* Copyright 2019 Amazon.com, Inc. or its affiliates.
Expand Down
2 changes: 1 addition & 1 deletion ...GlueSchemaRegistrySerializerInstance.java → ...GlueSchemaRegistrySerializerInstance.java
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package com.amazonaws.services.kinesis.producer;
package software.amazon.kinesis.producer;

import com.amazonaws.services.schemaregistry.common.configs.GlueSchemaRegistryConfiguration;
import com.amazonaws.services.schemaregistry.serializers.GlueSchemaRegistrySerializer;
Expand Down
2 changes: 1 addition & 1 deletion ...es/kinesis/producer/HashedFileCopier.java → ...on/kinesis/producer/HashedFileCopier.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package com.amazonaws.services.kinesis.producer;
package software.amazon.kinesis.producer;

import java.io.File;
import java.io.FileInputStream;
Expand Down
2 changes: 1 addition & 1 deletion ...es/kinesis/producer/IKinesisProducer.java → ...on/kinesis/producer/IKinesisProducer.java
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package com.amazonaws.services.kinesis.producer;
package software.amazon.kinesis.producer;

import java.nio.ByteBuffer;
import java.util.List;
Expand Down
2 changes: 1 addition & 1 deletion .../kinesis/producer/IrrecoverableError.java → .../kinesis/producer/IrrecoverableError.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@
* limitations under the License.
*/

package com.amazonaws.services.kinesis.producer;
package software.amazon.kinesis.producer;

public class IrrecoverableError extends RuntimeException {
private static final long serialVersionUID = 2657526423645068574L;
Expand Down
14 changes: 7 additions & 7 deletions ...ces/kinesis/producer/KinesisProducer.java → ...zon/kinesis/producer/KinesisProducer.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -13,14 +13,14 @@
* limitations under the License.
*/

package com.amazonaws.services.kinesis.producer;
package software.amazon.kinesis.producer;

import com.amazonaws.services.kinesis.producer.protobuf.Messages;
import com.amazonaws.services.kinesis.producer.protobuf.Messages.Flush;
import com.amazonaws.services.kinesis.producer.protobuf.Messages.Message;
import com.amazonaws.services.kinesis.producer.protobuf.Messages.MetricsRequest;
import com.amazonaws.services.kinesis.producer.protobuf.Messages.MetricsResponse;
import com.amazonaws.services.kinesis.producer.protobuf.Messages.PutRecord;
import software.amazon.kinesis.producer.protobuf.Messages;
import software.amazon.kinesis.producer.protobuf.Messages.Flush;
import software.amazon.kinesis.producer.protobuf.Messages.Message;
import software.amazon.kinesis.producer.protobuf.Messages.MetricsRequest;
import software.amazon.kinesis.producer.protobuf.Messages.MetricsResponse;
import software.amazon.kinesis.producer.protobuf.Messages.PutRecord;
import com.amazonaws.services.schemaregistry.common.Schema;
import com.amazonaws.services.schemaregistry.serializers.GlueSchemaRegistrySerializer;
import com.google.common.collect.ImmutableMap;
Expand Down
8 changes: 4 additions & 4 deletions ...roducer/KinesisProducerConfiguration.java → ...roducer/KinesisProducerConfiguration.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -13,11 +13,11 @@
* limitations under the License.
*/

package com.amazonaws.services.kinesis.producer;
package software.amazon.kinesis.producer;

import com.amazonaws.services.kinesis.producer.protobuf.Config.AdditionalDimension;
import com.amazonaws.services.kinesis.producer.protobuf.Config.Configuration;
import com.amazonaws.services.kinesis.producer.protobuf.Messages.Message;
import software.amazon.kinesis.producer.protobuf.Config.AdditionalDimension;
import software.amazon.kinesis.producer.protobuf.Config.Configuration;
import software.amazon.kinesis.producer.protobuf.Messages.Message;
import com.amazonaws.services.schemaregistry.common.configs.GlueSchemaRegistryConfiguration;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
Expand Down
2 changes: 1 addition & 1 deletion ...inesis/producer/LogInputStreamReader.java → ...inesis/producer/LogInputStreamReader.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@
* limitations under the License.
*/

package com.amazonaws.services.kinesis.producer;
package software.amazon.kinesis.producer;

import org.apache.commons.io.Charsets;
import org.apache.commons.lang3.StringUtils;
Expand Down
8 changes: 4 additions & 4 deletions ...aws/services/kinesis/producer/Metric.java → ...tware/amazon/kinesis/producer/Metric.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -13,14 +13,14 @@
* limitations under the License.
*/

package com.amazonaws.services.kinesis.producer;
package software.amazon.kinesis.producer;

import java.util.Collections;
import java.util.LinkedHashMap;
import java.util.Map;

import com.amazonaws.services.kinesis.producer.protobuf.Messages.Dimension;
import com.amazonaws.services.kinesis.producer.protobuf.Messages.Stats;
import software.amazon.kinesis.producer.protobuf.Messages.Dimension;
import software.amazon.kinesis.producer.protobuf.Messages.Stats;

/**
* A metric consists of a name, a list of dimensions, a set of statistics, and
Expand Down Expand Up @@ -90,7 +90,7 @@ public long getDuration() {
return duration;
}

protected Metric(com.amazonaws.services.kinesis.producer.protobuf.Messages.Metric m) {
protected Metric(software.amazon.kinesis.producer.protobuf.Messages.Metric m) {
this.name = m.getName();
this.duration = m.getSeconds();

Expand Down
2 changes: 1 addition & 1 deletion ...esis/producer/ProcessFailureBehavior.java → ...esis/producer/ProcessFailureBehavior.java
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package com.amazonaws.services.kinesis.producer;
package software.amazon.kinesis.producer;

public enum ProcessFailureBehavior {
Shutdown, AutoRestart
Expand Down
2 changes: 1 addition & 1 deletion .../producer/UnexpectedMessageException.java → .../producer/UnexpectedMessageException.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@
* limitations under the License.
*/

package com.amazonaws.services.kinesis.producer;
package software.amazon.kinesis.producer;

public class UnexpectedMessageException extends Exception {
private static final long serialVersionUID = 3168271192277927600L;
Expand Down
2 changes: 1 addition & 1 deletion ...services/kinesis/producer/UserRecord.java → ...e/amazon/kinesis/producer/UserRecord.java
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package com.amazonaws.services.kinesis.producer;
package software.amazon.kinesis.producer;

import com.amazonaws.services.schemaregistry.common.Schema;

Expand Down
2 changes: 1 addition & 1 deletion ...s/producer/UserRecordFailedException.java → ...s/producer/UserRecordFailedException.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@
* limitations under the License.
*/

package com.amazonaws.services.kinesis.producer;
package software.amazon.kinesis.producer;

public class UserRecordFailedException extends Exception {
private static final long serialVersionUID = 3168271192277927600L;
Expand Down
4 changes: 2 additions & 2 deletions ...es/kinesis/producer/UserRecordResult.java → ...on/kinesis/producer/UserRecordResult.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -13,12 +13,12 @@
* limitations under the License.
*/

package com.amazonaws.services.kinesis.producer;
package software.amazon.kinesis.producer;

import java.util.ArrayList;
import java.util.List;

import com.amazonaws.services.kinesis.producer.protobuf.Messages;
import software.amazon.kinesis.producer.protobuf.Messages;
import com.google.common.collect.ImmutableList;

/**
Expand Down
2 changes: 1 addition & 1 deletion ...is/producer/BinaryToHexConverterTest.java → ...is/producer/BinaryToHexConverterTest.java
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package com.amazonaws.services.kinesis.producer;
package software.amazon.kinesis.producer;

import org.junit.Test;

Expand Down
2 changes: 1 addition & 1 deletion ...is/producer/CertificateExtractorTest.java → ...is/producer/CertificateExtractorTest.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package com.amazonaws.services.kinesis.producer;
package software.amazon.kinesis.producer;

import java.io.File;
import java.io.FileOutputStream;
Expand Down
Loading