python kafka 代码示例
时间: 2023-10-05 19:14:03 浏览: 55
好的,以下是 Python 的 Kafka 代码示例:
```python
from kafka import KafkaProducer
from kafka import KafkaConsumer
# 生产者示例,用于向 Kafka 发送消息
producer = KafkaProducer(bootstrap_servers='localhost:9092')
producer.send('test-topic', b'hello world')
# 消费者示例,用于从 Kafka 接收消息
consumer = KafkaConsumer('test-topic', bootstrap_servers='localhost:9092')
for msg in consumer:
print(msg)
```
注意,这里需要安装 kafka-python 库。并且需要替换 bootstrap_servers 参数为你实际的 Kafka 服务器地址。
相关问题
python kafka 代码示例
以下是一个简单的 Python Kafka 代码示例,用于向 Kafka 主题发送消息:
```python
from kafka import KafkaProducer
# 设置 Kafka 服务器地址和主题名称
bootstrap_servers = ['localhost:9092']
topicName = 'test_topic'
# 创建 Kafka 生产者
producer = KafkaProducer(bootstrap_servers = bootstrap_servers)
# 发送消息到 Kafka 主题
producer.send(topicName, b'Hello, World!')
# 关闭 Kafka 生产者连接
producer.close()
```
请注意,这只是一个简单的示例,您需要根据您的实际场景修改代码以满足您的需求。
python ssl kafka 消费代码
当使用 Python 连接 Kafka 时,可以使用 `kafka-python` 库来消费消息。为了支持 SSL 连接,你需要配置 SSLContext。下面是一个示例代码:
```python
from kafka import KafkaConsumer
from ssl import create_default_context
# 创建 SSLContext 对象
ssl_context = create_default_context(sslcafile='path/to/ca.pem',
sslcertfile='path/to/cert.pem',
sslkeyfile='path/to/key.pem')
# 创建 KafkaConsumer 对象
consumer = KafkaConsumer('topic_name',
bootstrap_servers='kafka_server:port',
security_protocol='SSL',
ssl_context=ssl_context)
# 消费消息
for message in consumer:
print(message.value.decode('utf-8'))
```
在上述代码中,你需要替换以下参数:
- `'path/to/ca.pem'`:SSL CA 证书的路径。
- `'path/to/cert.pem'`:SSL 客户端证书的路径。
- `'path/to/key.pem'`:SSL 客户端证书的私钥文件的路径。
- `'topic_name'`:Kafka 主题的名称。
- `'kafka_server:port'`:Kafka 服务器的地址和端口。
确保你已经安装了 `kafka-python` 库,可以通过以下命令进行安装:
```
pip install kafka-python
```
希望这可以帮助到你!如果还有其他问题,请随时提问。
相关推荐
![pdf](https://img-home.csdnimg.cn/images/20210720083512.png)
![pdf](https://img-home.csdnimg.cn/images/20210720083512.png)
![pdf](https://img-home.csdnimg.cn/images/20210720083512.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)