擅长:python、mysql、java
<p>您看到的Scala代码是针对消费者的。所以你需要检查消费者的设置,而不是生产者的</p>
<p>如果你看<a href="https://kafka-python.readthedocs.io/en/master/apidoc/KafkaConsumer.html" rel="nofollow noreferrer">https://kafka-python.readthedocs.io/en/master/apidoc/KafkaConsumer.html</a>,你可以找到它们的等价物:</p>
<ul>
<li><code>group.id</code>:<code>group_id</code></li>
<li><code>auto.offset.reset</code>:<code>auto_offset_reset</code></li>
<li><code>enable.auto.commit</code>:<code>enable_auto_commit</code></li>
</ul>
<p>还要注意,使用者具有反序列化程序而不是序列化程序,因此:</p>
<ul>
<li><code>key.deserializer</code>:<code>key_deserializer</code></li>
<li><code>value.deserializer</code>:<code>value_deserializer</code></li>
</ul>