/**
 * Licensed to the Apache Software Foundation (ASF) under one or more
 * contributor license agreements.  See the NOTICE file distributed with
 * this work for additional information regarding copyright ownership.
 * The ASF licenses this file to You under the Apache License, Version 2.0
 * (the "License"); you may not use this file except in compliance with
 * the License.  You may obtain a copy of the License at
 *
 *    http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
package com.pinterest.secor.message;

import java.io.IOException;
import java.io.OutputStream;
import java.lang.String;

/**
 * Message represents a raw Kafka log message.
 *
 * @author Pawel Garbacki (pawel@pinterest.com)
 */
public class Message {

    private String mTopic;
    private int mKafkaPartition;
    private long mOffset;
    private byte[] mPayload;

    protected String fieldsToString() {

	return "topic='" + mTopic + '\'' + ", kafkaPartition="
		+ mKafkaPartition + ", offset=" + mOffset + ", payload="
		+ new String(mPayload);

    }

    @Override
    public String toString() {

	return "Message{" + fieldsToString() + '}';
    }

    public Message(String topic, int kafkaPartition, long offset, byte[] payload) {

	mTopic = topic;
	mKafkaPartition = kafkaPartition;
	mOffset = offset;
	mPayload = payload;

	if (mPayload == null) {
	    mPayload = new byte[0];
	}
    }

    public String getTopic() {

	return mTopic;
    }

    public int getKafkaPartition() {

	return mKafkaPartition;
    }

    public long getOffset() {

	return mOffset;
    }

    public byte[] getPayload() {

	return mPayload;
    }

    public void write(OutputStream output) throws IOException {

	output.write(mPayload);
    }
}

@@ -1194,33 +1194,32 @@
 ldsToString() %7B%0A
-%0A
 %09return %22topic='
@@ -1343,17 +1343,16 @@
 yload);%0A
-%0A
     %7D%0A%0A 
@@ -1391,25 +1391,24 @@
 oString() %7B%0A
-%0A
 %09return %22Mes
@@ -1531,17 +1531,16 @@
 load) %7B%0A
-%0A
 %09mTopic 
@@ -1623,17 +1623,16 @@
 ayload;%0A
-%0A
 %09if (mPa
@@ -1714,25 +1714,24 @@
 etTopic() %7B%0A
-%0A
 %09return mTop
@@ -1774,25 +1774,24 @@
 rtition() %7B%0A
-%0A
 %09return mKaf
@@ -1836,25 +1836,24 @@
 tOffset() %7B%0A
-%0A
 %09return mOff
@@ -1897,17 +1897,16 @@
 oad() %7B%0A
-%0A
 %09return 
@@ -1914,32 +1914,32 @@
 Payload;%0A    %7D%0A%0A
+
     public void 
@@ -1986,17 +1986,16 @@
 ption %7B%0A
-%0A
 %09output.

remove extra spaces