This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
# Null messages in Kafka permanently break a Kafka topic | |
# Reproduction Requirements: | |
# Install kafka-python (master is building towards 0.9, so use the kafka-0.8.0-release branch) | |
# Run a 3 node local kafka cluster (it may break with other sizes, but it is untested) | |
# Run a kafka SimpleConsumer (kafka-console-consumer works fine): | |
# kafka_2.8.0-0.8.0/bin/kafka-console-consumer.sh kafka-console-consumer.sh --topic some_topic --zookeeper localhost:2181 --from-beginning | |
# Run this: | |
import kafka |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
try: | |
from psycopg2cffi import compat | |
compat.register() | |
except ImportError: | |
pass | |
from pyutil.decorators import * | |
import tempfile, psycopg2, psycopg2.extras | |
def setup_test_table(conn): |