awslabs kinesis-kafka-connector issues

awslabs / kinesis-kafka-connector

kinesis-kafka-connector is connector based on Kafka Connect to publish messages to Amazon Kinesis streams or Amazon Kinesis Firehose.

Apache License 2.0

153 stars 91 forks source link

issues

Newest

Newest Most commented Recently updated Oldest Least commented Least recently updated

Support kafka message headers

#86 michaelwagler opened 8 months ago
0
Support for Individual AWS Credentials in Kinesis Connector Sink

#85 copernicium-112 opened 10 months ago
0
Versions updated to fix vulnerabilities

#84 brunoselvacj opened 1 year ago
0
Firehose: Bulk updates are not functional

#83 NiminU opened 1 year ago
1
Caused by: java.lang.ClassNotFoundException: com.google.common.util.concurrent.FutureCallback

#82 edha84564 opened 1 year ago
2
All messages ends up in same shard in Kinesis

#81 nenne70 opened 1 year ago
0
Create connector in MSK Connect

#80 nenne70 closed 1 year ago
1
ISSUE-77 Bump dependecy verions to resolve vulnerabilities

#78 ioanalex closed 1 year ago
2
CVEs reported on kinesis-kafka-connector

#77 nityavyas closed 1 year ago
8
Is it possible to read Avro data from MSK, and output it as JSON data to Kinesis?

#76 synchronizing closed 1 year ago
2
ISSUE-74 updating junits

#75 bdesert closed 1 year ago
0
ISSUE 74 - Build JAR in a standard way

#74 bdesert closed 1 year ago
0
Is it possible to change the format of the data being sinked to kinesis?

#73 miguellgramacho96 opened 1 year ago
1
[support]collect data from amazon msk to firehose

#72 tingxin opened 2 years ago
2
Invalid schema type when sending Avro message containing array of struct to Kinesis

#71 filpano opened 2 years ago
2
Memory Leak Issue for Kinesis Data Stream Sink Connector.

#70 shanhq96 opened 2 years ago
0
Caused by: org.apache.kafka.connect.runtime.rest.errors.BadRequestException: Connector config {internal.key.converter=org.apache.kafka.connect.json.JsonConverter, key.converter.schemas.enable=true, offset.storage.file.filename=offset.log, internal.value.converter.schemas.enable=true, internal.value.converter=org.apache.kafka.connect.json.JsonConverter, value.converter.schemas.enable=true, bootstrap.servers=127.0.0.1:9092, value.converter=org.apache.kafka.connect.storage.StringConverter, internal.key.converter.schemas.enable=true, key.converter=org.apache.kafka.connect.storage.StringConverter, schemas.enable=false} contains no connector type

#69 kapjoshi-cisco closed 2 years ago
1
Dockerize the connector

#68 masaruhoshi opened 2 years ago
3
How do i integrate this with the confluent connect container

#67 ecasilla opened 2 years ago
2
can't connect to Firehose with VPC Endpoint

#66 hellotherecsy opened 2 years ago
0
org.apache.kafka.common.errors.TimeoutException: Timed out waiting to send the call. Call: fetchMetadata

#65 paulseo0827 closed 2 years ago
2
Compatibility with MSK Connect

#64 RuiPinto93 closed 2 years ago
14
org.apache.kafka.connect.errors.ConnectException: Failed to find any class that implements Connector and which name matches com.amazon.kinesis.kafka.AmazonKinesisSinkConnector

#63 mdsufyan96 opened 3 years ago
2
Update README.md

#62 bdesert closed 3 years ago
0
Issue 60 vpc endpoint bug

#61 bdesert closed 3 years ago
0
VPC endpoint not supported

#60 dressst closed 3 years ago
0
ISSUE-54 Spelling

#59 bdesert closed 3 years ago
0
NPE in DataUtility.java line 35

#58 amaysakh opened 3 years ago
2
ISSUE-56 Fix NPE in DataUtility

#57 bdesert closed 3 years ago
0
NullPointerException in DataUtility.java

#56 amaysakh opened 3 years ago
2
java.io.IOException: Could not create tmp dir /tmp/amazon-kinesis-producer-native-binaries at com.amazonaws.services.kinesis.producer.KinesisProducer.extractBinaries(KinesisProducer.java:885)

#55 vidya-sva opened 3 years ago
1
Spelling Errors

#54 wildgordo closed 3 years ago
0
AmazonKinesisSinkTask.addUserRecord requires schema

#53 desavera opened 3 years ago
1
apply pause/unpase fix

#52 joeb-eb closed 3 years ago
0
SSL connection to broker

#51 atulrenapurkar opened 3 years ago
0
ISSUE-49: Fix propagation of KPL errors caught in FutureCallback.

#50 skidder closed 3 years ago
3
Kafka Connect 'DataException' instances are logged and swallowed by Futures

#49 skidder closed 3 years ago
0
Can kinesis-kafka-connector running on Kafka-connect cluster in aws account A write to a kinesis stream that exists in account B?

#48 rkrk3 closed 4 years ago
1
BUG: don't close the producer for the out-of-sync partitions

#47 zhiyanliu opened 4 years ago
0
Creat new distributed connector

#46 atulrenapurkar opened 4 years ago
3
ISSUE-44 Allow a task to run with an IAM role and external-id.

#45 skidder closed 4 years ago
3
Support IAM AssumeRole with an External ID

#44 skidder closed 4 years ago
0
java.lang.NoClassDefFoundError: com/amazonaws/services/kinesisfirehose/model/AmazonKinesisFirehoseException

#43 learner0101 opened 4 years ago
2
Is this project dead?

#42 deuscapturus closed 4 years ago
1
ISSUE-40 Support for China region

#41 JoeShi opened 5 years ago
0
Add support for China region

#40 JoeShi opened 5 years ago
1
Add kinesis and cloudwatch endpoint to config, allow to disable cert validation

#39 aidarko opened 5 years ago
0
Provide credentials via configuration

#38 marcinziolo opened 5 years ago
0
Upgrade to Kafka 2 and Kinesis 2 versions

#37 bdesert opened 5 years ago
0
ISSUE-35 - Update configs

#36 bdesert closed 5 years ago
0