Small comment changes and such.

zsmj513 · Mar 10, 2011 · cf6c0a9 · cf6c0a9
1 parent cfb6b65
commit cf6c0a9
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 7 deletions.
diff --git a/clients/csharp/src/Kafka/Kafka.Client/Consumer.cs b/clients/csharp/src/Kafka/Kafka.Client/Consumer.cs
@@ -79,7 +79,7 @@ public List<Message> Consume(ConsumerRequest request)
                 {
                     byte[] data = connection.Read(dataLength);
 
-                    // remove two byte buffer
+                    // TODO: need to check in on kafka error codes...assume all's good for now
                     byte[] unbufferedData = data.Skip(2).ToArray();
 
                     int processed = 0;
@@ -129,7 +129,7 @@ public IList<long> GetOffsetsBefore(OffsetRequest request)
                 {
                     byte[] data = connection.Read(dataLength);
 
-                    // remove two byte buffer
+                    // TODO: need to check in on kafka error codes...assume all's good for now
                     byte[] unbufferedData = data.Skip(2).ToArray();
 
                     // first four bytes are the number of offsets

diff --git a/clients/csharp/src/Kafka/Tests/Kafka.Client.Tests/KafkaIntegrationTest.cs b/clients/csharp/src/Kafka/Tests/Kafka.Client.Tests/KafkaIntegrationTest.cs
@@ -26,7 +26,7 @@ public void ProducerSendsMessage()
             byte[] payloadData2 = Encoding.UTF8.GetBytes(payload2);
             Message msg2 = new Message(payloadData2);
 
-            Producer producer = new Producer("192.168.50.202", 9092);
+            Producer producer = new Producer("192.168.50.203", 9092);
             producer.Send("test", 0, new List<Message> { msg1, msg2 });
         }
 
@@ -40,7 +40,7 @@ public void ProducerSendsMessageAsynchronously()
 
             List<Message> messages = GenerateRandomMessages(50);
 
-            Producer producer = new Producer("192.168.50.202", 9092);
+            Producer producer = new Producer("192.168.50.203", 9092);
             producer.SendAsync(
                 "test",
                 0,
@@ -62,7 +62,7 @@ public void ConsumerGetsMessage()
         {
             ProducerSendsMessage();
 
-            Consumer consumer = new Consumer("192.168.50.202", 9092);
+            Consumer consumer = new Consumer("192.168.50.203", 9092);
             consumer.Consume("test", 0, 0);
         }
 
@@ -72,9 +72,9 @@ public void ConsumerGetsMessage()
         [Test]
         public void ConsumerGetsOffsets()
         {
-            OffsetRequest request = new OffsetRequest("test", 0, DateTime.Now.AddHours(-6).Ticks, 10);
+            OffsetRequest request = new OffsetRequest("test", 0, DateTime.Now.AddHours(-24).Ticks, 10);
 
-            Consumer consumer = new Consumer("192.168.50.202", 9092);
+            Consumer consumer = new Consumer("192.168.50.203", 9092);
             IList<long> list = consumer.GetOffsetsBefore(request);
 
             foreach (long l in list)