The eo-kafka from eo-cqrs

log information data and its pipeline

log.info or log.debug some data in methods, where we are consuming, sending, or processing data

it cases for KfConsumer and KfProducer

we need to create a few integration tests with Consumer and Producer;
this ticket can be closed after #81 will be implemented

Consumer.java:31-35: Consume method. We must create a...

The puzzle 48-2996689e from #48 has to be resolved:

eo-kafka/src/main/java/org/eocqrs/kafka/Consumer.java

Lines 31 to 35 in 549c573

    
            * @todo #48:60m/DEV Consume method. 
        
            * We must create a consume method that 
        
            * will accept the meta-information and the message. 
        
            * Perhaps we need to create a new class, say. 
        
            * `class MsgData` or something like that.

The puzzle was created by @h1alexbel on 25-Feb-23.

Estimate: 60 minutes, role: DEV.

If you have any technical questions, don't ask me, submit new tickets instead. The task will be "done" when the problem is fixed and the text of the puzzle is removed from the source code. Here is more about PDD and about me.

codecov

consumer-api

KfProducerSettings.java:20: test producer construction

The puzzle 26-7c38feaf from #26 has to be resolved:

eo-kafka/src/main/java/org/eocqrs/kafka/KfProducerSettings.java

Line 20 in 4da907a

* @todo #26:20m/DEV test producer construction

The puzzle was created by @h1alexbel on 22-Feb-23.

Estimate: 20 minutes, role: DEV.

If you have any technical questions, don't ask me, submit new tickets instead. The task will be "done" when the problem is fixed and the text of the puzzle is removed from the source code. Here is more about PDD and about me.

FkConsumer.java:36: Fake Consumer implementation

The puzzle 49-da1616f3 from #49 has to be resolved:

eo-kafka/src/main/java/org/eocqrs/kafka/fake/FkConsumer.java

Line 36 in 446bb97

* @todo #49:45m/DEV Fake Consumer implementation

The puzzle was created by @h1alexbel on 26-Feb-23.

Estimate: 45 minutes, role: DEV.

If you have any technical questions, don't ask me, submit new tickets instead. The task will be "done" when the problem is fixed and the text of the puzzle is removed from the source code. Here is more about PDD and about me.

consumer config

XSD schema for consumer.xml

KfProducerTest.java:39-41: Too much time. This test takes...

The puzzle 46-4ddc69d8 from #46 has to be resolved:

eo-kafka/src/test/java/org/eocqrs/kafka/KfProducerTest.java

Lines 39 to 41 in 83a8e75

    
            * @todo #46:60m/DEV Too much time. 
        
            * This test takes too long to run, it should be an integration test, 
        
            * or we should do something about the execution speed.

The puzzle was created by @h1alexbel on 25-Feb-23.

Estimate: 60 minutes, role: DEV.

If you have any technical questions, don't ask me, submit new tickets instead. The task will be "done" when the problem is fixed and the text of the puzzle is removed from the source code. Here is more about PDD and about me.

readme

rultor java 17

consumer.xml:27-28: Consumer settings in XML -->

The puzzle 25-2c1d96ec from #25 has to be resolved:

eo-kafka/src/test/resources/consumer.xml

Lines 27 to 28 in 446bb97

    
             @todo #25:15m/DEV Consumer settings in XML 
        
             -->

The puzzle was created by Aliaksei Bialiauski on 26-Feb-23.

Estimate: 15 minutes, role: DEV.

If you have any technical questions, don't ask me, submit new tickets instead. The task will be "done" when the problem is fixed and the text of the puzzle is removed from the source code. Here is more about PDD and about me.

enable static analysis

Right now, seems that qulice doesn't work with Java 17, which is our java version.

yegor256/qulice#1145 (comment)

KfConsumerSettings.java:36: Origin consumer construction...

The puzzle 25-7325f361 from #25 has to be resolved:

eo-kafka/src/main/java/org/eocqrs/kafka/consumer/KfConsumerSettings.java

Line 36 in 446bb97

* @todo #25:15m/DEV Origin consumer construction from XML

The puzzle was created by @h1alexbel on 26-Feb-23.

Estimate: 15 minutes, role: DEV.

If you have any technical questions, don't ask me, submit new tickets instead. The task will be "done" when the problem is fixed and the text of the puzzle is removed from the source code. Here is more about PDD and about me.

Dependency Dashboard

This issue lists Renovate updates and detected dependencies. Read the Dependency Dashboard docs to learn more.

Open

These updates have all been created already. Click a checkbox below to force a retry/rebase of any.

Update dependency org.projectlombok:lombok to v1.18.32

Ignored or Blocked

