May have been left over. Remove it if needed.

Amol

From: tweise [mailto:notifications@github.com]
Sent: Monday, September 30, 2013 12:32 PM
To: DataTorrent/Malhar
Subject: Re: [Malhar] Upgrade Kafka to 0.8 (#93)


In contrib/src/main/java/com/datatorrent/contrib/kafka/AbstractKafkaInputOperator.java:

> @@ -69,20 +83,42 @@

>    private static final Logger logger = LoggerFactory.getLogger(AbstractKafkaInputOperator.class);

>    protected static final int TUPLES_BLAST_DEFAULT = 10 * 1024; // 10k

>    protected static final int BUFFER_SIZE_DEFAULT = 1024 * 1024; // 1M

> +  protected static final String DEFAULT_HOST = "localhost";

Why do we need these values here?

—
Reply to this email directly or view it on GitHub<https://github.com/DataTorrent/Malhar/pull/93/files#r6668336>.