Stack Overflow
Stack Overflow

Questions tagged [aeron]

Aeron is a reliable UDP unicast, UDP multicast, and IPC message transport

See https://github.com/real-logic/Aeron for more information

83 questions
5
votes
1 answer

Is it possible to replay from Aeron Cluster?

We would like to use Aeron as persistent queue. Is it possible to setup Aeron Cluster to provide replication, and possibility to replay (like Aeron Archive) for the clients?
Milos Gregor
  • 940
  • 8
  • 14
5
votes
1 answer

Different results for transport benchmarks

I made some benchmarks for my presentation about Aeron, but I found out that if I use different tools for the same transport I got slightly different results. For example, if I use HDR histograms I got the results that align with that numbers the…
QIvan
  • 652
  • 4
  • 13
5
votes
2 answers

How do I create a file sending client/server with RSocket?

I can't seem to find any resources/tutorials on RSocket, other than just reading their code on GitHub, which I don't understand. I have a file's path on my server: String serverFilePath; I'd like to be able to download it from my client (using…
James
  • 71
  • 3
5
votes
1 answer

What is the largest message Aeron can process?

What is size of the largest message real-logic's Aeron can process? I realize Aeron shines for small messages, however I would like to have a single protocol throughout our stack and some of our messages easily reach a size of 100Mb. The…
Erik van Oosten
  • 1,541
  • 14
  • 16
4
votes
1 answer

Using Aeron with RSocket

Good morning, I am trying to use RSocket on top of the Aeron transport protocol. However, it appears that there is no documentation on the topic - did anyone successfully integrate those two technologies together ? Is it ready to be used or still a…
Emmanuel
  • 199
  • 4
  • 7
3
votes
1 answer

OneToManyRingBuffer implementation in agrona

This may be a stupid question but there's a OneToOneRingBuffer and a ManyToOneRingBuffer available in aeron (agrona). I have a single producer and many consumers I'm wondering how to achieve the equivalent effect of OneToManyRingBuffer?
hawk
  • 1,827
  • 2
  • 14
  • 28
3
votes
1 answer

Aeron MQ : Multiple subscription

I am currently working on a PoC about Aeron MQ. As per PoC, i have 2 subscriptions and 1 publisher for a local channel with embedded media driver. The messages published are received in both the subscriptions whereas i would want to distribute the…
Sudharsan
  • 207
  • 1
  • 2
  • 12
2
votes
1 answer

Aeron cluster gets blocked when taking a big snapshot

I've been experimenting with Aeron cluster, and one thing that is unclear to me is how do you deal with applications where nodes have 10s of gigabytes of state... this state is in memory and is accumulated by playing the events. However if I…
vach
  • 10,571
  • 12
  • 68
  • 106
2
votes
2 answers

What is the difference between RSocket + TCP and RSocket + WebSocket?

I am completely new to RSocket. I read the FAQ and the motiviations page (and skimmed the Protocol page) and understand that RSocket can be used on top of TCP, WebSocket and Aeron. But what I don't understand is what the differences are between…
RatManMan
  • 63
  • 6
2
votes
1 answer

How can I embed the Aeron driver JAR in a Rust program and start it later?

I have a Rust program that uses Aeron through the aeron-rs crate. Every time I want to run my program, I need to manually start the driver first. In fact, the crate explicitly states that it works simply as a wrapper around the running driver. I…
digital illusion
  • 497
  • 3
  • 19
2
votes
2 answers

Aeron basic pub/sub pair connects on same host, fails across hosts

I am running the BasicPublisher/BasicSubscriber pair from https://github.com/real-logic/aeron binding them to the same multicast group+port. When they run on the same host they connect, but when they run on separate hosts (same switch+subnet+vlan)…
asyncify
  • 95
  • 7
2
votes
1 answer

How to replace Kafka with Aeron

At present, the trading system of our production environment is using Kafka. Because Kafka latency is too high, we hope to replace Kafka with Aeron. How can I use Aeron correctly?
user13454562
  • 23
  • 3
2
votes
1 answer

How to create Multi-Destination-Cast in Aeron Library

I am trying to use the Multi-Destination-Cast transportation, but I don't know how to configure-it, I am trying to implement the Example URIs explained here using the SimplePublisher.java and the SimpleSubscriber.java I have one publisher and two…
david.t_92
  • 1,971
  • 1
  • 11
  • 15
2
votes
1 answer

Not able to set ThreadFactory() for Aeron Media Driver

I cannot setup new Threadfactory() in the LowLatencyMediaDriver sample for Aeron. See below code and snapshot for thread names in VisualVM. public class LowLatencyMediaDriver { public static void main(final String[] args) { …
Sam
  • 61
  • 6
1
vote
1 answer

Two questions need to help about Aeron

ver: 1.42.0 deploy on: k8s In my business system, the absence of subscribers is a reasonable phenomenon, and sometimes there may be situations of backpressure. Does it mean that Aeron is not applicable to my business system? During the…
qinglok
  • 13
  • 2
1
2 3 4 5 6