Skip to content
This repository was archived by the owner on Apr 13, 2022. It is now read-only.
Open
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
19 commits
Select commit Hold shift + click to select a range
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
6 changes: 6 additions & 0 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -4,10 +4,16 @@ kafka-s3-consumer
Store batched Kafka messages in S3.

Build
-----------------

mvn package

Run
-----------------

java -jar kafka-s3-consumer-1.0.jar <props>

#in order to start after some time of inactivity (so there are logs stored,
#but the gap is larger between last uploaded log end the first record in kafka

java -jar kafka-s3-consumer-1.0.jar <props> clean
21 changes: 21 additions & 0 deletions kafka-s3-consumer.properties
Original file line number Diff line number Diff line change
@@ -0,0 +1,21 @@
# Kafka settings
kafka.host=127.0.0.1
kafka.port=9092
kafka.brokerid=0
kafka.topics=topic:1
#max size of a single message in the queue
kafka.maxmessagesize=4096

# S3 settings
s3.accesskey=$AWS_ACCESS_KEY_ID
s3.secretkey=$AWS_SECRET_ACCESS_KEY

# Consumer settings
s3.bucket=persuasionapi-test
s3.prefix=s3-consumer

#object size 1024*1024*10 = 10mb (10506200)
s3.maxobjectsize=10506200

#compress the file which is send to s3
s3.compression=true
2 changes: 1 addition & 1 deletion pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -42,7 +42,7 @@
<dependency>
<groupId>kafka</groupId>
<artifactId>kafka</artifactId>
<version>0.7.1</version>
<version>0.7.2</version>
</dependency>

<dependency>
Expand Down
Binary file added repo/kafka/kafka/0.7.2/kafka-0.7.2.jar
Binary file not shown.
Loading