These are blocked by an existing closed PR and will not be recreated unless you click a checkbox below.

Detected dependencies

github-actions

.github/workflows/codecov.yml

actions/checkout v4

actions/setup-java v4

actions/cache v4

codecov/codecov-action v4

ubuntu 22.04

.github/workflows/maven.yml

actions/checkout v4

actions/setup-java v4

actions/cache v4

actions/checkout v4

actions/setup-java v4

actions/cache v4

.github/workflows/pdd.yml

actions/checkout v4

ubuntu 22.04

.github/workflows/xcop.yml

actions/checkout v4

ubuntu 22.04

maven

pom.xml

com.jcabi:parent 0.67.0

org.apache.kafka:kafka-clients 3.7.0

org.cactoos:cactoos 0.55.0

io.github.eo-cqrs:xfake 0.1.2

io.github.eo-cqrs:eokson 0.3.2

com.jcabi.incubator:xembly 0.31.1

org.yaml:snakeyaml 2.2

org.projectlombok:lombok 1.18.30

org.slf4j:slf4j-api 2.0.12

org.slf4j:slf4j-simple 2.0.12

org.junit.jupiter:junit-jupiter-api 5.10.2

org.junit.jupiter:junit-jupiter-params 5.10.2

org.assertj:assertj-core 3.25.3

org.mockito:mockito-core 5.11.0

org.mockito:mockito-junit-jupiter 5.11.0

org.apache.maven.plugins:maven-surefire-plugin 3.2.5

org.apache.maven.plugins:maven-verifier-plugin 1.1

org.apache.maven.plugins:maven-invoker-plugin 3.6.0

com.github.volodya-lombrozo:jtcop-maven-plugin 0.1.14

ru.l3r8y:sa-tan 0.1.5

org.apache.maven.plugins:maven-checkstyle-plugin 3.3.1

com.puppycrawl.tools:checkstyle 8.15

org.apache.maven.plugins:maven-source-plugin 3.3.0

org.apache.maven.plugins:maven-gpg-plugin 3.2.1

org.sonatype.plugins:nexus-staging-maven-plugin 1.6.13

org.apache.maven.plugins:maven-invoker-plugin 3.6.0

src/it/producer-consumer-api/pom.xml

org.assertj:assertj-core 3.25.3

org.rnorth.duct-tape:duct-tape 1.0.8

org.slf4j:slf4j-api 2.0.12

org.junit.jupiter:junit-jupiter-api 5.10.2

org.junit.jupiter:junit-jupiter 5.10.2

org.hamcrest:hamcrest 2.2

org.testcontainers:testcontainers 1.19.7

org.testcontainers:kafka 1.19.7

org.testcontainers:junit-jupiter 1.19.7

org.mockito:mockito-core 5.11.0

io.github.eo-cqrs:eo-kafka 1.0-SNAPSHOT

org.apache.maven.plugins:maven-surefire-plugin 3.2.5

Check this box to trigger a request for Renovate to run again on this repository

KfConsumerSettings.java:44: Which settings needed for...

The puzzle 25-d7d33e52 from #25 has to be resolved:

eo-kafka/src/main/java/org/eocqrs/kafka/consumer/KfConsumerSettings.java

Line 44 in 446bb97

* @todo #25:10m/DEV Which settings needed for origin consumer construction

The puzzle was created by @h1alexbel on 26-Feb-23.

Estimate: 10 minutes, role: DEV.

If you have any technical questions, don't ask me, submit new tickets instead. The task will be "done" when the problem is fixed and the text of the puzzle is removed from the source code. Here is more about PDD and about me.

KfProducer.java:18: send

The puzzle 21-2541d938 from #21 has to be resolved:

eo-kafka/src/main/java/org/eocqrs/kafka/KfProducer.java

Line 18 in 4376a1c

* @todo #21:30m/DEV send

The puzzle was created by @h1alexbel on 21-Feb-23.

Estimate: 30 minutes, role: DEV.

If you have any technical questions, don't ask me, submit new tickets instead. The task will be "done" when the problem is fixed and the text of the puzzle is removed from the source code. Here is more about PDD and about me.

gradle dependency in README

XSD schema for producer.xml

DataizedOf.java:9: DataizedOf implementation

The puzzle 19-8fc50e58 from #19 has to be resolved:

eo-kafka/src/main/java/org/eocqrs/kafka/DataizedOf.java

Line 9 in 8c364cc

* @todo #19:30m/DEV DataizedOf implementation

The puzzle was created by @h1alexbel on 21-Feb-23.

Estimate: 30 minutes, role: DEV.

