File tree 8 files changed +96
-0
lines changed
src/Symfony/Component/Messenger/Bridge/Kafka/Transport 8 files changed +96
-0
lines changed Original file line number Diff line number Diff line change 1
1
<?php
2
2
3
+ /*
4
+ * This file is part of the Symfony package.
5
+ *
6
+ * (c) Fabien Potencier <fabien@symfony.com>
7
+ *
8
+ * For the full copyright and license information, please view the LICENSE
9
+ * file that was distributed with this source code.
10
+ */
11
+
3
12
declare (strict_types=1 );
4
13
5
14
namespace Symfony \Component \Messenger \Bridge \Kafka \Transport ;
6
15
7
16
use RdKafka \Message ;
8
17
use Symfony \Component \Messenger \Stamp \NonSendableStampInterface ;
9
18
19
+ /**
20
+ * @author Konstantin Scheumann <konstantin@konstantin.codes>
21
+ */
10
22
final class KafkaMessageStamp implements NonSendableStampInterface
11
23
{
12
24
/** @var Message */
Original file line number Diff line number Diff line change 1
1
<?php
2
2
3
+ /*
4
+ * This file is part of the Symfony package.
5
+ *
6
+ * (c) Fabien Potencier <fabien@symfony.com>
7
+ *
8
+ * For the full copyright and license information, please view the LICENSE
9
+ * file that was distributed with this source code.
10
+ */
11
+
3
12
declare (strict_types=1 );
4
13
5
14
namespace Symfony \Component \Messenger \Bridge \Kafka \Transport ;
11
20
use Symfony \Component \Messenger \Transport \Receiver \ReceiverInterface ;
12
21
use Symfony \Component \Messenger \Transport \Serialization \SerializerInterface ;
13
22
23
+ /**
24
+ * @author Konstantin Scheumann <konstantin@konstantin.codes>
25
+ */
14
26
class KafkaReceiver implements ReceiverInterface
15
27
{
16
28
/** @var LoggerInterface */
Original file line number Diff line number Diff line change 1
1
<?php
2
2
3
+ /*
4
+ * This file is part of the Symfony package.
5
+ *
6
+ * (c) Fabien Potencier <fabien@symfony.com>
7
+ *
8
+ * For the full copyright and license information, please view the LICENSE
9
+ * file that was distributed with this source code.
10
+ */
11
+
3
12
declare (strict_types=1 );
4
13
5
14
namespace Symfony \Component \Messenger \Bridge \Kafka \Transport ;
6
15
7
16
use RdKafka \Conf as KafkaConf ;
8
17
18
+ /**
19
+ * @author Konstantin Scheumann <konstantin@konstantin.codes>
20
+ */
9
21
final class KafkaReceiverProperties
10
22
{
11
23
/** @var KafkaConf */
Original file line number Diff line number Diff line change 1
1
<?php
2
2
3
+ /*
4
+ * This file is part of the Symfony package.
5
+ *
6
+ * (c) Fabien Potencier <fabien@symfony.com>
7
+ *
8
+ * For the full copyright and license information, please view the LICENSE
9
+ * file that was distributed with this source code.
10
+ */
11
+
3
12
declare (strict_types=1 );
4
13
5
14
namespace Symfony \Component \Messenger \Bridge \Kafka \Transport ;
11
20
use Symfony \Component \Messenger \Transport \Sender \SenderInterface ;
12
21
use Symfony \Component \Messenger \Transport \Serialization \SerializerInterface ;
13
22
23
+ /**
24
+ * @author Konstantin Scheumann <konstantin@konstantin.codes>
25
+ */
14
26
class KafkaSender implements SenderInterface
15
27
{
16
28
/** @var LoggerInterface */
Original file line number Diff line number Diff line change 1
1
<?php
2
2
3
+ /*
4
+ * This file is part of the Symfony package.
5
+ *
6
+ * (c) Fabien Potencier <fabien@symfony.com>
7
+ *
8
+ * For the full copyright and license information, please view the LICENSE
9
+ * file that was distributed with this source code.
10
+ */
11
+
3
12
declare (strict_types=1 );
4
13
5
14
namespace Symfony \Component \Messenger \Bridge \Kafka \Transport ;
6
15
7
16
use RdKafka \Conf as KafkaConf ;
8
17
18
+ /**
19
+ * @author Konstantin Scheumann <konstantin@konstantin.codes>
20
+ */
9
21
final class KafkaSenderProperties
10
22
{
11
23
/** @var KafkaConf */
Original file line number Diff line number Diff line change 1
1
<?php
2
2
3
+ /*
4
+ * This file is part of the Symfony package.
5
+ *
6
+ * (c) Fabien Potencier <fabien@symfony.com>
7
+ *
8
+ * For the full copyright and license information, please view the LICENSE
9
+ * file that was distributed with this source code.
10
+ */
11
+
3
12
declare (strict_types=1 );
4
13
5
14
namespace Symfony \Component \Messenger \Bridge \Kafka \Transport ;
9
18
use Symfony \Component \Messenger \Transport \Serialization \SerializerInterface ;
10
19
use Symfony \Component \Messenger \Transport \TransportInterface ;
11
20
21
+ /**
22
+ * @author Konstantin Scheumann <konstantin@konstantin.codes>
23
+ */
12
24
class KafkaTransport implements TransportInterface
13
25
{
14
26
/** @var LoggerInterface */
Original file line number Diff line number Diff line change 1
1
<?php
2
2
3
+ /*
4
+ * This file is part of the Symfony package.
5
+ *
6
+ * (c) Fabien Potencier <fabien@symfony.com>
7
+ *
8
+ * For the full copyright and license information, please view the LICENSE
9
+ * file that was distributed with this source code.
10
+ */
11
+
3
12
declare (strict_types=1 );
4
13
5
14
namespace Symfony \Component \Messenger \Bridge \Kafka \Transport ;
19
28
use Symfony \Component \Messenger \Transport \TransportFactoryInterface ;
20
29
use Symfony \Component \Messenger \Transport \TransportInterface ;
21
30
31
+ /**
32
+ * @author Konstantin Scheumann <konstantin@konstantin.codes>
33
+ */
22
34
class KafkaTransportFactory implements TransportFactoryInterface
23
35
{
24
36
private const DSN_PROTOCOLS = [
Original file line number Diff line number Diff line change 1
1
<?php
2
2
3
+ /*
4
+ * This file is part of the Symfony package.
5
+ *
6
+ * (c) Fabien Potencier <fabien@symfony.com>
7
+ *
8
+ * For the full copyright and license information, please view the LICENSE
9
+ * file that was distributed with this source code.
10
+ */
11
+
3
12
declare (strict_types=1 );
4
13
5
14
namespace Symfony \Component \Messenger \Bridge \Kafka \Transport ;
8
17
use RdKafka \KafkaConsumer ;
9
18
use RdKafka \Producer as KafkaProducer ;
10
19
20
+ /**
21
+ * @author Konstantin Scheumann <konstantin@konstantin.codes>
22
+ */
11
23
class RdKafkaFactory
12
24
{
13
25
public function createConsumer (Conf $ conf ): KafkaConsumer
You can’t perform that action at this time.
0 commit comments