issues
search
eventuate-foundation
/
eventuate-messaging-kafka
Other
15
stars
11
forks
source link
issues
Newest
Newest
Most commented
Recently updated
Oldest
Least commented
Least recently updated
On CircleCI EventuateKafkaNativeContainer fails to start with /opt/kafka/config/ not writable
#65
cer
opened
3 months ago
2
Investigate EventuateKafkaConsumer.stop() behavior
#64
cer
opened
11 months ago
1
Implement Eventuate Leadership APIs using a Kafka topic
#63
cer
opened
1 year ago
0
Optimized Dockerfile HEALTHCHECK
#62
cer
closed
1 year ago
0
Improve testcontainer support
#61
cer
opened
1 year ago
0
Offsets not being recorded resulting in message redelivery on re-subscribe
#60
cer
closed
2 years ago
0
Performance of multiple topics per KafkaConsumer vs. multiple single topic KafkaConsumer
#59
cer
opened
2 years ago
0
Upgrade Kafka Client
#58
cer
opened
2 years ago
4
SwimlaneDispatcher configurable - hashing algorithm, threadpool size
#57
cer
opened
2 years ago
3
Make broker ID optionally configurable
#56
cer
opened
2 years ago
0
Replace sed with envsubst
#55
cer
opened
2 years ago
0
Cleanup yum
#54
cer
opened
2 years ago
0
java.lang.OutOfMemoryError: Java heap space - during Eventuate CDC CircleCI tests
#53
cer
opened
2 years ago
0
Publish a multi-architecture Kafka image
#52
cer
opened
2 years ago
0
Is there an option to slow down the pulling of messages from kafka topic when the consumer queue is full.
#51
ddaeyongee
opened
2 years ago
1
Replaced deprecated method.
#50
dartartem
opened
2 years ago
2
MessageConsumerKafkaImpl should allow for concurrent processing of messages from different topics (even if they have the same partition number)
#49
douggish
opened
3 years ago
0
Implemented reactive consumer.
#48
dartartem
closed
3 years ago
1
Updated micronaut version.
#47
dartartem
closed
3 years ago
0
Replaced 'Save test results' command by script in circle ci. Added gr…
#46
dartartem
closed
3 years ago
0
Updated gradle. Used eventuate publishing plugin.
#45
dartartem
closed
4 years ago
0
#43. Replace env variables by properties. Use gradle docker plugin.
#44
dartartem
closed
4 years ago
0
Replace env variables by properties. Use gradle docker plugin.
#43
dartartem
opened
4 years ago
0
Why do services need to @Import KafkaConsumerFactoryConfiguration
#42
cer
opened
4 years ago
1
Added snapshot repository reference.
#41
dartartem
closed
4 years ago
0
#39: Updgrade Eventuate Dependencies. Common messaging is updated to …
#40
dartartem
closed
4 years ago
0
Updgrade Eventuate Dependencies
#39
dartartem
opened
4 years ago
0
Added methods to kafka consumer required for cdc.
#38
dartartem
closed
4 years ago
0
Made DefaultKafkaConsumerFactory bean defenition optional.
#37
dartartem
closed
4 years ago
0
testConsumerSwitchOnHanging() fails when using confluent images.
#36
cer
opened
4 years ago
1
External offset storage
#35
dialtahi
closed
4 years ago
0
Support external offset storage (Elasticsearch, JDBC, etc)
#34
dialtahi
opened
4 years ago
3
0.3.0.release 合并到master
#33
tdcare
closed
4 years ago
1
fixed transitive dependencies of spring modules
#32
dartartem
closed
4 years ago
0
reorganized modules.
#31
dartartem
closed
4 years ago
0
Improved logging.
#30
dartartem
closed
4 years ago
0
Add possibility to send message to specific partition.
#29
dartartem
closed
4 years ago
0
Merged Master
#28
dartartem
closed
4 years ago
1
Replaced magic numbers by constants.
#27
dartartem
closed
4 years ago
0
Wip micronaut
#26
dartartem
closed
4 years ago
0
Added headers to multimessages
#25
dartartem
closed
4 years ago
0
testConsumerSwitchOnHanging fails only on *my* machine
#24
cer
opened
4 years ago
0
The configuration 'key.serializer' was supplied but isn't a known config.
#23
cer
opened
4 years ago
0
Used SBE as multimessage encoder.
#22
dartartem
closed
4 years ago
0
Added encoding performance tests. (Not for merge to master)
#21
dartartem
closed
4 years ago
0
Consider using SBE for message encoding
#20
cer
opened
4 years ago
0
Investigate ways to make deserialization from ByteBuffer more efficient
#19
cer
opened
4 years ago
1
Investigate first figuring out how many messages will fit, and then allocating a buffer large enough
#18
cer
opened
4 years ago
0
Consider using ByteBuffer instead -
#17
cer
opened
4 years ago
0
intToBytes() should not allocate. Instead, write directly to stream
#16
cer
opened
4 years ago
0
Next