If you have any technical questions, don't ask me, submit new tickets instead. The task will be "done" when the problem is fixed and the text of the puzzle is removed from the source code. Here is more about PDD and about me.

pom.xml:158: Coverage checks have not been met

The puzzle 3-1381bf53 from #3 has to be resolved:

eo-kafka/pom.xml

Line 158 in 31ed7fd

<!-- @todo #3:15m/DEV Coverage checks have not been met

The puzzle was created by @h1alexbel on 20-Feb-23.

Estimate: 15 minutes, role: DEV.

If you have any technical questions, don't ask me, submit new tickets instead. The task will be "done" when the problem is fixed and the text of the puzzle is removed from the source code. Here is more about PDD and about me.

Invoker

in the future we will need integration tests, a simple way to do this is to use invoker

sonatype account

KfProducer.java:17: it for data consumption

The puzzle 30-6ca3f2f5 from #30 has to be resolved:

eo-kafka/src/main/java/org/eocqrs/kafka/KfProducer.java

Line 17 in 7a07196

* @todo #30:60m/DEV it for data consumption

The puzzle was created by @h1alexbel on 23-Feb-23.

Estimate: 60 minutes, role: DEV.

If you have any technical questions, don't ask me, submit new tickets instead. The task will be "done" when the problem is fixed and the text of the puzzle is removed from the source code. Here is more about PDD and about me.

readme quickstart

update logo

KfConsumerSettingsTest.java:19: Consumer construction Test

The puzzle 25-60b0913a from #25 has to be resolved:

eo-kafka/src/test/java/org/eocqrs/kafka/consumer/KfConsumerSettingsTest.java

Line 19 in 446bb97

* @todo #25:20m/DEV Consumer construction Test

The puzzle was created by Aliaksei Bialiauski on 26-Feb-23.

Estimate: 20 minutes, role: DEV.

If you have any technical questions, don't ask me, submit new tickets instead. The task will be "done" when the problem is fixed and the text of the puzzle is removed from the source code. Here is more about PDD and about me.

KfConsumer.java:47-56: Data polling example:...

The puzzle 41-73d202c2 from #41 has to be resolved:

eo-kafka/src/main/java/org/eocqrs/kafka/consumer/KfConsumer.java

Lines 47 to 56 in 446bb97

    
              * @todo #41:30m/DEV Data polling 
        
              * example: 
        
              * origin.poll(timeout) 
        
              *       .records(topic) 
        
              *       .forEach(new java.util.function.Consumer<ConsumerRecord<K, X>>() { 
        
              *         @Override 
        
              *         public void accept(ConsumerRecord<K, X> record) { 
        
              *           throw new UnsupportedOperationException("#accept()"); 
        
              *         } 
        
              *       });

The puzzle was created by @h1alexbel on 26-Feb-23.

Estimate: 30 minutes, role: DEV.

If you have any technical questions, don't ask me, submit new tickets instead. The task will be "done" when the problem is fixed and the text of the puzzle is removed from the source code. Here is more about PDD and about me.

javadocs automated publishing

pipeline to maven central

KfProducer.java:17: test send construction

The puzzle 23-de2f665f from #23 has to be resolved:

eo-kafka/src/main/java/org/eocqrs/kafka/KfProducer.java

Line 17 in 4da907a

* @todo #23:30m/DEV test send construction

The puzzle was created by @h1alexbel on 22-Feb-23.

Estimate: 30 minutes, role: DEV.

If you have any technical questions, don't ask me, submit new tickets instead. The task will be "done" when the problem is fixed and the text of the puzzle is removed from the source code. Here is more about PDD and about me.

KfConsumerTest.java:13: Consumer subscribe Test

The puzzle 41-d60cef16 from #41 has to be resolved:

eo-kafka/src/test/java/org/eocqrs/kafka/consumer/KfConsumerTest.java

Line 13 in 446bb97

* @todo #41:30m/DEV Consumer subscribe Test

The puzzle was created by Aliaksei Bialiauski on 26-Feb-23.

Estimate: 30 minutes, role: DEV.

If you have any technical questions, don't ask me, submit new tickets instead. The task will be "done" when the problem is fixed and the text of the puzzle is removed from the source code. Here is more about PDD and about me.

producer-api

Clarification for whole idea

@h1alexbel could you give me a list of the resources you need to study to help you with this project?

DataizedOf.java:14: DataizedOf Ctor

The puzzle 20-8b422e84 from #20 has to be resolved:

eo-kafka/src/main/java/org/eocqrs/kafka/DataizedOf.java

Line 14 in 8c364cc

* @todo #20:15m/DEV DataizedOf Ctor

The puzzle was created by @h1alexbel on 21-Feb-23.

