[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Flink RMQSource Consumer: How I get the RabbitMQ UserId


how I can get the UserId from the Properties in my DataStream?

I can read the userId if I extend the RMQSource Class:
QueueingConsumer.Delivery delivery = consumer.nextDelivery();
String userId = delivery.getProperties().getUserId();

But how can I provide this to my DataStream ?

Best regards,