JarCasting
JarCasting JarCasting

pincette-jes-prodcon

Command line Kafka producer and consumer for JSON Event Sourcing

License

License
Categories

Categories

Net
GroupId

GroupId

net.pincette
ArtifactId

ArtifactId

pincette-jes-prodcon
Last Version

Last Version

1.0.2
Release Date

Release Date
Type

Type

jar
Description

Description

pincette-jes-prodcon
Command line Kafka producer and consumer for JSON Event Sourcing
Project URL

Project URL

https://github.com/json-event-sourcing/pincette-jes-prodcon
Project Organization

Project Organization

Pincette
Source Code Management

Source Code Management

https://github.com/json-event-sourcing/pincette-jes-prodcon

Download pincette-jes-prodcon

Filename Size
pincette-jes-prodcon-1.0.2.pom
pincette-jes-prodcon-1.0.2.jar 10 KB
pincette-jes-prodcon-1.0.2-sources.jar 6 KB
pincette-jes-prodcon-1.0.2-javadoc.jar 32 KB
pincette-jes-prodcon-1.0.2-jar-with-dependencies.jar 31 MB
Browse

How to add to project

<!-- https://jarcasting.com/artifacts/net.pincette/pincette-jes-prodcon/ -->
<dependency>
    <groupId>net.pincette</groupId>
    <artifactId>pincette-jes-prodcon</artifactId>
    <version>1.0.2</version>
</dependency>
// https://jarcasting.com/artifacts/net.pincette/pincette-jes-prodcon/
implementation 'net.pincette:pincette-jes-prodcon:1.0.2'
// https://jarcasting.com/artifacts/net.pincette/pincette-jes-prodcon/
implementation ("net.pincette:pincette-jes-prodcon:1.0.2")
'net.pincette:pincette-jes-prodcon:jar:1.0.2'
<dependency org="net.pincette" name="pincette-jes-prodcon" rev="1.0.2">
  <artifact name="pincette-jes-prodcon" type="jar" />
</dependency>
@Grapes(
@Grab(group='net.pincette', module='pincette-jes-prodcon', version='1.0.2')
)
libraryDependencies += "net.pincette" % "pincette-jes-prodcon" % "1.0.2"
[net.pincette/pincette-jes-prodcon "1.0.2"]

Dependencies

compile (6)

Group / Artifact Type Version
org.apache.kafka : kafka-clients jar 2.7.0
net.pincette : pincette-common jar 1.7.9
net.pincette : pincette-jes-util jar 1.3.12
org.glassfish : javax.json jar 1.1.4
org.slf4j : slf4j-log4j12 jar 1.7.30
log4j : log4j jar 1.2.17

Project Modules

There are no modules declared in this project.

JSON Event Sourcing Console Consumer and Producer

This command-line tool can consume JSON messages, serialized with the JES serializer, from a Kafka topic. It writes one message per line to the console. It can also produce messages on a Kafka topic using the JES serializer. The input from the console can be one JSON object or an array of JSON objects. The field _id is used for the message key.

You can build it with mvn clean package.

Run it as follows:

> java -jar target/pincette-jes-prodcon-<version>-jar-with-dependencies.jar
  (consume | produce)
  (-c | --config-file) $HOME/.ccloud/config
  (-t | --topic) topic

It reads from stdin when producing and writes to stdout when consuming. The format of the configuration file is the same as for your ccloud configuration.

See also the API documentation.

net.pincette

JSON Event Sourcing

JSON Event Sourcing

Versions

Version
1.0.2
1.0.1
1.0