Estimate: 15 minutes, role: DEV.

If you have any technical questions, don't ask me, submit new tickets instead. The task will be "done" when the problem is fixed and the text of the puzzle is removed from the source code. Here is more about PDD and about me.

readme producer api

change the domain

concept

Producer<X> producer = new KfProducer<>(new Dataized("json"), "localhost", "...");
    producer.send(new X());
    Consumer<X> consumer =
        new KfConsumer<>("localhost", "...");
    consumer.fetch(15L);
    consumer.fetch();
    Datazied<X> result = consumer.fetch(15L, 3); // wait  and disconnect  // 3 retries
    result.origin(); // returns in json

FkProducer.java:12: Fake Producer implementation

The puzzle 10-404e50f4 from #10 has to be resolved:

eo-kafka/src/main/java/org/eocqrs/kafka/fake/FkProducer.java

Line 12 in 7c5f31a

* @todo #10:45m/DEV Fake Producer implementation

The puzzle was created by @h1alexbel on 24-Feb-23.

Estimate: 45 minutes, role: DEV.

If you have any technical questions, don't ask me, submit new tickets instead. The task will be "done" when the problem is fixed and the text of the puzzle is removed from the source code. Here is more about PDD and about me.

SCM Information

KfData.java:16: KfData dataization

The puzzle 2-c054d253 from #2 has to be resolved:

eo-kafka/src/main/java/org/eocqrs/kafka/KfData.java

Line 16 in 31ed7fd

* @todo #2:30m/DEV KfData dataization

The puzzle was created by @h1alexbel on 20-Feb-23.

Estimate: 30 minutes, role: DEV.

If you have any technical questions, don't ask me, submit new tickets instead. The task will be "done" when the problem is fixed and the text of the puzzle is removed from the source code. Here is more about PDD and about me.

KfConsumer.java:52-60: Data polling <pre> example:...

The puzzle 41-80474f37 from #41 has to be resolved:

eo-kafka/src/main/java/io/github/eocqrs/kafka/consumer/KfConsumer.java

Lines 52 to 60 in 457754b

    
              * @todo #41:30m/DEV Data polling 
        
              * <pre> 
        
              * example: 
        
              * origin.poll(timeout) 
        
              *       .records(topic) 
        
              *       .forEach(...ConsumerRecord) { 
        
              *         ... 
        
              *       }; 
        
              * </pre>

The puzzle was created by @rultor on 01-Mar-23.

Estimate: 30 minutes, role: DEV.

If you have any technical questions, don't ask me, submit new tickets instead. The task will be "done" when the problem is fixed and the text of the puzzle is removed from the source code. Here is more about PDD and about me.

SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder". SLF4J: Defaulting to no-operation (NOP) logger implementation

pdd

readme consumer api

license to all .java, .xml files

producer config

maven javadoc plugin

KfConsumerTest.java:20: Consumer data polling Test

The puzzle 41-a2146b71 from #41 has to be resolved:

eo-kafka/src/test/java/org/eocqrs/kafka/consumer/KfConsumerTest.java

Line 20 in 446bb97

* @todo #41:30m/DEV Consumer data polling Test

The puzzle was created by Aliaksei Bialiauski on 26-Feb-23.

Estimate: 30 minutes, role: DEV.

If you have any technical questions, don't ask me, submit new tickets instead. The task will be "done" when the problem is fixed and the text of the puzzle is removed from the source code. Here is more about PDD and about me.

	* @todo #48:60m/DEV Consume method.
	* We must create a consume method that
	* will accept the meta-information and the message.
	* Perhaps we need to create a new class, say.
	* `class MsgData` or something like that.

	* @todo #46:60m/DEV Too much time.
	* This test takes too long to run, it should be an integration test,
	* or we should do something about the execution speed.

	* @todo #41:30m/DEV Data polling
	* example:
	* origin.poll(timeout)
	* .records(topic)
	* .forEach(new java.util.function.Consumer<ConsumerRecord<K, X>>() {
	* @Override
	* public void accept(ConsumerRecord<K, X> record) {
	* throw new UnsupportedOperationException("#accept()");
	* }
	* });

	* @todo #41:30m/DEV Data polling
	* <pre>
	* example:
	* origin.poll(timeout)
	* .records(topic)
	* .forEach(...ConsumerRecord) {
	* ...
	* };
	* </pre>

eo-cqrs / eo-kafka Goto Github PK

eo-kafka's People

Contributors

Stargazers

Watchers

Forkers

eo-kafka's Issues

Open

Ignored or Blocked

Detected dependencies

Recommend Projects

Recommend Topics

Recommend Org