public class PutKafkaTest
extends java.lang.Object
| Constructor and Description |
|---|
PutKafkaTest() |
| Modifier and Type | Method and Description |
|---|---|
static void |
afterClass() |
static void |
beforeClass() |
void |
validateComplexLeftPartialDemarcatedMessages() |
void |
validateComplexPartialMatchDemarcatedMessages() |
void |
validateComplexRightPartialDemarcatedMessages() |
void |
validateDemarcationIntoEmptyMessages() |
void |
validateDeprecatedPartitionStrategy() |
void |
validateMultiCharacterDelimitedMessages() |
void |
validatePartitionOutOfBounds() |
void |
validateSingleCharacterDemarcatedMessages() |
public static void beforeClass()
public static void afterClass()
throws java.lang.Exception
java.lang.Exceptionpublic void validateSingleCharacterDemarcatedMessages()
public void validateMultiCharacterDelimitedMessages()
public void validateDemarcationIntoEmptyMessages()
public void validateComplexRightPartialDemarcatedMessages()
public void validateComplexLeftPartialDemarcatedMessages()
public void validateComplexPartialMatchDemarcatedMessages()
public void validateDeprecatedPartitionStrategy()
public void validatePartitionOutOfBounds()