18315DEV3-1381bf53158-158
Coverage checks have not been met
pom.xml@h1alexbelHialexbel@gmail.com19230DEV2-c054d25316-16
KfData dataization
src/main/java/org/eocqrs/kafka/KfData.java@h1alexbelHialexbel@gmail.com211930DEV19-8fc50e589-9
DataizedOf implementation
src/main/java/org/eocqrs/kafka/DataizedOf.java@h1alexbelHialexbel@gmail.com232130DEV21-2541d93818-18
send
src/main/java/org/eocqrs/kafka/KfProducer.java@h1alexbelHialexbel@gmail.com302330DEV23-de2f665f17-17
test send construction
src/main/java/org/eocqrs/kafka/KfProducer.java@h1alexbelHialexbel@gmail.com393060DEV30-6ca3f2f517-17
it for data consumption
src/main/java/org/eocqrs/kafka/KfProducer.java@h1alexbelHialexbel@gmail.com222015DEV20-8b422e8414-14
DataizedOf Ctor
src/main/java/org/eocqrs/kafka/DataizedOf.java@h1alexbelHialexbel@gmail.com312620DEV26-7c38feaf20-20
test producer construction
src/main/java/org/eocqrs/kafka/KfProducerSettings.java@h1alexbelHialexbel@gmail.com441045DEV10-404e50f412-12
Fake Producer implementation
src/main/java/org/eocqrs/kafka/fake/FkProducer.java@h1alexbelHialexbel@gmail.com2924460DEV44-72db5d0241-41
Fake send is not implemented
src/main/java/io/github/eocqrs/kafka/fake/FkProducer.javah1alexbelhialexbel@gmail.com36429260DEV292-fab4489f29-31
Broker has too many methods We should decompose methods adding something to the broker, such as #withDataset(), #withTopics(), and so on.
src/main/java/io/github/eocqrs/kafka/fake/FkBroker.java@h1alexbelhialexbel@gmail.com2934460DEV44-45e8868749-49
Fake producer close is not implemented
src/main/java/io/github/eocqrs/kafka/fake/FkProducer.javah1alexbelhialexbel@gmail.com37329330DEV293-5652f6a3113-113
Fake consumer close log test
src/main/java/io/github/eocqrs/kafka/fake/FkProducer.javah1alexbelhialexbel@gmail.com474660DEV46-4ddc69d839-41
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.
src/test/java/org/eocqrs/kafka/KfProducerTest.java@h1alexbelHialexbel@gmail.com984745DEV47-4164e46d57-57
Producer <> Consumer it.
src/test/java/io/github/eocqrs/kafka/producer/KfProducerTest.java@rultorme@rultor.com1114745DEV47-77e605ac43-44
Consumer Producer communication. We have to create an ITCase for communication between Consumer and Producer.
src/test/java/io/github/eocqrs/kafka/producer/KfProducerTest.java@ivanclicker.heroes.acg@gmail.com494860DEV48-2996689e31-35
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.
src/main/java/org/eocqrs/kafka/Consumer.java@h1alexbelHialexbel@gmail.com544945DEV49-da1616f336-36
Fake Consumer implementation
src/main/java/org/eocqrs/kafka/fake/FkConsumer.java@h1alexbelHialexbel@gmail.com2945460DEV54-622a27cf44-44
Fake subscribe is not implemented
src/main/java/io/github/eocqrs/kafka/fake/FkConsumer.java@h1alexbelhialexbel@gmail.com2955460DEV54-24b9fc6657-58
Fake subscribe with ConsumerRebalanceListener is not implemented
src/main/java/io/github/eocqrs/kafka/fake/FkConsumer.java@h1alexbelhialexbel@gmail.com2965460DEV54-18f70e3d67-67
Fake iterate is not implemented
src/main/java/io/github/eocqrs/kafka/fake/FkConsumer.javah1alexbelhialexbel@gmail.com2975460DEV54-fcc45b5d75-75
Fake unsubscribe is not implemented
src/main/java/io/github/eocqrs/kafka/fake/FkConsumer.javah1alexbelhialexbel@gmail.com2985460DEV54-846ada4083-83
Fake consumer close is not implemented
src/main/java/io/github/eocqrs/kafka/fake/FkConsumer.javah1alexbelhialexbel@gmail.comunknown5460DEV54-4323f44866-66
Fake records is not implemented
src/main/java/io/github/eocqrs/kafka/fake/FkConsumer.java@rultorme@rultor.com552515DEV25-7325f36136-36
Origin consumer construction from XML
src/main/java/org/eocqrs/kafka/consumer/KfConsumerSettings.java@h1alexbelHialexbel@gmail.com562510DEV25-d7d33e5244-44
Which settings needed for origin consumer construction
src/main/java/org/eocqrs/kafka/consumer/KfConsumerSettings.java@h1alexbelHialexbel@gmail.com574130DEV41-73d202c247-56
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()"); } });
src/main/java/org/eocqrs/kafka/consumer/KfConsumer.java@h1alexbelHialexbel@gmail.com582515DEV25-2c1d96ec27-28
Consumer settings in XML -->
src/test/resources/consumer.xmlAliaksei BialiauskiHialexbel@gmail.com594130DEV41-d60cef1613-13
Consumer subscribe Test
src/test/java/org/eocqrs/kafka/consumer/KfConsumerTest.javaAliaksei BialiauskiHialexbel@gmail.com604130DEV41-a2146b7120-20
Consumer data polling Test
src/test/java/org/eocqrs/kafka/consumer/KfConsumerTest.javaAliaksei BialiauskiHialexbel@gmail.com612520DEV25-60b0913a19-19
Consumer construction Test
src/test/java/org/eocqrs/kafka/consumer/KfConsumerSettingsTest.javaAliaksei BialiauskiHialexbel@gmail.com814130DEV41-80474f3752-60
Data polling <pre> example: origin.poll(timeout) .records(topic) .forEach(...ConsumerRecord) { ... }; </pre>
src/main/java/io/github/eocqrs/kafka/consumer/KfConsumer.java@rultorme@rultor.com236810DEV81-60413ccb54-56
Tests to produce-consume data. Write a test which will be check how consumer reads data from producer.
src/it/producer-consumer-api/src/test/java/EntryTest.java@ivanclicker.heroes.acg@gmail.com28723630DEV236-9498fb8429-29
Producer send data without partition
src/main/java/io/github/eocqrs/kafka/Producer.java@h1alexbelhialexbel@gmail.com30428730DEV287-f527de8429-29
Producer send is not flexible enough
src/main/java/io/github/eocqrs/kafka/Producer.java@rultorme@rultor.com28823630DEV236-63d4f36338-38
Unsubscribe is not implemented
src/main/java/io/github/eocqrs/kafka/consumer/KfConsumer.java@h1alexbelhialexbel@gmail.com28923630DEV236-0a53974e92-92
ConsumerRecords data polling
src/main/java/io/github/eocqrs/kafka/consumer/KfConsumer.java@h1alexbelhialexbel@gmail.com30528930DEV289-af1a45bc86-87
ConsumerRecords wrapping up we have to wrap the ConsumerRecords into some object
src/main/java/io/github/eocqrs/kafka/consumer/KfConsumer.java@rultorme@rultor.com29023630DEV236-14bb941b91-91
Enable tests
src/it/producer-consumer-api/src/test/java/EntryTest.javah1alexbelhialexbel@gmail.com30629030DEV290-2e9c547070-70
Split ITCases into multiple files
src/it/producer-consumer-api/src/test/java/EntryTest.java@rultorme@rultor.com14113460DEV134-93373f7061-64
Replace a private method with object. We should implement something like NameInCamelCase. Or even send a pull request to cactoos with an implementation of TextInCamelCase.
src/main/java/io/github/eocqrs/kafka/settings/AttrEnvelope.java@h1alexbelHialexbel@gmail.com15014115DEV141-faa8076e31-34
Transfer NameInCamelCase class to cactoos. We should create a pull request/issue with suggestion of this class. */
src/main/java/io/github/eocqrs/kafka/xml/NameInCamelCase.java@ivanclicker.heroes.acg@gmail.com15114115DEV141-51feecdd33-36
Transfer this StringsInCamelCase to cactoos. We should create a pull request/issue with suggestion of this class. */
src/main/java/io/github/eocqrs/kafka/xml/StringsInCamelCase.javaIvanclicker.heroes.acg@gmail.com14212730DEV127-53fab03c34-35
Readme update. We have to update documentation and code examples in README.
src/main/java/io/github/eocqrs/kafka/producer/settings/KfProducerSettings.java@h1alexbelHialexbel@gmail.com15414730DEV147-324191c015-16
Opportunity for XML configuration We have to implement creating of settings from XML file.
src/main/java/io/github/eocqrs/kafka/parameters/KfFlexible.javaIvanclicker.heroes.acg@gmail.com16315430DEV154-3e7b661316-17
/Tests for {@link io.github.eocqrs.kafka.parameters.XmlMapParams}. Write unit tests.
src/main/java/io/github/eocqrs/kafka/parameters/XmlMapParams.java@rultorme@rultor.com16415430DEV154-63f981f58-9
Get rid of deprecated api. We have to remove <b>all</b> deprecated api, before release `0.0.3`.
src/main/java/io/github/eocqrs/kafka/parameters/KfXmlFlexible.java@rultorme@rultor.com15514730DEV147-c2522b3619-20
Update documentation Add use-cases to README for KfFlexible.
src/main/java/io/github/eocqrs/kafka/parameters/KfFlexible.javaIvanclicker.heroes.acg@gmail.com15614730DEV147-5906b54445-47
Implement via new class. Implement method as `Configuration` class which implement `Scalar<Map<String, Object>>` interface.
src/main/java/io/github/eocqrs/kafka/parameters/KfFlexible.javaIvanclicker.heroes.acg@gmail.com16214730DEV147-fa2de2d934-35
/Tests for {@link io.github.eocqrs.kafka.parameters.MapParams}. We have to write unit tests.
src/main/java/io/github/eocqrs/kafka/parameters/MapParams.java@rultorme@rultor.com18318115DEV181-38f7384526-26
Add Acks to README API documentation
src/main/java/io/github/eocqrs/kafka/parameters/Acks.java@h1alexbelHialexbel@gmail.com23114960DEV149-79199a8c26-26
Turn on JavaDoc suppressions.
checkstyle-suppressions.xml@ivanclicker.heroes.acg@gmail.com2652040DEV204-52513c7128-30
Make send return CompletableFuture. A more correct way to implement the #send method should have the return type CompletableFuture
src/main/java/io/github/eocqrs/kafka/Producer.java@ivanclicker.heroes.acg@gmail.com2662040DEV204-5fca849135-36
Integration test for `KfCallback` Create an integration test to test the callback mechanism.
src/main/java/io/github/eocqrs/kafka/producer/KfCallback.java@ivanclicker.heroes.acg@gmail.com35832645DEV326-af48ff4946-46
Introduce Integration Tests for Partition Assigning
src/test/java/io/github/eocqrs/kafka/act/AssignPartitionsTest.java@rultorme@rultor.com35935145DEV351-a36aee3745-45
Introduce Integration Tests for Consumer Wakeup
src/test/java/io/github/eocqrs/kafka/act/WakeupTest.java@rultorme@rultor.com36032745DEV327-8fa687f245-45
Introduce Integration Tests for Async Commit
src/test/java/io/github/eocqrs/kafka/act/CommitAsyncTest.javarultorme@rultor.com36132545DEV325-61fbc47c45-45
Introduce Integration Tests for Sync Commit
src/test/java/io/github/eocqrs/kafka/act/CommitSyncTest.javarultorme@rultor.com39430345DEV303-e88363b046-46
multi partitioning is not supported
src/main/java/io/github/eocqrs/kafka/fake/FkRecords.java@h1alexbelHialexbel@gmail.com39530390DEV303-28eb728637-37
fake consumer is not support various data types
src/main/java/io/github/eocqrs/kafka/fake/FkConsumer.java@h1alexbelHialexbel@gmail.com39630345DEV303-f98800f5104-104
records timeout is not implemented
src/main/java/io/github/eocqrs/kafka/fake/FkConsumer.java@h1alexbelHialexbel@gmail.com40030345DEV303-4241205d80-80
message key is not supported
src/main/java/io/github/eocqrs/kafka/fake/FkRecords.java@h1alexbelhialexbel@gmail.com43142860DEV428-981dbe6f47-49
Write tests for WithPartition caching mechanism. We need to prove with tests that our caching works and that it is also thread-safe.
src/main/java/io/github/eocqrs/kafka/data/WithPartition.java@l3r8yJl3r8y@duck.com43242860DEV428-0120af8f47-49
Write tests for Timestamped caching mechanism. We need to prove with tests that our caching works and that it is also thread-safe.
src/main/java/io/github/eocqrs/kafka/data/Timestamped.java@l3r8yJl3r8y@duck.com