kafka-python-ng API

• KafkaConsumer
  • KafkaConsumer
    • KafkaConsumer.assign()
    • KafkaConsumer.assignment()
    • KafkaConsumer.beginning_offsets()
    • KafkaConsumer.bootstrap_connected()
    • KafkaConsumer.close()
    • KafkaConsumer.commit()
    • KafkaConsumer.commit_async()
    • KafkaConsumer.committed()
    • KafkaConsumer.end_offsets()
    • KafkaConsumer.highwater()
    • KafkaConsumer.metrics()
    • KafkaConsumer.offsets_for_times()
    • KafkaConsumer.partitions_for_topic()
    • KafkaConsumer.pause()
    • KafkaConsumer.paused()
    • KafkaConsumer.poll()
    • KafkaConsumer.position()
    • KafkaConsumer.resume()
    • KafkaConsumer.seek()
    • KafkaConsumer.seek_to_beginning()
    • KafkaConsumer.seek_to_end()
    • KafkaConsumer.subscribe()
    • KafkaConsumer.subscription()
    • KafkaConsumer.topics()
    • KafkaConsumer.unsubscribe()
• KafkaProducer
  • KafkaProducer
    • KafkaProducer.bootstrap_connected()
    • KafkaProducer.close()
    • KafkaProducer.flush()
    • KafkaProducer.metrics()
    • KafkaProducer.partitions_for()
    • KafkaProducer.send()
• KafkaAdminClient
  • KafkaAdminClient
    • KafkaAdminClient.alter_configs()
    • KafkaAdminClient.close()
    • KafkaAdminClient.create_acls()
    • KafkaAdminClient.create_partitions()
    • KafkaAdminClient.create_topics()
    • KafkaAdminClient.delete_acls()
    • KafkaAdminClient.delete_consumer_groups()
    • KafkaAdminClient.delete_topics()
    • KafkaAdminClient.describe_acls()
    • KafkaAdminClient.describe_configs()
    • KafkaAdminClient.describe_consumer_groups()
    • KafkaAdminClient.describe_log_dirs()
    • KafkaAdminClient.list_consumer_group_offsets()
    • KafkaAdminClient.list_consumer_groups()
• KafkaClient
  • KafkaClient
    • KafkaClient.add_topic()
    • KafkaClient.bootstrap_connected()
    • KafkaClient.check_version()
    • KafkaClient.close()
    • KafkaClient.connected()
    • KafkaClient.connection_delay()
    • KafkaClient.get_api_versions()
    • KafkaClient.in_flight_request_count()
    • KafkaClient.is_disconnected()
    • KafkaClient.is_ready()
    • KafkaClient.least_loaded_node()
    • KafkaClient.maybe_connect()
    • KafkaClient.poll()
    • KafkaClient.ready()
    • KafkaClient.send()
    • KafkaClient.set_topics()
• BrokerConnection
  • BrokerConnection
    • BrokerConnection.blacked_out()
    • BrokerConnection.can_send_more()
    • BrokerConnection.check_version()
    • BrokerConnection.close()
    • BrokerConnection.connect()
    • BrokerConnection.connected()
    • BrokerConnection.connecting()
    • BrokerConnection.connection_delay()
    • BrokerConnection.disconnected()
    • BrokerConnection.recv()
    • BrokerConnection.send()
    • BrokerConnection.send_pending_requests()
    • BrokerConnection.send_pending_requests_v2()
• ClusterMetadata
  • ClusterMetadata
    • ClusterMetadata.add_group_coordinator()
    • ClusterMetadata.add_listener()
    • ClusterMetadata.available_partitions_for_topic()
    • ClusterMetadata.broker_metadata()
    • ClusterMetadata.brokers()
    • ClusterMetadata.coordinator_for_group()
    • ClusterMetadata.failed_update()
    • ClusterMetadata.leader_for_partition()
    • ClusterMetadata.partitions_for_broker()
    • ClusterMetadata.partitions_for_topic()
    • ClusterMetadata.refresh_backoff()
    • ClusterMetadata.remove_listener()
    • ClusterMetadata.request_update()
    • ClusterMetadata.topics()
    • ClusterMetadata.ttl()
    • ClusterMetadata.update_metadata()
    • ClusterMetadata.with_partitions()