File Manager

Hackfut Security File Manager

Current Path: /opt/td-agent/embedded/lib/ruby/gems/2.4.0/gems/ruby-kafka-0.7.10/lib/kafka

opt / td-agent / embedded / lib / ruby / gems / 2.4.0 / gems / ruby-kafka-0.7.10 / lib / kafka /

📁 ..
📄 async_producer.rb(9.18 KB)
📄 broker.rb(4.9 KB)
📄 broker_info.rb(305 B)
📄 broker_pool.rb(902 B)
📄 broker_uri.rb(1.01 KB)
📄 client.rb(26.55 KB)
📄 cluster.rb(12.73 KB)
📄 compression.rb(881 B)
📄 compressor.rb(2.67 KB)
📄 connection.rb(6.99 KB)
📄 connection_builder.rb(891 B)
📄 consumer.rb(22.12 KB)
📄 consumer_group.rb(5.7 KB)
📄 datadog.rb(11.53 KB)
📄 fetch_operation.rb(3.4 KB)
📄 fetched_batch.rb(1.18 KB)
📄 fetched_batch_generator.rb(3.96 KB)
📄 fetched_message.rb(1.04 KB)
📄 fetched_offset_resolver.rb(1.25 KB)
📄 fetcher.rb(6.01 KB)
📄 gzip_codec.rb(592 B)
📄 heartbeat.rb(618 B)
📄 instrumenter.rb(881 B)
📄 lz4_codec.rb(444 B)
📄 message_buffer.rb(1.97 KB)
📄 offset_manager.rb(7.99 KB)
📄 partitioner.rb(1.11 KB)
📄 pause.rb(2.66 KB)
📄 pending_message.rb(851 B)
📄 pending_message_queue.rb(658 B)
📄 produce_operation.rb(7.92 KB)
📄 producer.rb(18.59 KB)
📄 prometheus.rb(12.83 KB)
📁 protocol
📄 protocol.rb(8.35 KB)
📄 round_robin_assignment_strategy.rb(1.55 KB)
📁 sasl
📄 sasl_authenticator.rb(1.68 KB)
📄 snappy_codec.rb(511 B)
📄 socket_with_timeout.rb(2.86 KB)
📄 ssl_context.rb(2.85 KB)
📄 ssl_socket_with_timeout.rb(6.24 KB)
📄 statsd.rb(9.79 KB)
📄 tagged_logger.rb(1.72 KB)
📄 transaction_manager.rb(8.28 KB)
📄 transaction_state_machine.rb(1.85 KB)
📄 version.rb(69 B)
📄 zstd_codec.rb(460 B)

Editing: broker_uri.rb

# frozen_string_literal: true

require "uri"

module Kafka
  module BrokerUri
    DEFAULT_PORT = 9092
    URI_SCHEMES = ["kafka", "kafka+ssl", "plaintext", "ssl"]

# Parses a Kafka broker URI string.
    #
    # Examples of valid strings:
    # * `kafka1.something`
    # * `kafka1.something:1234`
    # * `kafka://kafka1.something:1234`
    # * `kafka+ssl://kafka1.something:1234`
    # * `plaintext://kafka1.something:1234`
    #
    # @param str [String] a Kafka broker URI string.
    # @return [URI]
    def self.parse(str)
      # Make sure there's a scheme part if it's missing.
      str = "kafka://" + str unless str.include?("://")

uri = URI.parse(str)
      uri.port ||= DEFAULT_PORT

# Map some schemes to others.
      case uri.scheme
      when 'plaintext'
        uri.scheme = 'kafka'
      when 'ssl'
        uri.scheme = 'kafka+ssl'
      end

unless URI_SCHEMES.include?(uri.scheme)
        raise Kafka::Error, "invalid protocol `#{uri.scheme}` in `#{str}`"
      end

uri
    end
  end
end

Hackfut Security File Manager

Editing: broker_uri.rb

Upload File

Create Folder