mink67/kafka_connect_bundle

1.0.24 2022-04-22 08:43 UTC

Requires

• api-platform/core: ^2.6
• doctrine/annotations: ^1.13
• doctrine/doctrine-bundle: ^2.5
• doctrine/orm: ^2.11
• enqueue/rdkafka: ^0.10.15
• firebase/php-jwt: ^6.0
• mink67/encrypt_bundle: ^1.0
• rakit/validation: ^1.4
• symfony/config: 5.4.*
• symfony/dependency-injection: 5.4.*
• symfony/http-client: 5.4.*
• symfony/messenger: 5.4.*
• symfony/serializer: 5.4.*

MIT

• Michée NKUSU

README

Add the config file

• Create file kafka_connect.yaml in config/packages directory

• Add the following content in the file :

      kafka_connect:
        producer:
          bootstrap_servers: "localhost:9093/"
          socket_timeout_ms: 50
          queue_buffering_max_messages: 1000
          max_in_flight_requests_per_connection: 1
          topic:
            message_timeout_ms: 30000
            request_required_acks: -1
            request_timeout_ms: 5000
        consumer:
          bootstrap_servers: "localhost:9093/"
          group_id: "consumer-highlevel"
          enable_partition_eof: "true"
          auto_offset_reset: "earliest"
        db:
          table_name: 'kafka_settings'
        default_topic_name: 'sync_rn_db'
        prefix_channel: 'prefix'
  
  
      mink67_encrypt:
          ciphering: 'AES-128-CTR'
          options: 0
          encryption_iv: '1234567891011121'
          encryption_key: '%env(resolve:DATABASE_URL)%'
          decryption_iv: '1234567891011121'
          decryption_key: '%env(resolve:DATABASE_URL)%'
          
  

Add package

    $ composer require mink67/kafka_connect_bundle

Require symfony messenger

    $ composer require mink67/kafka_connect_bundle